From af8b9d05dfa69974bec463299a59d5f1080e9ec2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20Frosteg=C3=A5rd?= Date: Sun, 5 Apr 2020 03:18:56 +0200 Subject: [PATCH] main: add "socket_timeout" var --- aquatic/src/main.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/aquatic/src/main.rs b/aquatic/src/main.rs index 03e0046..301a118 100644 --- a/aquatic/src/main.rs +++ b/aquatic/src/main.rs @@ -9,17 +9,18 @@ use common::State; fn main(){ let addr = ([127, 0, 0, 1], 3000).into(); - let socket = network::create_socket(addr, 4096 * 8); let state = State::new(); + let socket = network::create_socket(addr, 4096 * 8); + let socket_timeout = Duration::from_millis(1000); for i in 1..4 { let socket = socket.try_clone().unwrap(); let state = state.clone(); ::std::thread::spawn(move || { - network::run_event_loop(state, socket, i, Duration::from_millis(1000)); + network::run_event_loop(state, socket, i, socket_timeout); }); } - network::run_event_loop(state, socket, 0, Duration::from_millis(1000)); + network::run_event_loop(state, socket, 0, socket_timeout); }