Equalize some of the timeouts

observIQ · Feb 23, 2022 · c97bd1a · c97bd1a
1 parent 99ea77f
commit c97bd1a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/operator/builtin/input/file/rotation_test.go b/operator/builtin/input/file/rotation_test.go
@@ -259,7 +259,7 @@ func (rt rotationTest) run(tc rotationTest, copyTruncate, sequential bool) func(
 			select {
 			case e := <-logReceived:
 				received = append(received, e.Record.(string))
-			case <-time.After(200 * time.Millisecond):
+			case <-time.After(3 * time.Second):
 				break LOOP
 			}
 		}

diff --git a/operator/builtin/input/file/util_test.go b/operator/builtin/input/file/util_test.go
@@ -143,7 +143,7 @@ LOOP:
 		select {
 		case e := <-c:
 			receivedMessages = append(receivedMessages, e.Record.(string))
-		case <-time.After(time.Second):
+		case <-time.After(3 * time.Second):
 			break LOOP
 		}
 	}
@@ -152,7 +152,7 @@ LOOP:
 }
 
 func expectNoMessages(t *testing.T, c chan *entry.Entry) {
-	expectNoMessagesUntil(t, c, 200*time.Millisecond)
+	expectNoMessagesUntil(t, c, 3*time.Second)
 }
 
 func expectNoMessagesUntil(t *testing.T, c chan *entry.Entry, d time.Duration) {