it's not the pollSize, but the poll timeout in poll() :facepalm:

1 files 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)
 			}
 		}
 	}()