diff options
| author | tv <tv@krebsco.de> | 2026-10-31 03:49:56 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 03:49:56 +0100 |
| commit | 43230f03f7b7bd3ed3b4d45c04529ab3527a5ceb (patch) | |
| tree | 974aeda7a385c551ac7f8d4e620d4ca1bce03a36 /src/state/host.rs | |
| parent | 67638bbf82a6fd565d65f2e0bcce556bfa8e7875 (diff) | |
unify sync_on predicate
Diffstat (limited to 'src/state/host.rs')
| -rw-r--r-- | src/state/host.rs | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/state/host.rs b/src/state/host.rs index ee67b80..04b328c 100644 --- a/src/state/host.rs +++ b/src/state/host.rs @@ -41,10 +41,8 @@ impl AppState { let mut peer_state = peer_state_mutex.lock().await; // What it said about syncing with us was about our old epoch. peer_state.syncs_with_us = None; - let gets_our_opening = !peer_state.liveness.is_dormant() - && matches!(peer_state.standing, Standing::Member { .. }) - && peer_state.epoch == Some(local) - && peer_state.reports_ready == Some(true); + let gets_our_opening = + peer_state.syncs_on(local) && peer_state.reports_ready == Some(true); if !gets_our_opening { announce.push(id); } |
