From 7afaa2702ad92b8055d0eb539edb34fbbfe01972 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= <joakim.frostegard@gmail.com>
Date: Tue, 16 Nov 2021 23:06:29 +0100
Subject: [PATCH] udp: config: request worker timeout in ms instead of
 microseconds

---
 aquatic_udp/src/lib/config.rs   | 4 ++--
 aquatic_udp/src/lib/handlers.rs | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/aquatic_udp/src/lib/config.rs b/aquatic_udp/src/lib/config.rs
index 8f2b8a2..9bd5bc7 100644
--- a/aquatic_udp/src/lib/config.rs
+++ b/aquatic_udp/src/lib/config.rs
@@ -75,7 +75,7 @@ pub struct HandlerConfig {
     /// Maximum number of requests to receive from channel before locking
     /// mutex and starting work
     pub max_requests_per_iter: usize,
-    pub channel_recv_timeout_microseconds: u64,
+    pub channel_recv_timeout_ms: u64,
 }
 
 #[derive(Clone, Debug, Serialize, Deserialize)]
@@ -143,7 +143,7 @@ impl Default for HandlerConfig {
     fn default() -> Self {
         Self {
             max_requests_per_iter: 10000,
-            channel_recv_timeout_microseconds: 200,
+            channel_recv_timeout_ms: 100,
         }
     }
 }
diff --git a/aquatic_udp/src/lib/handlers.rs b/aquatic_udp/src/lib/handlers.rs
index 44c934d..1f478c4 100644
--- a/aquatic_udp/src/lib/handlers.rs
+++ b/aquatic_udp/src/lib/handlers.rs
@@ -22,7 +22,7 @@ pub fn run_request_worker(
     let mut torrents = TorrentMaps::default();
     let mut small_rng = SmallRng::from_entropy();
 
-    let timeout = Duration::from_micros(config.handlers.channel_recv_timeout_microseconds);
+    let timeout = Duration::from_millis(config.handlers.channel_recv_timeout_ms);
 
     loop {
         if let Ok((sender_index, request, src)) = request_receiver.recv_timeout(timeout) {