From 97384637211bbb70c43abc08389ea05c139d36ae Mon Sep 17 00:00:00 2001
From: Paul Buetow <paul@buetow.org>
Date: Fri, 16 Feb 2024 01:36:30 +0200
Subject: delete dead code

---
 internal/ioriotng.go | 41 -----------------------------------------
 1 file changed, 41 deletions(-)

diff --git a/internal/ioriotng.go b/internal/ioriotng.go
index 614aa8a..d2535d3 100644
--- a/internal/ioriotng.go
+++ b/internal/ioriotng.go
@@ -86,47 +86,6 @@ func Run(flags flags.Flags) {
 	log.Println("Good bye")
 }
 
-func deserialize() {
-	// TODO: Use sync pool to speed up
-
-}
-
-func listenToEvents[T BpfMapper](ctx context.Context, bpfModule *bpf.Module, mapName string) <-chan T {
-	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, 1024)
-	if err != nil {
-		log.Fatal(err)
-	}
-
-	go func() {
-		defer func() {
-			pb.Stop()
-			pb.Close()
-			close(eventsCh)
-		}()
-		pb.Poll(300)
-		for {
-			select {
-			case <-ctx.Done():
-				return
-			case lost := <-rawLostCh:
-				log.Println("Lost", lost, mapName, "events. Consider increasing ring buffer!")
-			case rawEv := <-rawEventsCh:
-				var ev T
-				if err := binary.Read(bytes.NewReader(rawEv), binary.LittleEndian, &ev); err != nil {
-					log.Fatal(err)
-				}
-				eventsCh <- ev
-			}
-		}
-	}()
-
-	return eventsCh
-}
-
 func ksymArch() string {
 	switch runtime.GOARCH {
 	case "amd64":
-- 
cgit v1.2.3