fix: response count has decreased

Author: lzf575

agent/src/common/l7_protocol_info.rs

@@ -397,11 +397,28 @@ where
                 if !cur_info.on_blacklist && cur_info.msg_type == LogMessageType::Request {
                     timeout_counter.in_cache[index] += 1;
                 }
+                let cur_is_req = cur_info.msg_type == LogMessageType::Request;
+                let cur_on_blacklist = cur_info.on_blacklist;
                 let prev_info = rtt_cache.put(key, cur_info).unwrap();
-                if !prev_info.on_blacklist {
-                    Some(L7PerfStats::from(&prev_info))
-                } else {
+                // Requests are counted (req=1) eagerly when they first enter the cache,
+                // so re-emitting a displaced Request here would double-count it.
+                // Responses were cached with None on arrival and must be counted here.
+                let mut result =
+                    if !prev_info.on_blacklist && prev_info.msg_type == LogMessageType::Response {
+                        L7PerfStats::from(&prev_info)
+                    } else {
+                        L7PerfStats::default()
+                    };
+                // A new Request entering the cache via this path (replacing a previous entry)
+                // was never counted by the first-entry path, so emit req=1 now so that
+                // "request accounted before" holds when its response arrives via is_request_of.
+                if !cur_on_blacklist && cur_is_req {
+                    result.inc_req();
+                }
+                if result == L7PerfStats::default() {
                     None
+                } else {
+                    Some(result)
                 }
             }
         } else {

agent/src/common/l7_protocol_log.rs

@@ -532,6 +532,12 @@ impl RrtCache {
         let mut backward = L7PerfStats::default();
         for (key, _) in keys {
             if let Some(cache) = self.logs.pop(&key) {
+                // Requests were already counted (req=1) when they first entered the cache;
+                // re-counting them here would double-count. Only Responses need to be
+                // counted here because they were cached with None on arrival.
+                if cache.msg_type != LogMessageType::Response {
+                    continue;
+                }
                 if key.is_reversed() {
                     backward.sequential_merge(&L7PerfStats::from(&cache));
                 } else {