A bugfix

karolba · karolba · commit 602522b15e0a · 2023-09-24T03:53:34.000+02:00
diff --git a/main.go b/main.go
@@ -290,7 +290,7 @@ func main() {
 		os.Exit(0)
 	}
 
-	if !*flRecursiveProcessLimit {
+	if *flRecursiveProcessLimit {
 		if _, hasMasterLimitServer := os.LookupEnv(EnvGparallelChildLimitSocket); !hasMasterLimitServer {
 			createLimitServer()
 		}
diff --git a/runner.go b/runner.go
@@ -345,6 +345,7 @@ func runWithStdin(command []string, stdin io.Reader) (result *ProcessResult) {
 		var exitErr *exec.ExitError
 		if errors.As(err, &exitErr) {
 			result.exitCode <- exitErr.ExitCode()
+			return
 		}
 		if err != nil {
 			log.Fatalf("Failed to wait for command %s: %v\n", shellescape.QuoteCommand(command), err)

Original file line number	Diff line number	Diff line change
`@@ -290,7 +290,7 @@ func main() {`
`290`	`290`	`os.Exit(0)`
`291`	`291`	`}`
`292`	`292`
`293`		`- if !*flRecursiveProcessLimit {`
	`293`	`+ if *flRecursiveProcessLimit {`
`294`	`294`	`if _, hasMasterLimitServer := os.LookupEnv(EnvGparallelChildLimitSocket); !hasMasterLimitServer {`
`295`	`295`	`createLimitServer()`
`296`	`296`	`}`
Original file line number	Diff line number	Diff line change
`@@ -345,6 +345,7 @@ func runWithStdin(command []string, stdin io.Reader) (result *ProcessResult) {`
`345`	`345`	`var exitErr *exec.ExitError`
`346`	`346`	`if errors.As(err, &exitErr) {`
`347`	`347`	`result.exitCode <- exitErr.ExitCode()`
	`348`	`+ return`
`348`	`349`	`}`
`349`	`350`	`if err != nil {`
`350`	`351`	`log.Fatalf("Failed to wait for command %s: %v\n", shellescape.QuoteCommand(command), err)`