From f70036a89d1ee5b000ad6d97031bb37f50dae778 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sat, 10 Feb 2024 21:21:39 +0200 Subject: it's not the pollSize, but the poll timeout in poll() :facepalm: --- main.go | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/main.go b/main.go index 941af2f..5fbcc6c 100644 --- a/main.go +++ b/main.go @@ -94,13 +94,13 @@ func main() { go func() { defer wg.Done() - for ev := range listenToEvents[openEvent](ctx, bpfModule, "open_event_map") { + for ev := range listenToEvents[fdEvent](ctx, bpfModule, "fd_event_map") { log.Println(ev) } }() go func() { defer wg.Done() - for ev := range listenToEvents[fdEvent](ctx, bpfModule, "fd_event_map") { + for ev := range listenToEvents[openEvent](ctx, bpfModule, "open_event_map") { log.Println(ev) } }() @@ -114,12 +114,11 @@ func main() { } func listenToEvents[T BpfMapper](ctx context.Context, bpfModule *bpf.Module, mapName string) <-chan T { - pollSize := 300 rawEventsCh := make(chan []byte) rawLostCh := make(chan uint64) // TODO: Of any use this channel? eventsCh := make(chan T) - pb, err := bpfModule.InitPerfBuf(mapName, rawEventsCh, rawLostCh, 1) + pb, err := bpfModule.InitPerfBuf(mapName, rawEventsCh, rawLostCh, 4096) if err != nil { log.Fatal(err) } @@ -130,7 +129,7 @@ func listenToEvents[T BpfMapper](ctx context.Context, bpfModule *bpf.Module, map pb.Close() close(eventsCh) }() - pb.Poll(pollSize) + pb.Poll(300) for { select { case <-ctx.Done(): @@ -143,7 +142,6 @@ func listenToEvents[T BpfMapper](ctx context.Context, bpfModule *bpf.Module, map log.Fatal(err) } eventsCh <- ev - pb.Poll(pollSize) } } }() -- cgit v1.2.3