diff options
| author | tv <tv@krebsco.de> | 2026-11-05 05:38:20 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-05 05:38:27 +0100 |
| commit | 4e53e152f83ecb88fa162e0a18e6832df5a38fef (patch) | |
| tree | 12e92bedfd0f081b8827f956d0d15c9e8837fb12 /src/state/peer.rs | |
| parent | c1cb16be7894885ec5066dafc25b92f348ced11a (diff) | |
round trips in trees
Diffstat (limited to 'src/state/peer.rs')
| -rw-r--r-- | src/state/peer.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/state/peer.rs b/src/state/peer.rs index 231f320..4923f0f 100644 --- a/src/state/peer.rs +++ b/src/state/peer.rs @@ -159,6 +159,9 @@ pub(crate) struct PeerState { pub(crate) slow_announced_at: Option<Instant>, /// Whom it said it reaches (`swarm::reach`), by pair key, and when. pub(crate) reaches: Option<(Instant, Vec<u64>)>, + /// Its round trip to each of them, in their order, as a bucket + /// (`Status::round_trips`); None if it said none, or not one each. + pub(crate) round_trips: Option<Vec<u8>>, /// Whose change the next sync message to it passes on along the writer's tree /// (`swarm::tree`); taken when it is generated. pub(crate) tree_writer: Option<u64>, @@ -297,6 +300,7 @@ impl PeerState { hop_delays: Default::default(), slow_announced_at: None, reaches: None, + round_trips: None, tree_writer: None, left: false, hello_attempts: 0, @@ -316,6 +320,7 @@ impl PeerState { self.sync = SyncSession::new(reply_backoff); // Said over the session that ended. self.reaches = None; + self.round_trips = None; } /// An overdue sync answer from an established, active peer (see |
