(skywalking-rover) branch missing-details updated: tmp logs

[liuhan]

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

liuhan pushed a commit to branch missing-details
in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git


The following commit(s) were added to refs/heads/missing-details by this push:
     new 2632f5e  tmp logs
2632f5e is described below

commit 2632f5e3bec736e7072beaeacd9a621abc26f567
Author: mrproliu <741550...@qq.com>
AuthorDate: Thu Dec 12 14:11:47 2024 +0800

    tmp logs
---
 pkg/tools/buffer/buffer.go | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/pkg/tools/buffer/buffer.go b/pkg/tools/buffer/buffer.go
index 5cd9f16..0ffcd95 100644
--- a/pkg/tools/buffer/buffer.go
+++ b/pkg/tools/buffer/buffer.go
@@ -20,6 +20,7 @@ package buffer
 import (
        "container/list"
        "errors"
+       "github.com/apache/skywalking-rover/pkg/logger"
        "io"
        "sync"
        "time"
@@ -31,6 +32,8 @@ import (
 var (
        ErrNotComplete = errors.New("socket: not complete event")
        emptyList      = list.New()
+
+       log = logger.GetLogger("tools", "buffer")
 )
 
 type SocketDataBuffer interface {
@@ -315,6 +318,10 @@ func (r *Buffer) BuildDetails() *list.List {
                                events.PushBack(e.Value)
                        }
                }
+               if events.Len() == 0 {
+                       log.Infof("cannot found details from original buffer, 
from data id: %d, end data id: %d, ref: %p",
+                               fromDataId, endDataId, r.originalBuffer)
+               }
                return events
        }
        return r.detailEvents
@@ -687,10 +694,17 @@ func (r *Buffer) AppendDetailEvent(event 
SocketDataDetail) {
 
        if r.detailEvents.Len() == 0 {
                r.detailEvents.PushFront(event)
+               log.Infof("append details into front1, data id: %d, ref: %p", 
event.DataID(), r)
+               return
+       }
+       if r.detailEvents.Back().Value == nil {
+               r.detailEvents.PushFront(event)
+               log.Infof("append details into front2, data id: %d, ref: %p", 
event.DataID(), r)
                return
        }
        if r.detailEvents.Back().Value.(SocketDataDetail).DataID() < 
event.DataID() {
                r.detailEvents.PushBack(event)
+               log.Infof("append details into back1, data id: %d, ref: %p", 
event.DataID(), r)
                return
        }
        beenAdded := false
@@ -702,10 +716,12 @@ func (r *Buffer) AppendDetailEvent(event 
SocketDataDetail) {
                }
                if beenAdded {
                        r.detailEvents.InsertBefore(event, element)
+                       log.Infof("append details by insert, data id: %d, 
before data id: %d, ref: %p", event.DataID(), existEvent.DataID(), r)
                        break
                }
        }
        if !beenAdded {
+               log.Infof("append details into back2, data id: %d, ref: %p", 
event.DataID(), r)
                r.detailEvents.PushBack(event)
        }
 }