mirrors/uquic
1
0
Fork 0
mirror of https://github.com/refraction-networking/uquic.git synced 2025-04-05 13:17:36 +03:00
Code Issues Projects Releases Packages Wiki Activity

set max tracked packets to max cwnd * 2

Browse source
This commit is contained in:
Lucas Clemente 2016-09-05 00:59:10 +02:00
parent 3b1231db81
commit 8c6eb61850
6 changed files with 9 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

2
ackhandler/received_packet_handler.go
View file

@ -75,7 +75,7 @@ func (h *receivedPacketHandler) ReceivedPacket(packetNumber protocol.PacketNumbe
h.receivedTimes[packetNumber] = time.Now() h.receivedTimes[packetNumber] = time.Now()
if uint32(len(h.receivedTimes)) > protocol.MaxTrackedReceivedPackets { if protocol.PacketNumber(len(h.receivedTimes)) > protocol.MaxTrackedReceivedPackets {
return errTooManyOutstandingReceivedPackets return errTooManyOutstandingReceivedPackets
} }

2
ackhandler/received_packet_handler_test.go
View file

@ -83,7 +83,7 @@ var _ = Describe("receivedPacketHandler", func() {
}) })
It("doesn't store more than MaxTrackedReceivedPackets packets", func() { It("doesn't store more than MaxTrackedReceivedPackets packets", func() {
for i := uint32(0); i < protocol.MaxTrackedReceivedPackets; i++ { for i := protocol.PacketNumber(0); i < protocol.MaxTrackedReceivedPackets; i++ {
packetNumber := protocol.PacketNumber(1 + 2*i) packetNumber := protocol.PacketNumber(1 + 2*i)
err := handler.ReceivedPacket(packetNumber) err := handler.ReceivedPacket(packetNumber)
Expect(err).ToNot(HaveOccurred()) Expect(err).ToNot(HaveOccurred())

2
ackhandler/sent_packet_handler.go
View file

@ -274,7 +274,7 @@ func (h *sentPacketHandler) CongestionAllowsSending() bool {
func (h *sentPacketHandler) CheckForError() error { func (h *sentPacketHandler) CheckForError() error {
length := len(h.retransmissionQueue) + h.packetHistory.Len() length := len(h.retransmissionQueue) + h.packetHistory.Len()
if uint32(length) > protocol.MaxTrackedSentPackets { if protocol.PacketNumber(length) > protocol.MaxTrackedSentPackets {
return ErrTooManyTrackedSentPackets return ErrTooManyTrackedSentPackets
} }
return nil return nil

2
ackhandler/sent_packet_handler_test.go
View file

@ -213,7 +213,7 @@ var _ = Describe("SentPacketHandler", func() {
Context("DOS mitigation", func() { Context("DOS mitigation", func() {
It("checks the size of the packet history, for unacked packets", func() { It("checks the size of the packet history, for unacked packets", func() {
for i := uint32(1); i < protocol.MaxTrackedSentPackets+10; i++ { for i := protocol.PacketNumber(1); i < protocol.MaxTrackedSentPackets+10; i++ {
packet := Packet{PacketNumber: protocol.PacketNumber(i), Frames: []frames.Frame{&streamFrame}, Length: 1} packet := Packet{PacketNumber: protocol.PacketNumber(i), Frames: []frames.Frame{&streamFrame}, Length: 1}
err := handler.SentPacket(&packet) err := handler.SentPacket(&packet)
Expect(err).ToNot(HaveOccurred()) Expect(err).ToNot(HaveOccurred())

9
protocol/server_parameters.go
View file

@ -44,7 +44,7 @@ const MaxNewStreamIDDelta = 4 * MaxStreamsPerConnection
const MaxIdleConnectionStateLifetime = 60 * time.Second const MaxIdleConnectionStateLifetime = 60 * time.Second
// MaxSessionUnprocessedPackets is the max number of packets stored in each session that are not yet processed. // MaxSessionUnprocessedPackets is the max number of packets stored in each session that are not yet processed.
const MaxSessionUnprocessedPackets = 2000 const MaxSessionUnprocessedPackets = DefaultMaxCongestionWindow
// RetransmissionThreshold + 1 is the number of times a packet has to be NACKed so that it gets retransmitted // RetransmissionThreshold + 1 is the number of times a packet has to be NACKed so that it gets retransmitted
const RetransmissionThreshold = 3 const RetransmissionThreshold = 3
@ -59,13 +59,10 @@ const MaxTrackedSkippedPackets = 10
const STKExpiryTimeSec = 24 * 60 * 60 const STKExpiryTimeSec = 24 * 60 * 60
// MaxTrackedSentPackets is maximum number of sent packets saved for either later retransmission or entropy calculation // MaxTrackedSentPackets is maximum number of sent packets saved for either later retransmission or entropy calculation
// TODO: find a reasonable value here const MaxTrackedSentPackets = 2 * DefaultMaxCongestionWindow
// TODO: decrease this value after dropping support for QUIC 33 and earlier
const MaxTrackedSentPackets = 2000
// MaxTrackedReceivedPackets is the maximum number of received packets saved for doing the entropy calculations // MaxTrackedReceivedPackets is the maximum number of received packets saved for doing the entropy calculations
// TODO: think about what to do with this when adding support for QUIC 34 const MaxTrackedReceivedPackets = 2 * DefaultMaxCongestionWindow
const MaxTrackedReceivedPackets = 2000
// MaxStreamFrameSorterGaps is the maximum number of gaps between received StreamFrames // MaxStreamFrameSorterGaps is the maximum number of gaps between received StreamFrames
// prevents DOS attacks against the streamFrameSorter // prevents DOS attacks against the streamFrameSorter

4
session_test.go
View file

@ -762,7 +762,7 @@ var _ = Describe("Session", func() {
It("errors when the SentPacketHandler has too many packets tracked", func() { It("errors when the SentPacketHandler has too many packets tracked", func() {
streamFrame := frames.StreamFrame{StreamID: 5, Data: []byte("foobar")} streamFrame := frames.StreamFrame{StreamID: 5, Data: []byte("foobar")}
for i := uint32(1); i < protocol.MaxTrackedSentPackets+10; i++ { for i := protocol.PacketNumber(1); i < protocol.MaxTrackedSentPackets+10; i++ {
packet := ackhandler.Packet{PacketNumber: protocol.PacketNumber(i), Frames: []frames.Frame{&streamFrame}, Length: 1} packet := ackhandler.Packet{PacketNumber: protocol.PacketNumber(i), Frames: []frames.Frame{&streamFrame}, Length: 1}
err := session.sentPacketHandler.SentPacket(&packet) err := session.sentPacketHandler.SentPacket(&packet)
Expect(err).ToNot(HaveOccurred()) Expect(err).ToNot(HaveOccurred())
@ -774,7 +774,7 @@ var _ = Describe("Session", func() {
It("stores up to MaxSessionUnprocessedPackets packets", func(done Done) { It("stores up to MaxSessionUnprocessedPackets packets", func(done Done) {
// Nothing here should block // Nothing here should block
for i := 0; i < protocol.MaxSessionUnprocessedPackets+10; i++ { for i := protocol.PacketNumber(0); i < protocol.MaxSessionUnprocessedPackets+10; i++ {
session.handlePacket(nil, nil, nil) session.handlePacket(nil, nil, nil)
} }
close(done) close(done)