Fix exec source leaves zombie processes after fail #814

2023-12-17 17:59:41 +03:00
parent 7036d196be
commit c63fc6a2ad
1 changed files with 6 additions and 1 deletions
@@ -83,7 +83,12 @@ func handlePipe(url string, cmd *exec.Cmd) (core.Producer, error) {
 		return nil, err
 	}

-	return magic.Open(r)
+	prod, err := magic.Open(r)
+	if err != nil {
+		_ = r.Close()
+	}
+
+	return prod, err
 }

 func handleRTSP(url, path string, cmd *exec.Cmd) (core.Producer, error) {