Fix the tx/rx update in ProxyStream

shadowsocks · Jul 20, 2020 · edf6909 · edf6909
1 parent b56eaac
commit edf6909
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/relay/tcprelay/proxy_stream.rs b/src/relay/tcprelay/proxy_stream.rs
@@ -368,7 +368,7 @@ impl AsyncRead for ProxyStream {
         {
             if self.is_proxied() {
                 if let Poll::Ready(Ok(n)) = p {
-                    self.context().local_flow_statistic().tcp().incr_tx(n as u64);
+                    self.context().local_flow_statistic().tcp().incr_rx(n as u64);
                 }
             }
         }
@@ -386,7 +386,7 @@ impl AsyncWrite for ProxyStream {
         {
             if self.is_proxied() {
                 if let Poll::Ready(Ok(n)) = p {
-                    self.context().local_flow_statistic().tcp().incr_rx(n as u64);
+                    self.context().local_flow_statistic().tcp().incr_tx(n as u64);
                 }
             }
         }