From 0e6a2491262765a6d550354cf0520acb7b7b4d82 Mon Sep 17 00:00:00 2001 From: David Burkett Date: Tue, 23 Apr 2019 02:29:24 -0400 Subject: [PATCH] Increasing thread sleeps for socket listener thread and per-connection threads. (#2773) --- p2p/src/conn.rs | 2 +- p2p/src/serv.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/p2p/src/conn.rs b/p2p/src/conn.rs index 06a8a206..d6313929 100644 --- a/p2p/src/conn.rs +++ b/p2p/src/conn.rs @@ -244,7 +244,7 @@ fn poll( let _ = thread::Builder::new() .name("peer".to_string()) .spawn(move || { - let sleep_time = time::Duration::from_millis(1); + let sleep_time = time::Duration::from_millis(5); let mut retry_send = Err(()); loop { // check the read end diff --git a/p2p/src/serv.rs b/p2p/src/serv.rs index 8488a116..5cbb1614 100644 --- a/p2p/src/serv.rs +++ b/p2p/src/serv.rs @@ -73,7 +73,7 @@ impl Server { let listener = TcpListener::bind(addr)?; listener.set_nonblocking(true)?; - let sleep_time = Duration::from_millis(1); + let sleep_time = Duration::from_millis(5); loop { // Pause peer ingress connection request. Only for tests. if self.stop_state.lock().is_paused() {