fix crash when socket_listener receiving invalid data (#8551)

Co-authored-by: Hoa Nguyen Van <vanhoa@vhn.vn> (cherry picked from commit 8e08da1)
influxdata · Dec 16, 2020 · 56bf51a · 56bf51a
1 parent dd8014c
commit 56bf51a
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)