summaryrefslogtreecommitdiffstats
path: root/src/swarm/peer.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-24 06:09:22 +0200
committertv <tv@krebsco.de>2026-10-24 06:09:22 +0200
commit7542d33f5d476a35d068a4246399cc0c164dac06 (patch)
tree54290aafd8b3a11c85a01578dffdd0c7f9f8dd52 /src/swarm/peer.rs
parentecec63df16ba51fde6a63c9610a8296fa81c3f54 (diff)
add swarm stats
Diffstat (limited to 'src/swarm/peer.rs')
-rw-r--r--src/swarm/peer.rs2
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(());
}