From 689ca503e2aded182de812c6bdbd691f355b7a9b Mon Sep 17 00:00:00 2001
From: Lijun Wang <83639177+lijunwangs@users.noreply.github.com>
Date: Thu, 22 Jun 2023 15:18:05 -0700
Subject: [PATCH] Remove a unnecessary sleep in run server (#32216)

remove sleep; and handle initializing connection as soon as available
---
 streamer/src/nonblocking/quic.rs | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/streamer/src/nonblocking/quic.rs b/streamer/src/nonblocking/quic.rs
index fd9fcbb62..4299a0424 100644
--- a/streamer/src/nonblocking/quic.rs
+++ b/streamer/src/nonblocking/quic.rs
@@ -36,10 +36,7 @@ use {
         },
         time::{Duration, Instant},
     },
-    tokio::{
-        task::JoinHandle,
-        time::{sleep, timeout},
-    },
+    tokio::{task::JoinHandle, time::timeout},
 };
 
 const WAIT_FOR_STREAM_TIMEOUT: Duration = Duration::from_millis(100);
@@ -135,7 +132,6 @@ async fn run_server(
     coalesce: Duration,
 ) {
     const WAIT_FOR_CONNECTION_TIMEOUT: Duration = Duration::from_secs(1);
-    const WAIT_BETWEEN_NEW_CONNECTIONS: Duration = Duration::from_millis(1);
     debug!("spawn quic server");
     let mut last_datapoint = Instant::now();
     let unstaked_connection_table: Arc<Mutex<ConnectionTable>> = Arc::new(Mutex::new(
@@ -173,7 +169,6 @@ async fn run_server(
                 stats.clone(),
                 wait_for_chunk_timeout,
             ));
-            sleep(WAIT_BETWEEN_NEW_CONNECTIONS).await;
         } else {
             debug!("accept(): Timed out waiting for connection");
         }