diff --git a/src/rpc.rs b/src/rpc.rs index 502c0ed..790bdfa 100644 --- a/src/rpc.rs +++ b/src/rpc.rs @@ -515,6 +515,7 @@ impl RPC { info!("RPC server running on {}", addr); loop { let (stream, addr) = listener.accept().expect("accept failed"); + stream.set_nonblocking(false).expect("failed to set connection as blocking"); acceptor.send(Some((stream, addr))).expect("send failed"); } });