Fix deadlock on huge input #435

Author: edoardottt

go.mod

@@ -41,7 +41,7 @@ require (
 	github.com/minio/minlz v1.0.1 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
-	github.com/nwaples/rardecode/v2 v2.2.0 // indirect
+	github.com/nwaples/rardecode/v2 v2.1.1 // indirect
 	github.com/pierrec/lz4/v4 v4.1.22 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect

go.sum

@@ -131,8 +131,8 @@ github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
-github.com/nwaples/rardecode/v2 v2.2.0 h1:4ufPGHiNe1rYJxYfehALLjup4Ls3ck42CWwjKiOqu0A=
-github.com/nwaples/rardecode/v2 v2.2.0/go.mod h1:7uz379lSxPe6j9nvzxUZ+n7mnJNgjsRNb6IbvGVHRmw=
+github.com/nwaples/rardecode/v2 v2.1.1 h1:OJaYalXdliBUXPmC8CZGQ7oZDxzX1/5mQmgn0/GASew=
+github.com/nwaples/rardecode/v2 v2.1.1/go.mod h1:7uz379lSxPe6j9nvzxUZ+n7mnJNgjsRNb6IbvGVHRmw=
 github.com/pierrec/lz4/v4 v4.1.22 h1:cKFw6uJDK+/gfw5BcDL0JL5aBsAFdsIT18eRtLj7VIU=
 github.com/pierrec/lz4/v4 v4.1.22/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=

pkg/csprecon/csprecon.go

@@ -58,17 +58,17 @@ func New(options *input.Options) Runner {
 }
 
 func (r *Runner) Run() {
-	r.InWg.Add(1)
+	r.OutWg.Add(1)
 
-	go pushInput(r)
+	go pullOutput(r)
 
 	r.InWg.Add(1)
 
 	go execute(r)
 
-	r.OutWg.Add(1)
+	r.InWg.Add(1)
 
-	go pullOutput(r)
+	go pushInput(r)
 
 	r.InWg.Wait()
 
@@ -150,7 +150,7 @@ func execute(r *Runner) {
 				if err != nil {
 					gologger.Error().Msgf("%s", err)
 
-					return
+					continue
 				}
 
 				rl.Take()
@@ -159,7 +159,7 @@ func execute(r *Runner) {
 				if err != nil {
 					gologger.Error().Msgf("%s", err)
 
-					return
+					continue
 				}
 
 				result, err := CheckCSP(targetURL, r.UserAgent, dregex, client)
@@ -168,7 +168,7 @@ func execute(r *Runner) {
 						gologger.Error().Msgf("%s", err)
 					}
 
-					return
+					continue
 				}
 
 				if r.Options.JSON {