From 17f461baf74f2101ce6f0b46f1c90bb4b922faee Mon Sep 17 00:00:00 2001 From: Dmitry Dodzin Date: Tue, 28 Jan 2025 11:07:37 +0200 Subject: [PATCH] Tiny --- mirrord/cli/src/external_proxy.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/mirrord/cli/src/external_proxy.rs b/mirrord/cli/src/external_proxy.rs index 8c92ad9a901..3ff76dd6bd1 100644 --- a/mirrord/cli/src/external_proxy.rs +++ b/mirrord/cli/src/external_proxy.rs @@ -81,6 +81,10 @@ pub async fn proxy(listen_port: u16, watch: drain::Watch) -> CliResult<()> { let mut analytics = AnalyticsReporter::new(config.telemetry, execution_kind, watch); (&config).collect_analytics(analytics.get_mut()); + // This connection is just to keep the agent alive as long as the client side is running. + let mut own_agent_conn = + connect_and_ping(&config, agent_connect_info.clone(), &mut analytics).await?; + let tls_acceptor = create_external_proxy_tls_acceptor(&config).await?; let listener = create_listen_socket(SocketAddr::new( local_ip().unwrap_or_else(|_| Ipv4Addr::UNSPECIFIED.into()), @@ -101,11 +105,6 @@ pub async fn proxy(listen_port: u16, watch: drain::Watch) -> CliResult<()> { config.external_proxy.start_idle_timeout, ))); - // This connection is just to keep the agent alive as long as the client side is running. - let mut own_agent_conn = connect_and_ping(&config, agent_connect_info.clone(), &mut analytics) - .await - .inspect_err(|_| cancellation_token.cancel())?; - let mut ping_pong_ticker = tokio::time::interval(Duration::from_secs(30)); loop {