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() {