From 7a35b57489e395727f9ef6923da0597ba6363cfe Mon Sep 17 00:00:00 2001 From: hengyoush Date: Sun, 15 Dec 2024 23:50:19 +0800 Subject: [PATCH] fix: fix latency filter bug --- agent/conn/record_processor.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/agent/conn/record_processor.go b/agent/conn/record_processor.go index 0906e006..b059f12d 100644 --- 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()))