diff options
| author | tv <tv@krebsco.de> | 2026-10-26 04:24:52 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 04:24:52 +0100 |
| commit | 2f3d191a12b6e03ef1845c202d15c7b90736558c (patch) | |
| tree | f9e0aecafd5d32f904ffd62893132994ee52958f /src/simtest/mod.rs | |
| parent | 7b7dcb5a77061cb69d368de263a02b5ad26fbf51 (diff) | |
unify peers snapshot logic
Diffstat (limited to 'src/simtest/mod.rs')
| -rw-r--r-- | src/simtest/mod.rs | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/src/simtest/mod.rs b/src/simtest/mod.rs index 408f53e..26092ee 100644 --- a/src/simtest/mod.rs +++ b/src/simtest/mod.rs @@ -200,13 +200,7 @@ impl Sim { .load(std::sync::atomic::Ordering::Acquire), ); let _ = writeln!(out, " view: {:?}", *node.neighbours.read_or_recover()); - let peers: Vec<_> = node - .peer_states - .read() - .await - .iter() - .map(|(peer, state)| (peer.clone(), Arc::clone(state))) - .collect(); + let peers = node.peers_snapshot().await; for (peer, peer_state) in peers { let p = peer_state.lock().await; let _ = writeln!( |
