diff options
| author | tv <tv@krebsco.de> | 2026-11-04 20:10:08 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-04 20:10:08 +0100 |
| commit | 6487281ad8e33138173cdb934bc6caf9333a3721 (patch) | |
| tree | 7e950fa3e020a26390708d932225d08089a28375 /src/swarm/peer | |
| parent | c3faf6ecde8157154a01daa2ddc0ac02e6c761f1 (diff) | |
slow round back off
Diffstat (limited to 'src/swarm/peer')
| -rw-r--r-- | src/swarm/peer/inbound.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/swarm/peer/inbound.rs b/src/swarm/peer/inbound.rs index cfafbd3..53f1aa3 100644 --- a/src/swarm/peer/inbound.rs +++ b/src/swarm/peer/inbound.rs @@ -190,6 +190,11 @@ pub(crate) async fn handle_message( } } transport::ParsedMessage::StatusReply(remote) => { + // An answer to our slow round's announcement: a tree missed. + let announced = peer_state.lock().await.slow_announced_at.take(); + if let Some(at) = announced { + crate::swarm::relay::slow_round_answered(state, at.elapsed()); + } on_status(state, &peer, &remote, reactivated).await; } transport::ParsedMessage::Links(request) => { |
