From 5311314fce5d8cbfa65b972721ab53e94f43ff0e Mon Sep 17 00:00:00 2001 From: Mike Dilger Date: Tue, 20 Feb 2024 09:07:35 +1300 Subject: [PATCH] possible fix on shutdown (use interval not sleep) --- src/main.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main.rs b/src/main.rs index 828aa0e..43a9928 100644 --- a/src/main.rs +++ b/src/main.rs @@ -143,8 +143,8 @@ async fn main() -> Result<(), Error> { log::info!("Waiting for {num_clients} websockets to shutdown..."); // We will check if all clients have shutdown every 25ms - let sleep = tokio::time::sleep(Duration::from_millis(25)); - tokio::pin!(sleep); + let interval = tokio::time::interval(Duration::from_millis(25)); + tokio::pin!(interval); while num_clients != 0 { // If we get another shutdown signal, stop waiting for websockets @@ -158,7 +158,7 @@ async fn main() -> Result<(), Error> { v = terminate_signal.recv() => if v.is_some() { break; }, - () = &mut sleep => { + _instant = interval.tick() => { num_clients = GLOBALS.num_clients.load(Ordering::Relaxed); continue; }