From 45933d695118e77be77f8c003ce25fa55fff54a5 Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sat, 16 Apr 2022 12:19:40 +0100 Subject: [PATCH] reduce flakiness of deadline integration tests --- 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()