diff options
| author | tv <tv@krebsco.de> | 2026-10-24 06:09:22 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-24 06:09:22 +0200 |
| commit | 490234bbd44356da1cca0ad62b044e0cba70a226 (patch) | |
| tree | 74c1b840a125bc9317602c63e29cbf8f81853b3d /src/swarm/peer.rs | |
| parent | e0ab17f665bb476329e0c7f980f31bb10cbfc944 (diff) | |
add swarm stats
Diffstat (limited to 'src/swarm/peer.rs')
| -rw-r--r-- | src/swarm/peer.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs index 3ceea3c..7a3eed8 100644 --- a/src/swarm/peer.rs +++ b/src/swarm/peer.rs @@ -492,6 +492,7 @@ pub(crate) async fn run_peer_worker(state: AppState) { apply_forget_records(&state).await; crate::swarm::members::ensure_registered(&state).await; crate::swarm::stability::tick(&state).await; + crate::swarm::stats::measure_saved_size(&state); { let known = state.peer_states.read().await; state.traffic.retain(|peer| known.contains_key(peer)); @@ -725,6 +726,7 @@ pub(crate) async fn handle_message( // we were down) says nothing about now; the peer answers our current HELLO. if let transport::ParsedMessage::HelloReply(reply) = &message { if reply.run_id != state.run_id { + state.stats.stale_hello_reply(); debug!(peer = %peer, "Ignoring a HELLO_REPLY to a HELLO from an earlier run"); return Ok(()); } |
