diff --git a/transport/internet/kcp/kcp.go b/transport/internet/kcp/kcp.go index 4c57e8ef..2e49b3c0 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 }