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

fix flaky INVALID_TOKEN server test

Browse source
This commit is contained in:
Marten Seemann 2021-07-06 10:31:46 -07:00
parent 20547329e8
commit adcb1ea5de
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
server_test.go
View file

@ -568,10 +568,12 @@ var _ = Describe("Server", func() {
packet := getPacket(hdr, make([]byte, protocol.MinInitialPacketSize)) packet := getPacket(hdr, make([]byte, protocol.MinInitialPacketSize))
packet.data[len(packet.data)-10] ^= 0xff // corrupt the packet packet.data[len(packet.data)-10] ^= 0xff // corrupt the packet
packet.remoteAddr = &net.UDPAddr{IP: net.IPv4(127, 0, 0, 1), Port: 1337} packet.remoteAddr = &net.UDPAddr{IP: net.IPv4(127, 0, 0, 1), Port: 1337}
tracer.EXPECT().DroppedPacket(packet.remoteAddr, logging.PacketTypeInitial, packet.Size(), logging.PacketDropPayloadDecryptError) done := make(chan struct{})
tracer.EXPECT().DroppedPacket(packet.remoteAddr, logging.PacketTypeInitial, packet.Size(), logging.PacketDropPayloadDecryptError).Do(func(net.Addr, logging.PacketType, protocol.ByteCount, logging.PacketDropReason) { close(done) })
serv.handlePacket(packet) serv.handlePacket(packet)
// make sure there are no Write calls on the packet conn // make sure there are no Write calls on the packet conn
time.Sleep(50 * time.Millisecond) time.Sleep(50 * time.Millisecond)
Eventually(done).Should(BeClosed())
}) })
It("creates a session, if no Token is required", func() { It("creates a session, if no Token is required", func() {