From f5b93fbd3ebc10a11e8bb5db38dea133cd1c8e84 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Wed, 3 Nov 2021 01:05:49 +0100 Subject: [PATCH] aquatic_udp: mio: fix bug where connections were cleaned all the time --- aquatic_udp/src/lib/mio/network.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/aquatic_udp/src/lib/mio/network.rs b/aquatic_udp/src/lib/mio/network.rs index f7143e6..dfe00d6 100644 --- a/aquatic_udp/src/lib/mio/network.rs +++ b/aquatic_udp/src/lib/mio/network.rs @@ -52,6 +52,8 @@ pub fn run_socket_worker( let timeout = Duration::from_millis(50); + let cleaning_duration = Duration::from_secs(config.cleaning.connection_cleaning_interval); + let mut iter_counter = 0usize; let mut last_cleaning = Instant::now(); @@ -88,9 +90,7 @@ pub fn run_socket_worker( if iter_counter % 32 == 0 { let now = Instant::now(); - if last_cleaning + Duration::from_secs(config.cleaning.connection_cleaning_interval) - > now - { + if now > last_cleaning + cleaning_duration { connections.clean(); last_cleaning = now;