fix: fix latency filter bug

hengyoush · Jan 6, 2025 · 7a35b57 · 7a35b57
1 parent 73c8585
commit 7a35b57
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/agent/conn/record_processor.go b/agent/conn/record_processor.go
@@ -49,14 +49,10 @@ func submitRecord(record protocol.Record, c *Connection4) {
 	var needSubmit bool
 
 	needSubmit = c.MessageFilter.FilterByProtocol(c.Protocol)
-	var duration uint64
-	if c.IsServerSide() {
-		duration = record.Request().TimestampNs() - record.Response().TimestampNs()
-	} else {
-		duration = record.Response().TimestampNs() - record.Request().TimestampNs()
-	}
 
+	duration := record.Response().TimestampNs() - record.Request().TimestampNs()
 	needSubmit = needSubmit && c.LatencyFilter.Filter(float64(duration)/1000000)
+
 	needSubmit = needSubmit &&
 		c.SizeFilter.FilterByReqSize(int64(record.Request().ByteSize())) &&
 		c.SizeFilter.FilterByRespSize(int64(record.Response().ByteSize()))