aboutsummaryrefslogtreecommitdiffstats
path: root/src/state
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-31 06:54:59 +0100
committertv <tv@krebsco.de>2026-10-31 06:54:59 +0100
commitb67c08db206494ded718f17ff4afd1ec4c0b59a4 (patch)
tree63545aa5ef326db41fe03a59b45f8e24e11370dd /src/state
parentdf3f11a337955dd703199cc2b037d4bfb698ceba (diff)
propagate clock figures
Diffstat (limited to 'src/state')
-rw-r--r--src/state/mod.rs3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/state/mod.rs b/src/state/mod.rs
index cf50b2a..ec8823a 100644
--- a/src/state/mod.rs
+++ b/src/state/mod.rs
@@ -116,6 +116,9 @@ pub(crate) struct AppState {
/// This node's clock is off when it differs from most of its peers' by more than
/// this (`--clock-skew-warn`, `swarm::skew`); 0: never.
pub(crate) clock_skew_warn: Duration,
+ /// 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>>>,
/// Chunked transfers served and fetched (`swarm::blob`).