From f8a614714c7522d2e0568a3bba4df9b2bdef4d87 Mon Sep 17 00:00:00 2001 From: v2ray Date: Sun, 3 Jul 2016 09:38:40 +0200 Subject: [PATCH] sending window fix --- transport/internet/kcp/kcp.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/transport/internet/kcp/kcp.go b/transport/internet/kcp/kcp.go index 4c57e8ef4..2e49b3c08 100644 --- a/transport/internet/kcp/kcp.go +++ b/transport/internet/kcp/kcp.go @@ -291,10 +291,10 @@ func (kcp *KCP) flush() { // calculate window size cwnd := kcp.snd_una + kcp.snd_wnd - if cwnd < kcp.rmt_wnd { + if cwnd > kcp.rmt_wnd { cwnd = kcp.rmt_wnd } - if kcp.congestionControl && cwnd < kcp.snd_una+kcp.cwnd { + if kcp.congestionControl && cwnd > kcp.snd_una+kcp.cwnd { cwnd = kcp.snd_una + kcp.cwnd }