From 61471be615ffce3012bfe4e92d1ba70236960d90 Mon Sep 17 00:00:00 2001 From: Jordan Liggitt Date: Thu, 19 Nov 2020 13:59:27 -0500 Subject: [PATCH] Deflake ThrottledLogger test Kubernetes-commit: c84df5d66ea8d949374b67c5205b9869b984ea84 --- rest/request_test.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/rest/request_test.go b/rest/request_test.go index 645512b70b..4527a8afb9 100644 --- a/rest/request_test.go +++ b/rest/request_test.go @@ -2228,14 +2228,18 @@ func TestRequestPreflightCheck(t *testing.T) { func TestThrottledLogger(t *testing.T) { now := time.Now() + oldClock := globalThrottledLogger.clock + defer func() { + globalThrottledLogger.clock = oldClock + }() clock := clock.NewFakeClock(now) globalThrottledLogger.clock = clock logMessages := 0 - for i := 0; i < 10000; i++ { + for i := 0; i < 1000; i++ { var wg sync.WaitGroup - wg.Add(100) - for j := 0; j < 100; j++ { + wg.Add(10) + for j := 0; j < 10; j++ { go func() { if _, ok := globalThrottledLogger.attemptToLog(); ok { logMessages++ @@ -2248,7 +2252,7 @@ func TestThrottledLogger(t *testing.T) { clock.SetTime(now) } - if a, e := logMessages, 1000; a != e { + if a, e := logMessages, 100; a != e { t.Fatalf("expected %v log messages, but got %v", e, a) } }