forked from quic-go/quic-go
initialize the slow start threshold to infinity
This commit is contained in:
@@ -83,7 +83,7 @@ func newCubicSender(clock Clock, rttStats *utils.RTTStats, reno bool, initialCon
|
||||
initialMaxCongestionWindow: initialMaxCongestionWindow,
|
||||
congestionWindow: initialCongestionWindow,
|
||||
minCongestionWindow: minCongestionWindow,
|
||||
slowStartThreshold: initialMaxCongestionWindow,
|
||||
slowStartThreshold: protocol.MaxByteCount,
|
||||
maxCongestionWindow: initialMaxCongestionWindow,
|
||||
cubic: NewCubic(clock),
|
||||
clock: clock,
|
||||
|
||||
@@ -289,7 +289,7 @@ var _ = Describe("Cubic Sender", func() {
|
||||
|
||||
It("RTO congestion window", func() {
|
||||
Expect(sender.GetCongestionWindow()).To(Equal(defaultWindowTCP))
|
||||
Expect(sender.slowStartThreshold).To(Equal(MaxCongestionWindow))
|
||||
Expect(sender.slowStartThreshold).To(Equal(protocol.MaxByteCount))
|
||||
|
||||
// Expect the window to decrease to the minimum once the RTO fires
|
||||
// and slow start threshold to be set to 1/2 of the CWND.
|
||||
@@ -420,7 +420,7 @@ var _ = Describe("Cubic Sender", func() {
|
||||
|
||||
It("reset after connection migration", func() {
|
||||
Expect(sender.GetCongestionWindow()).To(Equal(defaultWindowTCP))
|
||||
Expect(sender.slowStartThreshold).To(Equal(MaxCongestionWindow))
|
||||
Expect(sender.slowStartThreshold).To(Equal(protocol.MaxByteCount))
|
||||
|
||||
// Starts with slow start.
|
||||
const numberOfAcks = 10
|
||||
|
||||
Reference in New Issue
Block a user