diff options
| author | tv <tv@krebsco.de> | 2026-10-31 12:18:13 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 12:18:13 +0100 |
| commit | bac81678fc2853b5b28375c410adb70b86d66268 (patch) | |
| tree | 3c9e0339a11319b9271113b55b186a79d1f208f8 /src/state/mod.rs | |
| parent | e746f005d6c2252872efd89e0c020680bada321a (diff) | |
detect local clock jumps
Diffstat (limited to 'src/state/mod.rs')
| -rw-r--r-- | src/state/mod.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/state/mod.rs b/src/state/mod.rs index ec8823a..36dd4ad 100644 --- a/src/state/mod.rs +++ b/src/state/mod.rs @@ -119,8 +119,8 @@ pub(crate) struct AppState { /// How far this node's clock is ahead of its peers' (their median, `swarm::skew`), as /// last measured; 0 before. The propagation figures take it off. pub(crate) clock_ahead_ms: Arc<std::sync::atomic::AtomicI64>, - /// When the log last said this node's clock is off, while it is (`swarm::skew`). - pub(crate) clock_skew_warned: Arc<std::sync::Mutex<Option<tokio::time::Instant>>>, + /// What the clock checks remember between them (`swarm::skew`). + pub(crate) clock_skew: Arc<std::sync::Mutex<crate::swarm::skew::Watch>>, /// Chunked transfers served and fetched (`swarm::blob`). pub(crate) blobs: Arc<crate::swarm::blob::Blobs>, /// LINKS asked and answered, for a map of the swarm (`swarm::links`). |
