Skip to content

Commit 1954ea8

Browse files
committed
fix: Metrics not filtered for unmatched requests and responses
1 parent 2dcc18a commit 1954ea8

1 file changed

Lines changed: 6 additions & 5 deletions

File tree

agent/src/common/l7_protocol_info.rs

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -360,10 +360,10 @@ where
360360
);
361361

362362
if prev_info.time > cur_info.time {
363-
if cur_info.msg_type == LogMessageType::Request {
363+
if !cur_info.on_blacklist && cur_info.msg_type == LogMessageType::Request {
364364
timeout_counter.timeout += 1;
365365
}
366-
if prev_info.msg_type == LogMessageType::Request {
366+
if !prev_info.on_blacklist && prev_info.msg_type == LogMessageType::Request {
367367
timeout_counter.in_cache += 1;
368368
}
369369
if !cur_info.on_blacklist {
@@ -372,10 +372,10 @@ where
372372
None
373373
}
374374
} else {
375-
if prev_info.msg_type == LogMessageType::Request {
375+
if !prev_info.on_blacklist && prev_info.msg_type == LogMessageType::Request {
376376
timeout_counter.timeout += 1;
377377
}
378-
if cur_info.msg_type == LogMessageType::Request {
378+
if !cur_info.on_blacklist && cur_info.msg_type == LogMessageType::Request {
379379
timeout_counter.in_cache += 1;
380380
}
381381
let prev_info = rtt_cache.put(key, cur_info).unwrap();
@@ -386,7 +386,8 @@ where
386386
}
387387
}
388388
} else {
389-
if prev_info.msg_type != cur_info.msg_type
389+
if !prev_info.on_blacklist
390+
&& prev_info.msg_type != cur_info.msg_type
390391
&& !prev_info.multi_merge_info.as_ref().unwrap().merged
391392
{
392393
timeout_counter.timeout += 1;

0 commit comments

Comments
 (0)