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

fix session RTO test for version 34

Browse source
This commit is contained in:
Lucas Clemente 2016-08-12 22:19:44 +02:00
parent 7796fad2b7
commit 61e06de838
1 changed files with 16 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

23
session_test.go
View file

@ -729,24 +729,33 @@ var _ = Describe("Session", func() {
err := session.sentPacketHandler.SentPacket(&ackhandlerlegacy.Packet{PacketNumber: p, Length: 1})
Expect(err).NotTo(HaveOccurred())
time.Sleep(time.Microsecond)
ack := frames.AckFrameLegacy{LargestObserved: p}
err = session.sentPacketHandler.ReceivedAck(&frames.AckFrame{AckFrameLegacy: &ack}, p)
ack := &frames.AckFrame{}
if version == protocol.Version33 {
ack.AckFrameLegacy = &frames.AckFrameLegacy{LargestObserved: p}
} else {
ack.LargestAcked = p
}
err = session.sentPacketHandler.ReceivedAck(ack, p)
Expect(err).NotTo(HaveOccurred())
}
if version == protocol.Version33 {
session.packer.lastPacketNumber = n
} else {
session.packer.packetNumberGenerator.last = n
}
// Now, we send a single packet, and expect that it was retransmitted later
go session.run()
Expect(conn.written).To(BeEmpty())
err := session.sentPacketHandler.SentPacket(&ackhandlerlegacy.Packet{
PacketNumber: n,
Length: 1,
Frames: []frames.Frame{&frames.StreamFrame{
Data: bytes.Repeat([]byte{'a'}, 1000),
Data: []byte("foobar"),
}},
})
session.packer.lastPacketNumber = n
Expect(err).NotTo(HaveOccurred())
go session.run()
session.scheduleSending()
Eventually(func() bool { return len(conn.written) > 0 }).Should(BeTrue())
Eventually(func() [][]byte { return conn.written }).ShouldNot(BeEmpty())
Expect(conn.written[0]).To(ContainSubstring("foobar"))
})
Context("counting streams", func() {