Finalizing updates after testing
This commit is contained in:
parent
b40ca17fea
commit
5a947e459c
|
@ -157,6 +157,8 @@ impl<'a> DataPacket<'a> {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
self.num_blocks += 1;
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -199,8 +201,6 @@ impl DataStream {
|
||||||
// Note(unwrap): We guarantee that the socket is available above.
|
// Note(unwrap): We guarantee that the socket is available above.
|
||||||
let socket = self.socket.take().unwrap();
|
let socket = self.socket.take().unwrap();
|
||||||
self.stack.close(socket).unwrap();
|
self.stack.close(socket).unwrap();
|
||||||
|
|
||||||
log::info!("Stream Disconnecting");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
fn open(&mut self, remote: SocketAddr) -> Result<(), ()> {
|
fn open(&mut self, remote: SocketAddr) -> Result<(), ()> {
|
||||||
|
|
|
@ -73,10 +73,7 @@ impl NetworkProcessor {
|
||||||
let result = match self.stack.lock(|stack| stack.poll(now)) {
|
let result = match self.stack.lock(|stack| stack.poll(now)) {
|
||||||
Ok(true) => UpdateState::Updated,
|
Ok(true) => UpdateState::Updated,
|
||||||
Ok(false) => UpdateState::NoChange,
|
Ok(false) => UpdateState::NoChange,
|
||||||
Err(err) => {
|
Err(_) => UpdateState::Updated,
|
||||||
log::info!("Network error: {:?}", err);
|
|
||||||
UpdateState::Updated
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
|
|
||||||
result
|
result
|
||||||
|
|
Loading…
Reference in New Issue