From bd4752a6ab9ecb0e3de6e4a2d515fc70d2c43c00 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Sun, 8 Jul 2018 22:08:26 +0200 Subject: [PATCH] fix total inflight size --- transport/internet/kcp/sending.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/transport/internet/kcp/sending.go b/transport/internet/kcp/sending.go index 0a877377..4d5d47ce 100644 --- a/transport/internet/kcp/sending.go +++ b/transport/internet/kcp/sending.go @@ -142,6 +142,11 @@ func (sw *SendingWindow) Remove(number uint32) bool { if seg.Number > number { return false } else if seg.Number == number { + if sw.totalInFlightSize > 0 { + sw.totalInFlightSize-- + } + seg.Release() + sw.cache.Remove(e) return true } }