This is an automated email from the ASF dual-hosted git repository.
liuhan pushed a commit to branch fully-reading-buddy
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
The following commit(s) were added to refs/heads/fully-reading-buddy by this
push:
new d042e18 adding test log
d042e18 is described below
commit d042e1897fba3e9ac1f48c36bd6adca1b8c174cf
Author: mrproliu <[email protected]>
AuthorDate: Fri Jun 6 20:40:44 2025 +0800
adding test log
---
.../network/analyze/layer7/protocols/http1/reader/reader.go | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git
a/pkg/profiling/task/network/analyze/layer7/protocols/http1/reader/reader.go
b/pkg/profiling/task/network/analyze/layer7/protocols/http1/reader/reader.go
index 827d615..d00170b 100644
--- a/pkg/profiling/task/network/analyze/layer7/protocols/http1/reader/reader.go
+++ b/pkg/profiling/task/network/analyze/layer7/protocols/http1/reader/reader.go
@@ -284,6 +284,16 @@ func (m *MessageOpt) checkBodyWithSize(buf *buffer.Buffer,
reader *bufio.Reader,
if (err == io.EOF || errors.Is(err,
io.ErrUnexpectedEOF)) && reduceSize-lastReadSize <= 0 {
return nil, enums.ParseResultSuccess, nil
}
+
+ log.Debugf("check body size error")
+ log.Debugf("-----------------------------------")
+ totalBuffer := buf.TotalBuffer()
+ for _, b := range totalBuffer {
+ b.GenerateConnectionID()
+ log.Debugf("connection id: %s, data id: %d,
data: %s",
+ b.GenerateConnectionID(), b.DataID(),
string(b.BufferData()))
+ }
+ log.Debugf("-----------------------------------")
return nil, enums.ParseResultSkipPackage,
fmt.Errorf("reading the body error: %v", err)
}
reduceSize -= lastReadSize
