fix(tests): remove named pipe if it exists (#4171)

aquasecurity · Jul 3, 2024 · 96ebc05 · 96ebc05
1 parent 499c05b
commit 96ebc05
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/tests/integration/capture_test.go b/tests/integration/capture_test.go
@@ -246,7 +246,11 @@ func readWritevCaptureTest(t *testing.T, captureDir string, workingDir string) e
 
 func readWritePipe(t *testing.T, captureDir string, workingDir string) error {
 	namedPipe := fmt.Sprintf("%s/pipe_test", workingDir)
-	err := syscall.Mkfifo(namedPipe, 0666)
+	err := os.Remove(namedPipe)
+	if err != nil && !os.IsNotExist(err) {
+		return err
+	}
+	err = syscall.Mkfifo(namedPipe, 0666)
 	if err != nil {
 		return err
 	}