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 abe3fd5  tmp logs
abe3fd5 is described below

commit abe3fd5188a2d027a08a185fa0a91065782e8ff1
Author: mrproliu <[email protected]>
AuthorDate: Thu Dec 12 15:04:31 2024 +0800

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

diff --git a/pkg/tools/buffer/buffer.go b/pkg/tools/buffer/buffer.go
index 0ffcd95..0402c92 100644
--- a/pkg/tools/buffer/buffer.go
+++ b/pkg/tools/buffer/buffer.go
@@ -160,6 +160,7 @@ func (i *DataIDRange) DeleteDetails(buf *Buffer) {
                                break
                        }
                        buf.detailEvents.Remove(e)
+                       log.Infof("delete detail event2, data id: %d, ref: %p", 
dataId, buf)
                }
                e = next
        }
@@ -639,6 +640,7 @@ func (r *Buffer) RemoveReadElements(includeDetails bool) 
bool {
                        if startDelete {
                                tmp := e.Next()
                                r.detailEvents.Remove(e)
+                               log.Infof("delete detail event1, data id: %d, 
ref: %p", event.DataID(), r)
                                e = tmp
                        } else {
                                e = e.Next()
@@ -778,8 +780,12 @@ func (r *Buffer) DeleteExpireEvents(expireDuration 
time.Duration) int {
        // detail event queue
        count += r.deleteEventsWithJudgement(r.detailEvents, func(element 
*list.Element) bool {
                detail := element.Value.(SocketDataDetail)
-               return r.latestExpiredDataID > 0 && detail.DataID() <= 
r.latestExpiredDataID ||
+               isDelete := r.latestExpiredDataID > 0 && detail.DataID() <= 
r.latestExpiredDataID ||
                        (detail.Time() > 0 && 
expireTime.After(host.Time(detail.Time())))
+               if isDelete {
+                       log.Infof("delete expired detail event, data id: %d, 
buf: %p", detail.DataID(), r)
+               }
+               return isDelete
        })
        return count
 }

Reply via email to