diff options
Diffstat (limited to 'src/swarm')
| -rw-r--r-- | src/swarm/members.rs | 2 | ||||
| -rw-r--r-- | src/swarm/state_file.rs | 2 | ||||
| -rw-r--r-- | src/swarm/sync.rs | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/src/swarm/members.rs b/src/swarm/members.rs index 19abf2b..cb8a558 100644 --- a/src/swarm/members.rs +++ b/src/swarm/members.rs @@ -167,7 +167,7 @@ pub(crate) async fn ensure_registered(state: &AppState) { ) }; let wanted = state.alias.clone(); - let now = state.clock.now_millis(); + let now = state.clock.now_millis().as_u64(); if !registered { let mut entry = json!({ "since": now, "alive": now }); diff --git a/src/swarm/state_file.rs b/src/swarm/state_file.rs index ba9192e..73b80a2 100644 --- a/src/swarm/state_file.rs +++ b/src/swarm/state_file.rs @@ -132,7 +132,7 @@ pub(crate) async fn update(state: &AppState, now: bool) { &replica.doc, state.local_id(), state.electorate_window, - state.clock.now_millis(), + state.clock.now_millis().as_u64(), ) }; let remembered = Remembered { swarm_id, seeds }; diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index 07f66a3..805d700 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -336,7 +336,7 @@ pub(crate) async fn handle_sync( stats.heads_seen(heads_after.len()); let changed = heads_after != heads_before; if changed && measure_propagation { - let now_ms = clock.now_millis() as i64; + let now_ms = clock.now_millis().as_u64() as i64; // Time 0: not stamped (snapshots, older nodes). let delays: Vec<i64> = replica .doc |