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
}