diff options
| author | tv <tv@krebsco.de> | 2026-10-25 20:40:00 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-25 20:40:00 +0100 |
| commit | 31e6e6a2801a19515daa7adda09b0d24d420f18e (patch) | |
| tree | 7e05dff35c6c049d297810893976843ba6f4a809 /src/state.rs | |
| parent | 944bd3a9da9c14153247b483ba2cfe1457fc84d2 (diff) | |
require catch-up source to make progress
Diffstat (limited to 'src/state.rs')
| -rw-r--r-- | src/state.rs | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/state.rs b/src/state.rs index d14c1ea..af01cf0 100644 --- a/src/state.rs +++ b/src/state.rs @@ -649,6 +649,12 @@ pub(crate) struct CatchUpSource { pub(crate) peer: String, /// When it was chosen or last sent us anything. pub(crate) last_heard: Instant, + /// When it was chosen or last sent us a sync message: progress, not just liveness. + pub(crate) last_sync: Instant, + /// Our sync messages to it in a row whose answer didn't come in time. + pub(crate) reply_timeouts: u32, + /// When we last warned that catching up from it stalls. + pub(crate) last_warned: Option<Instant>, /// Our last probe PING to it. pub(crate) last_probe: Option<Instant>, /// Its keepalives in a row saying it wouldn't sync with us. |
