gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

rename loss delay variable in sent packet handler

Browse Source 
That's how it's called in the WG draft pseudo code.
This commit is contained in:
Marten Seemann
2019-04-16 11:25:58 +09:00
parent 9967b9d797
commit 9dc29effdf
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/ackhandler/sent_packet_handler.go
View File

@@ -340,7 +340,7 @@ func (h *sentPacketHandler) detectLostPackets(
pnSpace := h.getPacketNumberSpace(encLevel)
maxRTT := float64(utils.MaxDuration(h.rttStats.LatestRTT(), h.rttStats.SmoothedRTT()))
delayUntilLost := time.Duration((1.0 + timeReorderingFraction) * maxRTT)
lossDelay := time.Duration((1.0 + timeReorderingFraction) * maxRTT)
var lostPackets []*Packet
pnSpace.history.Iterate(func(packet *Packet) (bool, error) {
@@ -349,14 +349,14 @@ func (h *sentPacketHandler) detectLostPackets(
}
timeSinceSent := now.Sub(packet.SendTime)
if timeSinceSent > delayUntilLost {
if timeSinceSent > lossDelay {
lostPackets = append(lostPackets, packet)
} else if h.lossTime.IsZero() && encLevel == protocol.Encryption1RTT {
if h.logger.Debug() {
h.logger.Debugf("\tsetting loss timer for packet %#x to %s (in %s)", packet.PacketNumber, delayUntilLost, delayUntilLost-timeSinceSent)
h.logger.Debugf("\tsetting loss timer for packet %#x to %s (in %s)", packet.PacketNumber, lossDelay, lossDelay-timeSinceSent)
}
// Note: This conditional is only entered once per call
h.lossTime = now.Add(delayUntilLost - timeSinceSent)
h.lossTime = now.Add(lossDelay - timeSinceSent)
}
return true, nil
})