From 08644fc72f9e59c1e261b83b90677627aae738b3 Mon Sep 17 00:00:00 2001
From: Brandon Johnson <brandon.johnson@bluemedora.com>
Date: Wed, 16 Feb 2022 19:18:59 -0500
Subject: [PATCH] try upping wait interval when reading entries

---
 operator/builtin/input/file/rotation_test.go | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/operator/builtin/input/file/rotation_test.go b/operator/builtin/input/file/rotation_test.go
index 761d01d6..1a8b451d 100644
--- a/operator/builtin/input/file/rotation_test.go
+++ b/operator/builtin/input/file/rotation_test.go
@@ -190,6 +190,7 @@ type rotationTest struct {
 	writeInterval   time.Duration
 	pollInterval    time.Duration
 	ephemeralLines  bool
+	waitInterval    time.Duration
 }
 
 /*
@@ -259,7 +260,7 @@ func (rt rotationTest) run(tc rotationTest, copyTruncate, sequential bool) func(
 			select {
 			case e := <-logReceived:
 				received = append(received, e.Record.(string))
-			case <-time.After(100 * time.Millisecond):
+			case <-time.After(tc.waitInterval):
 				break LOOP
 			}
 		}
@@ -286,6 +287,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 		},
 		{
 			name:            "Fast/NoDeletion",
@@ -294,6 +296,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 		},
 		{
 			name:            "Fast/Deletion",
@@ -302,6 +305,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 			ephemeralLines:  true,
 		},
 		{
@@ -311,6 +315,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 			ephemeralLines:  true,
 		},
 		{
@@ -320,6 +325,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   3 * time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 		},
 		{
 			name:            "Slow/NoDeletion",
@@ -328,6 +334,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   3 * time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 		},
 		{
 			name:            "Slow/Deletion",
@@ -336,6 +343,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  1,
 			writeInterval:   3 * time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 		},
 		{
 			name:            "Slow/Deletion/ExceedFingerprint",
@@ -344,6 +352,7 @@ func TestRotation(t *testing.T) {
 			maxBackupFiles:  2,
 			writeInterval:   3 * time.Millisecond,
 			pollInterval:    10 * time.Millisecond,
+			waitInterval:    500 * time.Millisecond,
 		},
 	}