diff --git a/transport/internet/kcp/kcp.go b/transport/internet/kcp/kcp.go index 2b85d475a..4c57e8ef4 100644 --- a/transport/internet/kcp/kcp.go +++ b/transport/internet/kcp/kcp.go @@ -216,6 +216,7 @@ func (kcp *KCP) Input(data []byte) int { kcp.rmt_wnd = seg.ReceivingWindow } kcp.HandleReceivingNext(seg.ReceivingNext) + kcp.shrink_buf() for i := 0; i < int(seg.Count); i++ { ts := seg.TimestampList[i] sn := seg.NumberList[i]