From ce840940b3bd1012f431233742fc0c73c3f0afa7 Mon Sep 17 00:00:00 2001 From: "M. Mert Yildiran" Date: Thu, 12 May 2022 13:20:50 +0300 Subject: [PATCH] Copy to buffer only a message is received --- tap/tcp_reader.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tap/tcp_reader.go b/tap/tcp_reader.go index 3f7bf2561..71df99fce 100644 --- a/tap/tcp_reader.go +++ b/tap/tcp_reader.go @@ -97,6 +97,9 @@ func (reader *tcpReader) Read(p []byte) (int, error) { if msg != nil { reader.data = msg.GetBytes() reader.captureTime = msg.GetTimestamp() + if !reader.isProtocolIdentified() { + reader.buffer = append(reader.buffer, reader.data...) + } } if len(reader.data) > 0 { @@ -108,9 +111,6 @@ func (reader *tcpReader) Read(p []byte) (int, error) { } l := copy(p, reader.data) - if !reader.isProtocolIdentified() { - reader.buffer = append(reader.buffer, reader.data...) - } reader.data = reader.data[l:] reader.progress.Feed(l)