Change the conditions for determining the output accesslog

Signed-off-by: LiZhenCheng9527 <[email protected]>
byhlel · Sep 14, 2024 · bc49986 · bc49986
1 parent f493505
commit bc49986
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/pkg/controller/telemetry/accesslog.go b/pkg/controller/telemetry/accesslog.go
@@ -35,10 +35,8 @@ type logInfo struct {
 }
 
 func OutputAccesslog(data requestMetric, accesslog logInfo) {
-	if accesslog.destinationService != "-" || data.dstPort == uint16(15019) {
-		logStr := buildAccesslog(data, accesslog)
-		fmt.Println("accesslog:", logStr)
-	}
+	logStr := buildAccesslog(data, accesslog)
+	fmt.Println("accesslog:", logStr)
 }
 
 func buildAccesslog(data requestMetric, accesslog logInfo) string {

diff --git a/pkg/controller/telemetry/metric.go b/pkg/controller/telemetry/metric.go
@@ -260,7 +260,7 @@ func (m *MetricController) Run(ctx context.Context, mapOfTcpInfo *ebpf.Map) {
 				serviceLabels.reporter = "source"
 				accesslog.direction = "OUTBOUND"
 			}
-			if data.state == TCP_CLOSTED {
+			if data.state == TCP_CLOSTED && accesslog.sourceWorkload != "-" {
 				OutputAccesslog(data, accesslog)
 			}
 			m.mutex.Lock()