From 0408d6f26de63dd07827431fb4655b6ad262de3f Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Thu, 22 Feb 2024 20:43:33 +0200 Subject: add Recycle event methods --- internal/eventloop.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'internal/eventloop.go') diff --git a/internal/eventloop.go b/internal/eventloop.go index f3762b0..26d7a17 100644 --- a/internal/eventloop.go +++ b/internal/eventloop.go @@ -31,15 +31,15 @@ func eventLoop(bpfModule *bpf.Module, ch <-chan []byte) { enterEv, ok := enterOpen[ev.PidTgid] if !ok { fmt.Println("Dropping", ev) - RecycleFdEvent(ev) + ev.Recycle() continue } duration := float64(ev.Time-enterEv.Time) / float64(1_000_000) fmt.Println(duration, "ms", enterEv, ev) delete(enterOpen, ev.PidTgid) - RecycleFdEvent(ev) - RecycleOpenEnterEvent(enterEv) + ev.Recycle() + enterEv.Recycle() case CLOSE_ENTER_OP_ID: fallthrough @@ -58,15 +58,15 @@ func eventLoop(bpfModule *bpf.Module, ch <-chan []byte) { enterEv, ok := enterFd[ev.PidTgid] if !ok { fmt.Println("Dropping", ev) - RecycleNullEvent(ev) + ev.Recycle() continue } duration := float64(ev.Time-enterEv.Time) / float64(1_000_000) fmt.Println(duration, "ms", enterEv, ev) delete(enterFd, ev.PidTgid) - RecycleNullEvent(ev) - RecycleFdEvent(enterEv) + ev.Recycle() + enterEv.Recycle() default: panic(fmt.Sprintf("UNKNOWN Ringbuf data received len:%d raw:%v", len(raw), raw)) -- cgit v1.2.3