diff --git a/tap/tcp_reader.go b/tap/tcp_reader.go index 6f46e7a0a..471c2513d 100644 --- a/tap/tcp_reader.go +++ b/tap/tcp_reader.go @@ -54,7 +54,7 @@ func (reader *tcpReader) run(options *api.TrafficFilteringOptions, wg *sync.Wait reader.counterPair = reader.parent.counterPairs[i] b := bufio.NewReader(reader) err := extension.Dissector.Dissect(b, reader, options) - if err == nil || reader.isProtocolIdentified() { + if reader.isProtocolIdentified() { break } reader.rewind()