diff --git a/firewall/interception/ebpf/connection_listener/worker.go b/firewall/interception/ebpf/connection_listener/worker.go index d8aced12..4798e389 100644 --- a/firewall/interception/ebpf/connection_listener/worker.go +++ b/firewall/interception/ebpf/connection_listener/worker.go @@ -114,7 +114,8 @@ func ConnectionListenerWorker(ctx context.Context, packets chan packet.Packet) e PID: int(event.Pid), }) if isEventValid(event) { - log.Debugf("ebpf: received valid connect event: PID: %d Conn: %s", pkt.Info().PID, pkt) + // DEBUG: + // log.Debugf("ebpf: received valid connect event: PID: %d Conn: %s", pkt.Info().PID, pkt) packets <- pkt } else { log.Warningf("ebpf: received invalid connect event: PID: %d Conn: %s", pkt.Info().PID, pkt) diff --git a/firewall/interception/nfq/nfq.go b/firewall/interception/nfq/nfq.go index 585ba96e..184e15f9 100644 --- a/firewall/interception/nfq/nfq.go +++ b/firewall/interception/nfq/nfq.go @@ -196,7 +196,8 @@ func (q *Queue) packetHandler(ctx context.Context) func(nfqueue.Attribute) int { select { case q.packets <- pkt: - log.Tracef("nfqueue: queued packet %s (%s -> %s) after %s", pkt.ID(), pkt.Info().Src, pkt.Info().Dst, time.Since(pkt.Info().SeenAt)) + // DEBUG: + // log.Tracef("nfqueue: queued packet %s (%s -> %s) after %s", pkt.ID(), pkt.Info().Src, pkt.Info().Dst, time.Since(pkt.Info().SeenAt)) case <-ctx.Done(): return 0 case <-time.After(time.Second): diff --git a/firewall/interception/nfq/packet.go b/firewall/interception/nfq/packet.go index 6dd42186..8baeff5b 100644 --- a/firewall/interception/nfq/packet.go +++ b/firewall/interception/nfq/packet.go @@ -6,7 +6,6 @@ import ( "errors" "fmt" "sync/atomic" - "time" "github.com/florianl/go-nfqueue" "github.com/tevino/abool" @@ -117,7 +116,13 @@ func (pkt *packet) setMark(mark int) error { } break } - log.Tracer(pkt.Ctx()).Tracef("nfqueue: marking packet %s (%s -> %s) on queue %d with %s after %s", pkt.ID(), pkt.Info().Src, pkt.Info().Dst, pkt.queue.id, markToString(mark), time.Since(pkt.Info().SeenAt)) + + // DEBUG: + // log.Tracer(pkt.Ctx()).Tracef( + // "nfqueue: marking packet %s (%s -> %s) on queue %d with %s after %s", + // pkt.ID(), pkt.Info().Src, pkt.Info().Dst, pkt.queue.id, + // markToString(mark), time.Since(pkt.Info().SeenAt), + // ) return nil } diff --git a/netquery/manager.go b/netquery/manager.go index e34baa9c..b6be97be 100644 --- a/netquery/manager.go +++ b/netquery/manager.go @@ -113,7 +113,8 @@ func (mng *Manager) HandleFeed(ctx context.Context, feed <-chan *network.Connect continue } - log.Tracef("netquery: updating connection %s", conn.ID) + // DEBUG: + // log.Tracef("netquery: updating connection %s", conn.ID) if err := mng.store.Save(ctx, *model, conn.HistoryEnabled); err != nil { log.Errorf("netquery: failed to save connection %s in sqlite database: %s", conn.ID, err) diff --git a/network/clean.go b/network/clean.go index a538b7f5..f3103142 100644 --- a/network/clean.go +++ b/network/clean.go @@ -78,7 +78,8 @@ func cleanConnections() (activePIDs map[int]struct{}) { } case conn.Ended < deleteOlderThan: // Step 3: delete - log.Tracef("network.clean: deleted %s (ended at %s)", conn.DatabaseKey(), time.Unix(conn.Ended, 0)) + // DEBUG: + // log.Tracef("network.clean: deleted %s (ended at %s)", conn.DatabaseKey(), time.Unix(conn.Ended, 0)) conn.delete() }