From 260b0c7767d2c702392038539d7575f2f9e26a96 Mon Sep 17 00:00:00 2001 From: Ryan Summers Date: Tue, 15 Jun 2021 14:19:28 +0200 Subject: [PATCH] Updating comments --- src/net/data_stream.rs | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/net/data_stream.rs b/src/net/data_stream.rs index 5528b02..852cba4 100644 --- a/src/net/data_stream.rs +++ b/src/net/data_stream.rs @@ -293,9 +293,10 @@ impl DataStream { let mut socket = self.stack.socket().map_err(|_| ())?; + // Note(unwrap): We only connect with a new socket, so it is guaranteed to not already be + // bound. self.stack.connect(&mut socket, remote).unwrap(); - // Note(unwrap): The socket will be empty before we replace it. self.socket.replace(socket); Ok(()) @@ -320,9 +321,9 @@ impl DataStream { pub fn process(&mut self) { // If there's no socket available, try to connect to our remote. if self.socket.is_none() { - // If we still can't open the remote, continue. + // If we can't open the socket (e.g. we do not have an IP address yet), clear data from + // the queue. if self.open(self.remote).is_err() { - // Clear the queue out. while self.queue.ready() { self.queue.dequeue(); }