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

fix flaky accept queue integration test

Browse source
This commit is contained in:
Marten Seemann 2021-03-05 11:55:36 +08:00
parent f513437854
commit 67503f9d41
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
integrationtests/self/handshake_test.go
View file

@ -340,7 +340,7 @@ var _ = Describe("Handshake tests", func() {
Expect(err).ToNot(HaveOccurred())
defer sess.CloseWithError(0, "")
}
time.Sleep(25 * time.Millisecond) // wait a bit for the sessions to be queued
time.Sleep(scaleDuration(20 * time.Millisecond)) // wait a bit for the sessions to be queued
_, err = dial()
Expect(err).To(HaveOccurred())
@ -349,12 +349,13 @@ var _ = Describe("Handshake tests", func() {
// Now close the one of the session that are waiting to be accepted.
// This should free one spot in the queue.
Expect(firstSess.CloseWithError(0, ""))
time.Sleep(25 * time.Millisecond)
Eventually(firstSess.Context().Done()).Should(BeClosed())
time.Sleep(scaleDuration(20 * time.Millisecond))
// dial again, and expect that this dial succeeds
_, err = dial()
Expect(err).ToNot(HaveOccurred())
time.Sleep(25 * time.Millisecond) // wait a bit for the session to be queued
time.Sleep(scaleDuration(20 * time.Millisecond)) // wait a bit for the session to be queued
_, err = dial()
Expect(err).To(HaveOccurred())