fix crash when socket_listener receiving invalid data (#8551)

Co-authored-by: Hoa Nguyen Van <[email protected]>
influxdata · Dec 15, 2020 · 8e08da1 · 8e08da1
1 parent f6e2d45
commit 8e08da1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/plugins/inputs/socket_listener/socket_listener.go b/plugins/inputs/socket_listener/socket_listener.go
@@ -114,6 +114,7 @@ func (ssl *streamSocketListener) read(c net.Conn) {
 	decoder, err := internal.NewStreamContentDecoder(ssl.ContentEncoding, c)
 	if err != nil {
 		ssl.Log.Error("Read error: %v", err)
+		return
 	}
 
 	scnr := bufio.NewScanner(decoder)