try upping wait interval when reading entries

observIQ · Feb 18, 2022 · 08644fc · 08644fc
1 parent 4677b2b
commit 08644fc
Showing 1 changed file with 10 additions and 1 deletion.
diff --git 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,
 		},
 	}