renet/renet
renet
/
renet
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix a warning.

This commit is contained in:
whitequark 2017-09-22 17:38:58 +00:00
parent 8166037a91
commit b90cee43bb
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/socket/tcp.rs
View File

@ -627,15 +627,14 @@ impl<'a> TcpSocket<'a> {
// another (stale) SYN. // another (stale) SYN.
if !self.may_recv() { return Err(Error::Illegal) } if !self.may_recv() { return Err(Error::Illegal) }
#[cfg(any(test, feature = "verbose"))] let _old_length = self.rx_buffer.len();
let old_length = self.rx_buffer.len();
let buffer = self.rx_buffer.dequeue_many(size); let buffer = self.rx_buffer.dequeue_many(size);
self.remote_seq_no += buffer.len(); self.remote_seq_no += buffer.len();
if buffer.len() > 0 { if buffer.len() > 0 {
#[cfg(any(test, feature = "verbose"))] #[cfg(any(test, feature = "verbose"))]
net_trace!("[{}]{}:{}: rx buffer: dequeueing {} octets (now {})", net_trace!("[{}]{}:{}: rx buffer: dequeueing {} octets (now {})",
self.debug_id, self.local_endpoint, self.remote_endpoint, self.debug_id, self.local_endpoint, self.remote_endpoint,
buffer.len(), old_length - buffer.len()); buffer.len(), _old_length - buffer.len());
} }
Ok(buffer) Ok(buffer)
} }
@ -650,14 +649,14 @@ impl<'a> TcpSocket<'a> {
// See recv() above. // See recv() above.
if !self.may_recv() { return Err(Error::Illegal) } if !self.may_recv() { return Err(Error::Illegal) }
let old_length = self.rx_buffer.len(); let _old_length = self.rx_buffer.len();
let dequeued = self.rx_buffer.dequeue_slice(data); let dequeued = self.rx_buffer.dequeue_slice(data);
self.remote_seq_no += dequeued; self.remote_seq_no += dequeued;
if dequeued > 0 { if dequeued > 0 {
#[cfg(any(test, feature = "verbose"))] #[cfg(any(test, feature = "verbose"))]
net_trace!("[{}]{}:{}: rx buffer: dequeueing {} octets (now {})", net_trace!("[{}]{}:{}: rx buffer: dequeueing {} octets (now {})",
self.debug_id, self.local_endpoint, self.remote_endpoint, self.debug_id, self.local_endpoint, self.remote_endpoint,
dequeued, old_length - dequeued); dequeued, _old_length - dequeued);
} }
Ok(dequeued) Ok(dequeued)
} }