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

http: rewrite retain function

Browse source
This commit is contained in:
Joakim Frostegård 2022-03-23 21:24:53 +01:00
parent 9b85fa31d1
commit a348fcfd2d
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
aquatic_http/src/workers/socket.rs
View file

@ -73,7 +73,6 @@ pub async fn run_socket_worker(
let connection_slab = Rc::new(RefCell::new(Slab::new())); let connection_slab = Rc::new(RefCell::new(Slab::new()));
// Periodically remove closed connections
TimerActionRepeat::repeat(enclose!((config, connection_slab) move || { TimerActionRepeat::repeat(enclose!((config, connection_slab) move || {
clean_connections( clean_connections(
config.clone(), config.clone(),
@ -139,15 +138,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();