From 46f83e9c48a0e3240166debd6e5ac571a54be75d Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Mon, 25 Apr 2022 12:00:33 +0100 Subject: [PATCH] reduce flakiness of deadline integration tests (#3383) --- integrationtests/self/deadline_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/integrationtests/self/deadline_test.go b/integrationtests/self/deadline_test.go index 5400d917709..188350cae67 100644 --- a/integrationtests/self/deadline_test.go +++ b/integrationtests/self/deadline_test.go @@ -49,7 +49,7 @@ var _ = Describe("Stream deadline tests", func() { server, serverStr, clientStr := setup() defer server.Close() - const timeout = 20 * time.Millisecond + const timeout = time.Millisecond done := make(chan struct{}) go func() { defer GinkgoRecover() @@ -75,7 +75,7 @@ var _ = Describe("Stream deadline tests", func() { bytesRead += n } Expect(data).To(Equal(PRDataLong)) - // make sure the test actually worked an Read actually ran into the deadline a few times + // make sure the test actually worked and Read actually ran into the deadline a few times Expect(timeoutCounter).To(BeNumerically(">=", 10)) Eventually(done).Should(BeClosed()) }) @@ -84,7 +84,7 @@ var _ = Describe("Stream deadline tests", func() { server, serverStr, clientStr := setup() defer server.Close() - const timeout = 20 * time.Millisecond + const timeout = time.Millisecond go func() { defer GinkgoRecover() _, err := serverStr.Write(PRDataLong) @@ -134,7 +134,7 @@ var _ = Describe("Stream deadline tests", func() { server, serverStr, clientStr := setup() defer server.Close() - const timeout = 20 * time.Millisecond + const timeout = time.Millisecond done := make(chan struct{}) go func() { defer GinkgoRecover() @@ -167,7 +167,7 @@ var _ = Describe("Stream deadline tests", func() { server, serverStr, clientStr := setup() defer server.Close() - const timeout = 20 * time.Millisecond + const timeout = time.Millisecond readDone := make(chan struct{}) go func() { defer GinkgoRecover()