congestion/cubic.go: added a minimum window

cooldogedev · Oct 11, 2024 · f00f31f · f00f31f
1 parent 74f86aa
commit f00f31f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/congestion/cubic.go b/internal/congestion/cubic.go
@@ -10,6 +10,7 @@ import (
 
 const (
 	initialWindow = protocol.MaxPacketSize * 32
+	minWindow     = protocol.MaxPacketSize * 2
 	maxWindow     = protocol.MaxPacketSize * 10000
 
 	cubicC    = 0.7
@@ -69,7 +70,7 @@ func (c *Cubic) OnAck(bytes float64) {
 func (c *Cubic) OnLoss(bytes float64) {
 	c.mu.Lock()
 	c.wMax = c.cwnd
-	c.cwnd *= cubicBeta
+	c.cwnd = max(c.cwnd*cubicBeta, minWindow)
 	c.inFlight = max(c.inFlight-bytes, 0)
 	c.ssthresh = c.cwnd
 	c.epochStart = time.Time{}