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 | 4ee957385ebe392a2d1fe9ad09f0a8477be78f05 (patch) | |
| tree | c6b55503a368033837ca3edc7e9e822db517247c /src/state | |
| parent | 6b939f2c73e8909e0a2270e99d934be90181dfd1 (diff) | |
detect local clock jumps
Diffstat (limited to 'src/state')
| -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`). |
