From 965515a2756a437abe4813f47014982287c7d77e Mon Sep 17 00:00:00 2001 From: Jerome Gravel-Niquet Date: Fri, 27 Dec 2024 12:53:16 -0500 Subject: [PATCH] track lost packets by addr --- crates/corro-agent/src/transport.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/crates/corro-agent/src/transport.rs b/crates/corro-agent/src/transport.rs index 3aa03513..ab73b9f5 100644 --- a/crates/corro-agent/src/transport.rs +++ b/crates/corro-agent/src/transport.rs @@ -256,8 +256,9 @@ impl Transport { .set(stats.path.congestion_events as f64); gauge!("corro.transport.path.black_holes_detected", "addr" => addr.to_string()) .set(stats.path.black_holes_detected as f64); + gauge!("corro.transport.path.lost_packets", "addr" => addr.to_string()) + .set(stats.path.lost_packets as f64); - acc.path.lost_packets += stats.path.lost_packets; acc.path.lost_bytes += stats.path.lost_bytes; acc.path.sent_packets += stats.path.sent_packets; acc.path.sent_plpmtud_probes += stats.path.sent_plpmtud_probes; @@ -319,7 +320,6 @@ impl Transport { acc }); - gauge!("corro.transport.path.lost_packets").set(stats.path.lost_packets as f64); gauge!("corro.transport.path.lost_bytes").set(stats.path.lost_bytes as f64); gauge!("corro.transport.path.sent_packets").set(stats.path.sent_packets as f64); gauge!("corro.transport.path.sent_plpmtud_probes")