From d201ecb03b8bea080ec939fa9e252dc137a953b9 Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sun, 11 Aug 2019 19:50:18 +0700 Subject: [PATCH] fix flaky stateless reset integration test --- integrationtests/self/stateless_reset_test.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/integrationtests/self/stateless_reset_test.go b/integrationtests/self/stateless_reset_test.go index a8e1fe43b..3fbd404ae 100644 --- a/integrationtests/self/stateless_reset_test.go +++ b/integrationtests/self/stateless_reset_test.go @@ -92,12 +92,13 @@ var _ = Describe("Stateless Resets", func() { close(acceptStopped) }() - // trigger something (not too small) to be sent, - // so that we receive the stateless reset - _, err = str.Write([]byte("Lorem ipsum dolor sit amet.")) - Expect(err).ToNot(HaveOccurred()) - _, err = str.Read([]byte{0}) - Expect(err).To(MatchError("INTERNAL_ERROR: received a stateless reset")) + // Trigger something (not too small) to be sent, so that we receive the stateless reset. + // If the client already sent another packet, it might already have received a packet. + _, serr := str.Write([]byte("Lorem ipsum dolor sit amet.")) + if serr == nil { + _, serr = str.Read([]byte{0}) + } + Expect(serr).To(MatchError("INTERNAL_ERROR: received a stateless reset")) Expect(ln2.Close()).To(Succeed()) Eventually(acceptStopped).Should(BeClosed())