diff options
| author | tv <tv@krebsco.de> | 2026-11-07 22:35:10 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-07 22:35:10 +0100 |
| commit | c016fc783ff29e9069a446e17876046df64760a8 (patch) | |
| tree | 036850a3e3a580dfa5b73f91be53b59c267ce82a /src/api/dashboard/mod.rs | |
| parent | 7c6716358503abee5fab960c45e5fc2de5f61203 (diff) | |
dashboard: clocks on the page
The page compares the clocks the reports on its map carry: this
node's peers', and those of the nodes it subscribes to; the node no
longer gathers them from LINKS (api/dashboard/clocks.rs goes).
Auth plan M3 (preparing LINKS' removal).
Diffstat (limited to 'src/api/dashboard/mod.rs')
| -rw-r--r-- | src/api/dashboard/mod.rs | 15 |
1 files changed, 1 insertions, 14 deletions
diff --git a/src/api/dashboard/mod.rs b/src/api/dashboard/mod.rs index e86475f..78e8352 100644 --- a/src/api/dashboard/mod.rs +++ b/src/api/dashboard/mod.rs @@ -15,10 +15,7 @@ //! member tells of a change as it happens; the same answers for all clients. Or, if //! asked (`POST /admin/dashboard/links?live=false`, for every client, until asked //! otherwise or the node restarts), only asked every `LINKS_EVERY`, without -//! subscribing: fewer messages in the swarm, a map up to `LINKS_EVERY` behind. With -//! the clocks the links carry, every member's clock against the swarm's (`clocks`). - -mod clocks; +//! subscribing: fewer messages in the swarm, a map up to `LINKS_EVERY` behind. use std::collections::{BTreeMap, BTreeSet}; use std::convert::Infallible; @@ -396,15 +393,6 @@ async fn build(state: &AppState, graph: &Graph, live: bool) -> JsonValue { "epoch": epoch_json(epochs.get(member).copied()) }), ); } - let clocks = clocks::swarm( - local, - std::iter::once((local, &own[..])).chain( - replies - .iter() - .map(|(member, _, member_links)| (member.as_str(), &member_links[..])), - ), - u64::try_from(state.clock_skew_warn.as_millis()).unwrap_or(u64::MAX), - ); // Everyone on the map: in the member list's graph, measured, or at the other end of // a link measured. A node that joined through others is linked to them before its // registration reaches this node, and before the graph is computed again @@ -435,7 +423,6 @@ async fn build(state: &AppState, graph: &Graph, live: bool) -> JsonValue { "members": members_json, "intended": intended, "measured": measured, - "clocks": clocks, "live": live, }, "remakes": remakes, |
