cleanup

shawnburke · shawnburke · commit 0f28d843a405 · 2025-03-14T12:50:24.000+11:00
diff --git a/agent/server/snykbroker/supervisor.go b/agent/server/snykbroker/supervisor.go
@@ -271,12 +271,10 @@ func (b *Supervisor) scanLines(reader io.Reader, output chan string, refCount *s
 			if err == nil {
 				return
 			}
-			if err != nil {
-				output <- fmt.Sprintf("Warning (non-fatal), failed to read from scanner to pipe output: %v", err)
-			}
+			output <- fmt.Sprintf("Warning (non-fatal), failed to read from scanner to pipe output: %v", err)
 
-			// dump what we have in the buffer, then continue
-			output <- string(buffer) + "...[END OF BUFFER]"
+			// dump what we have in the buffer, first 16K, then continue
+			output <- string(buffer[0:16*1024]) + "...[END OF BUFFER]"
 		}
 
 	}()

Original file line number	Diff line number	Diff line change
`@@ -271,12 +271,10 @@ func (b Supervisor) scanLines(reader io.Reader, output chan string, refCount s`
`271`	`271`	`if err == nil {`
`272`	`272`	`return`
`273`	`273`	`}`
`274`		`- if err != nil {`
`275`		`- output <- fmt.Sprintf("Warning (non-fatal), failed to read from scanner to pipe output: %v", err)`
`276`		`- }`
	`274`	`+ output <- fmt.Sprintf("Warning (non-fatal), failed to read from scanner to pipe output: %v", err)`
`277`	`275`
`278`		`- // dump what we have in the buffer, then continue`
`279`		`- output <- string(buffer) + "...[END OF BUFFER]"`
	`276`	`+ // dump what we have in the buffer, first 16K, then continue`
	`277`	`+ output <- string(buffer[0:16*1024]) + "...[END OF BUFFER]"`
`280`	`278`	`}`
`281`	`279`
`282`	`280`	`}()`