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

ignore duplicate packets

Browse Source 
fixes #197
This commit is contained in:
Marten Seemann
2016-07-03 23:22:12 +08:00
parent 3e604a274d
commit 8071fda5ee
2 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
session.go
View File

@@ -240,6 +240,11 @@ func (s *Session) handlePacketImpl(remoteAddr interface{}, hdr *publicHeader, da
} }
err = s.receivedPacketHandler.ReceivedPacket(hdr.PacketNumber, packet.entropyBit) err = s.receivedPacketHandler.ReceivedPacket(hdr.PacketNumber, packet.entropyBit)
// ignore duplicate packets
if err == ackhandlerlegacy.ErrDuplicatePacket {
return nil
}
if err != nil { if err != nil {
return err return err
} }

8
session_test.go
View File

@@ -426,6 +426,14 @@ var _ = Describe("Session", func() {
Expect(err).ToNot(HaveOccurred()) Expect(err).ToNot(HaveOccurred())
Expect(session.lastRcvdPacketNumber).To(Equal(protocol.PacketNumber(3))) Expect(session.lastRcvdPacketNumber).To(Equal(protocol.PacketNumber(3)))
}) })
It("ignores duplicate packets", func() {
hdr.PacketNumber = 5
err := session.handlePacketImpl(nil, hdr, nil)
Expect(err).ToNot(HaveOccurred())
err = session.handlePacketImpl(nil, hdr, nil)
Expect(err).ToNot(HaveOccurred())
})
}) })
Context("sending packets", func() { Context("sending packets", func() {