fix: smoltcp replace tcp recv buffer

XOR-op · Feb 20, 2025 · 8f75d43 · 8f75d43
1 parent bb6d3fe
commit 8f75d43
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/boltconn/src/transport/smol.rs b/boltconn/src/transport/smol.rs
@@ -201,7 +201,7 @@ impl TcpConnTask {
         // Receive data
         let mut has_activity = false;
         let mut accum_bytes = 0;
-        while socket.can_recv() && self.back_tx.capacity() > 0 {
+        while socket.can_recv() && !self.back_tx.is_closed() && self.back_tx.capacity() > 0 {
             let mut buf = BytesMut::with_capacity(MAX_PKT_SIZE);
             if let Ok(size) = socket.recv_slice(unsafe { mut_buf(&mut buf) }) {
                 unsafe { buf.advance_mut(size) };