aboutsummaryrefslogtreecommitdiffstats
path: root/src/transport/traffic.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 06:02:19 +0100
committertv <tv@krebsco.de>2026-11-06 06:02:19 +0100
commitd9d398522a142283b537670068cc6418402d9546 (patch)
tree9253ee0761da39336296688f5c857786bcb9a665 /src/transport/traffic.rs
parent77ffa8807d0cf1f06bc040052f6a1873536a0255 (diff)
soak with churn test
Diffstat (limited to 'src/transport/traffic.rs')
-rw-r--r--src/transport/traffic.rs6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/transport/traffic.rs b/src/transport/traffic.rs
index b427a14..a34bf4b 100644
--- a/src/transport/traffic.rs
+++ b/src/transport/traffic.rs
@@ -345,6 +345,12 @@ impl Traffic {
pub(crate) fn retain(&self, mut keep: impl FnMut(&str) -> bool) {
self.lock().peers.retain(|peer, _| keep(peer));
}
+
+ /// How many peers (and their addresses) it counts for.
+ #[cfg(test)]
+ pub(crate) fn len(&self) -> usize {
+ self.lock().peers.len()
+ }
}
/// Counts what passes through `inner`.