This is an automated email from the ASF dual-hosted git repository. liuhan pushed a commit to branch tmp_disable_reading in repository https://gitbox.apache.org/repos/asf/skywalking-rover.git
commit b7fa6b5e2ea1222ce4ba225cd3d308e5b11150ec Author: mrproliu <[email protected]> AuthorDate: Sat Dec 21 14:26:07 2024 +0800 add test log --- pkg/tools/btf/queue.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/tools/btf/queue.go b/pkg/tools/btf/queue.go index 96e40c8..dc687ff 100644 --- a/pkg/tools/btf/queue.go +++ b/pkg/tools/btf/queue.go @@ -127,6 +127,7 @@ func (p *perfQueueReader) Close() error { type ringBufReader struct { reader *ringbuf.Reader + name string } func newRingBufReader(emap *ebpf.Map) (*ringBufReader, error) { @@ -134,7 +135,7 @@ func newRingBufReader(emap *ebpf.Map) (*ringBufReader, error) { if err != nil { return nil, err } - return &ringBufReader{reader: reader}, nil + return &ringBufReader{reader: reader, name: emap.String()}, nil } func (r *ringBufReader) Read() ([]byte, error) { @@ -142,6 +143,7 @@ func (r *ringBufReader) Read() ([]byte, error) { if err != nil { return nil, err } + log.Infof("ringbuf read of (%s): %d", r.name, read.Remaining) return read.RawSample, nil }
