diff options
| author | tv <tv@krebsco.de> | 2026-11-06 06:02:19 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 06:02:19 +0100 |
| commit | d9d398522a142283b537670068cc6418402d9546 (patch) | |
| tree | 9253ee0761da39336296688f5c857786bcb9a665 /src/transport | |
| parent | 77ffa8807d0cf1f06bc040052f6a1873536a0255 (diff) | |
soak with churn test
Diffstat (limited to 'src/transport')
| -rw-r--r-- | src/transport/traffic.rs | 6 |
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`. |
