From 8f68b3a9a2fe48fefd3ce99e2abe45a1a6afb980 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Mon, 13 Apr 2020 12:50:53 +0200 Subject: [PATCH] aquatic: config: change default settings --- aquatic/src/lib/config.rs | 6 +++--- aquatic/src/lib/handlers.rs | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/aquatic/src/lib/config.rs b/aquatic/src/lib/config.rs index 2edafb7..265d63a 100644 --- a/aquatic/src/lib/config.rs +++ b/aquatic/src/lib/config.rs @@ -40,7 +40,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_ms: u64, + pub channel_recv_timeout_microseconds: u64, } @@ -93,8 +93,8 @@ impl Default for NetworkConfig { impl Default for HandlerConfig { fn default() -> Self { Self { - max_requests_per_iter: 2048, - channel_recv_timeout_ms: 1, + max_requests_per_iter: 10000, + channel_recv_timeout_microseconds: 200, } } } diff --git a/aquatic/src/lib/handlers.rs b/aquatic/src/lib/handlers.rs index c1699de..4f35814 100644 --- a/aquatic/src/lib/handlers.rs +++ b/aquatic/src/lib/handlers.rs @@ -28,8 +28,8 @@ pub fn run_request_worker( let mut std_rng = StdRng::from_entropy(); let mut small_rng = SmallRng::from_rng(&mut std_rng).unwrap(); - let timeout = Duration::from_millis( - config.handlers.channel_recv_timeout_ms + let timeout = Duration::from_micros( + config.handlers.channel_recv_timeout_microseconds ); loop {