(skywalking-rover) branch reduce-handle-connect-time updated: fix data id missing

[liuhan]

This is an automated email from the ASF dual-hosted git repository.

liuhan pushed a commit to branch reduce-handle-connect-time
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git


The following commit(s) were added to refs/heads/reduce-handle-connect-time by 
this push:
     new 5276a7c  fix data id missing
5276a7c is described below

commit 5276a7cd6825dd93bfa3fcc202fcfd2d7ef7c1aa
Author: mrproliu <741550...@qq.com>
AuthorDate: Fri Dec 27 17:42:35 2024 +0800

    fix data id missing
---
 pkg/accesslog/collector/protocols/queue.go | 4 ++--
 pkg/tools/buffer/buffer.go                 | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/pkg/accesslog/collector/protocols/queue.go 
b/pkg/accesslog/collector/protocols/queue.go
index 977d5bf..a4577f7 100644
--- a/pkg/accesslog/collector/protocols/queue.go
+++ b/pkg/accesslog/collector/protocols/queue.go
@@ -216,7 +216,7 @@ func (p *PartitionContext) Consume(data interface{}) {
        switch event := data.(type) {
        case events.SocketDetail:
                pid, _ := events.ParseConnectionID(event.GetConnectionID())
-               log.Infof("receive the socket detail event, connection ID: %d, 
random ID: %d, pid: %d, data id: %d, "+
+               log.Debugf("receive the socket detail event, connection ID: %d, 
random ID: %d, pid: %d, data id: %d, "+
                        "function name: %s, package count: %d, package size: 
%d, ssl: %d, protocol: %d",
                        event.GetConnectionID(), event.GetRandomID(), pid, 
event.DataID(), event.GetFunctionName(),
                        event.GetL4PackageCount(), 
event.GetL4TotalPackageSize(), event.GetSSL(), event.GetProtocol())
@@ -229,7 +229,7 @@ func (p *PartitionContext) Consume(data interface{}) {
                connection.AppendDetail(p.context, event)
        case *events.SocketDataUploadEvent:
                pid, _ := events.ParseConnectionID(event.ConnectionID)
-               log.Infof("receive the socket data event, connection ID: %d, 
random ID: %d, pid: %d, prev data id: %d, "+
+               log.Debugf("receive the socket data event, connection ID: %d, 
random ID: %d, pid: %d, prev data id: %d, "+
                        "data id: %d, sequence: %d, protocol: %d",
                        event.ConnectionID, event.RandomID, pid, 
event.PrevDataID0, event.DataID0, event.Sequence0, event.Protocol0)
                connection := p.getConnectionContext(event.ConnectionID, 
event.RandomID, event.Protocol0, event.DataID0)
diff --git a/pkg/tools/buffer/buffer.go b/pkg/tools/buffer/buffer.go
index 9efa237..9d7305b 100644
--- a/pkg/tools/buffer/buffer.go
+++ b/pkg/tools/buffer/buffer.go
@@ -173,7 +173,7 @@ func (i *DataIDRange) DeleteDetails(buf *Buffer) {
                                break
                        }
                        buf.detailEvents.Remove(e)
-                       log.Debugf("delete detail event from buffer, data id: 
%d, ref: %p, range: %d-%d(%t)",
+                       log.Infof("delete detail event from buffer, data id: 
%d, ref: %p, range: %d-%d(%t)",
                                dataID, buf, i.From, i.To, 
i.IsToBufferReadFinished)
                }
                e = next
@@ -320,7 +320,7 @@ func (r *Buffer) BuildDetails() *list.List {
                                        dataIDList = append(dataIDList, 
e.Value.(SocketDataDetail).DataID())
                                }
                        }
-                       log.Debugf("cannot found details from original buffer, 
from data id: %d, end data id: %d, "+
+                       log.Infof("cannot found details from original buffer, 
from data id: %d, end data id: %d, "+
                                "ref: %p, existing details data id list: %v", 
fromDataID, endDataID, r.originalBuffer, dataIDList)
                }