diff --git a/mixnode/src/node/listener.rs b/mixnode/src/node/listener.rs index 24b541f2d9..eef3e8b35a 100644 --- a/mixnode/src/node/listener.rs +++ b/mixnode/src/node/listener.rs @@ -41,7 +41,7 @@ async fn process_socket_connection( ) { let mut buf = [0u8; sphinx::PACKET_SIZE]; loop { - match socket.read(&mut buf).await { + match socket.read_exact(&mut buf).await { // socket closed Ok(n) if n == 0 => { trace!("Remote connection closed."); diff --git a/sfw-provider/src/provider/mix_handling/listener.rs b/sfw-provider/src/provider/mix_handling/listener.rs index 70a37c7841..8bcc13fe7e 100644 --- a/sfw-provider/src/provider/mix_handling/listener.rs +++ b/sfw-provider/src/provider/mix_handling/listener.rs @@ -29,7 +29,7 @@ async fn process_socket_connection( ) { let mut buf = [0u8; sphinx::PACKET_SIZE]; loop { - match socket.read(&mut buf).await { + match socket.read_exact(&mut buf).await { // socket closed Ok(n) if n == 0 => { trace!("Remote connection closed.");