forked from quic-go/quic-go
simplify x = x <op> ... to x <op>= ...
This commit is contained in:
@@ -633,7 +633,7 @@ func (h *sentPacketHandler) computeRTOTimeout() time.Duration {
|
|||||||
}
|
}
|
||||||
rto = utils.MaxDuration(rto, minRTOTimeout)
|
rto = utils.MaxDuration(rto, minRTOTimeout)
|
||||||
// Exponential backoff
|
// Exponential backoff
|
||||||
rto = rto << h.rtoCount
|
rto <<= h.rtoCount
|
||||||
return utils.MinDuration(rto, maxRTOTimeout)
|
return utils.MinDuration(rto, maxRTOTimeout)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -193,7 +193,7 @@ func (c *cubicSender) OnPacketLost(
|
|||||||
if c.congestionWindow >= 2*c.initialCongestionWindow {
|
if c.congestionWindow >= 2*c.initialCongestionWindow {
|
||||||
c.minSlowStartExitWindow = c.congestionWindow / 2
|
c.minSlowStartExitWindow = c.congestionWindow / 2
|
||||||
}
|
}
|
||||||
c.congestionWindow = c.congestionWindow - protocol.DefaultTCPMSS
|
c.congestionWindow -= protocol.DefaultTCPMSS
|
||||||
} else if c.reno {
|
} else if c.reno {
|
||||||
c.congestionWindow = protocol.ByteCount(float32(c.congestionWindow) * c.RenoBeta())
|
c.congestionWindow = protocol.ByteCount(float32(c.congestionWindow) * c.RenoBeta())
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user