mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-08-02 09:07:56 +00:00
Use isProtocolIdentified
method instead
This commit is contained in:
parent
05495eebde
commit
2982d0f3cd
@ -55,7 +55,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.parent.protocol != nil {
|
||||
if err == nil || reader.isProtocolIdentified() {
|
||||
break
|
||||
}
|
||||
reader.exhaustBuffer = true
|
||||
|
Loading…
Reference in New Issue
Block a user