summaryrefslogtreecommitdiff
path: root/internal/eventloop.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-02-22 20:43:33 +0200
committerPaul Buetow <paul@buetow.org>2024-02-22 20:43:33 +0200
commit0408d6f26de63dd07827431fb4655b6ad262de3f (patch)
treefff22f1763f49ebf02ec13a39fa8383daf920fde /internal/eventloop.go
parenteff5b134c0a4532712ffcbed7701a668ba7c31ff (diff)
add Recycle event methods
Diffstat (limited to 'internal/eventloop.go')
-rw-r--r--internal/eventloop.go12
1 files changed, 6 insertions, 6 deletions
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))