nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-05-03 06:51:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

possible fix on shutdown (use interval not sleep)

Browse Source
This commit is contained in:
Mike Dilger 2024-02-20 09:07:35 +13:00
parent 9c7c92acd0
commit 5311314fce
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main.rs
View File

@ -143,8 +143,8 @@ async fn main() -> Result<(), Error> {
log::info!("Waiting for {num_clients} websockets to shutdown..."); log::info!("Waiting for {num_clients} websockets to shutdown...");
// We will check if all clients have shutdown every 25ms // We will check if all clients have shutdown every 25ms
let sleep = tokio::time::sleep(Duration::from_millis(25)); let interval = tokio::time::interval(Duration::from_millis(25));
tokio::pin!(sleep); tokio::pin!(interval);
while num_clients != 0 { while num_clients != 0 {
// If we get another shutdown signal, stop waiting for websockets // 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() { v = terminate_signal.recv() => if v.is_some() {
break; break;
}, },
() = &mut sleep => { _instant = interval.tick() => {
num_clients = GLOBALS.num_clients.load(Ordering::Relaxed); num_clients = GLOBALS.num_clients.load(Ordering::Relaxed);
continue; continue;
} }