YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ws: rewrite connection cleaning retain fn

Browse source
This commit is contained in:
Joakim Frostegård 2022-03-23 21:38:30 +01:00
parent 775607da3c
commit f0a1b8e1e1
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
aquatic_ws/src/workers/socket.rs
View file

@ -156,15 +156,15 @@ async fn clean_connections(
let now = Instant::now(); let now = Instant::now();
connection_slab.borrow_mut().retain(|_, reference| { connection_slab.borrow_mut().retain(|_, reference| {
let keep = reference.valid_until.0 > now; if reference.valid_until.0 > now {
true
if !keep { } else {
if let Some(ref handle) = reference.task_handle { if let Some(ref handle) = reference.task_handle {
handle.cancel(); handle.cancel();
} }
}
keep false
}
}); });
connection_slab.borrow_mut().shrink_to_fit(); connection_slab.borrow_mut().shrink_to_fit();