implement feedback

DataDog · Dec 16, 2024 · 3e3f2e0 · 3e3f2e0
1 parent f896d59
commit 3e3f2e0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/pkg/network/tracer/connection/ebpfless/tcp_processor.go b/pkg/network/tracer/connection/ebpfless/tcp_processor.go
@@ -70,7 +70,7 @@ type TCPProcessor struct {
 }
 
 // TODO make this into a config value
-const maxPendingConns = 1024
+const maxPendingConns = 4096
 
 // NewTCPProcessor constructs an empty TCPProcessor
 func NewTCPProcessor(cfg *config.Config) *TCPProcessor {

diff --git a/pkg/network/tracer/connection/ebpfless_tracer.go b/pkg/network/tracer/connection/ebpfless_tracer.go
@@ -242,9 +242,11 @@ func (t *ebpfLessTracer) processConnection(
 	case ebpfless.ProcessResultStoreConn:
 		maxTrackedConns := int(t.config.MaxTrackedConnections)
 		ok := ebpfless.WriteMapWithSizeLimit(t.conns, conn.ConnectionTuple, conn, maxTrackedConns)
-		// we don't have enough space to add this connection, remove its TCP state tracking
-		if !ok && conn.Type == network.TCP {
-			t.tcp.RemoveConn(conn.ConnectionTuple)
+		if !ok {
+			// we don't have enough space to add this connection, remove its TCP state tracking
+			if conn.Type == network.TCP {
+				t.tcp.RemoveConn(conn.ConnectionTuple)
+			}
 			ebpfLessTracerTelemetry.droppedConnections.Inc()
 		}
 	case ebpfless.ProcessResultCloseConn: