Increasing thread sleeps for socket listener thread and per-connection threads. ()

This commit is contained in:
David Burkett 2019-04-23 02:29:24 -04:00 committed by hashmap
parent 97e96e4fcf
commit 0e6a249126
2 changed files with 2 additions and 2 deletions

View file

@ -244,7 +244,7 @@ fn poll<H>(
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

View file

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