local-tun: wake poll thread on every read/write calls

- ref #1138
2026-02-09 01:59:16 +08:00 · 2023-03-12 19:40:13 +08:00
parent 23182d0435
commit 08bf30a285
1 changed files with 2 additions and 2 deletions
--- a/crates/shadowsocks-service/src/local/tun/tcp.rs
+++ b/crates/shadowsocks-service/src/local/tun/tcp.rs
@@ -149,7 +149,7 @@ impl AsyncRead for TcpConnection {
        let n = control.recv_buffer.dequeue_slice(recv_buf);
        buf.advance(n);

-        if control.recv_buffer.is_empty() {
+        if n > 0 {
            self.manager_notify.notify();
        }
        Ok(()).into()
@@ -177,7 +177,7 @@ impl AsyncWrite for TcpConnection {

        let n = control.send_buffer.enqueue_slice(buf);

-        if control.send_buffer.is_full() {
+        if n > 0 {
            self.manager_notify.notify();
        }
        Ok(n).into()