From 5a947e459cf471a52d900b897287c3c8c6b75425 Mon Sep 17 00:00:00 2001 From: Ryan Summers Date: Fri, 11 Jun 2021 17:52:11 +0200 Subject: [PATCH] Finalizing updates after testing --- src/net/data_stream.rs | 4 ++-- src/net/network_processor.rs | 5 +---- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/src/net/data_stream.rs b/src/net/data_stream.rs index 71f087e..545abcb 100644 --- a/src/net/data_stream.rs +++ b/src/net/data_stream.rs @@ -157,6 +157,8 @@ impl<'a> DataPacket<'a> { } } + self.num_blocks += 1; + Ok(()) } @@ -199,8 +201,6 @@ impl DataStream { // Note(unwrap): We guarantee that the socket is available above. let socket = self.socket.take().unwrap(); self.stack.close(socket).unwrap(); - - log::info!("Stream Disconnecting"); } fn open(&mut self, remote: SocketAddr) -> Result<(), ()> { diff --git a/src/net/network_processor.rs b/src/net/network_processor.rs index 43d75e0..13f7035 100644 --- a/src/net/network_processor.rs +++ b/src/net/network_processor.rs @@ -73,10 +73,7 @@ impl NetworkProcessor { let result = match self.stack.lock(|stack| stack.poll(now)) { Ok(true) => UpdateState::Updated, Ok(false) => UpdateState::NoChange, - Err(err) => { - log::info!("Network error: {:?}", err); - UpdateState::Updated - } + Err(_) => UpdateState::Updated, }; result