summaryrefslogtreecommitdiffstats
path: root/src/swarm/peer.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-23 13:21:12 +0200
committertv <tv@krebsco.de>2026-10-23 13:21:12 +0200
commitc32d3ef7bda4353875f28c6ce09f3dce736c4ced (patch)
treea6e53a6a71a487f61fcbcb42d50a428ebb30d630 /src/swarm/peer.rs
parent9d95468df589f34309d1e1cd30ce614b8063a0c8 (diff)
pick pair leader by hash instead of key orderHEADmaster
Diffstat (limited to 'src/swarm/peer.rs')
-rw-r--r--src/swarm/peer.rs2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs
index b6c9700..cec8842 100644
--- a/src/swarm/peer.rs
+++ b/src/swarm/peer.rs
@@ -410,7 +410,7 @@ pub(crate) async fn run_peer_worker(state: AppState) {
let (became_dormant, ping_due, unanswered) = {
let mut peer_state = peer_state_mutex.lock().await;
let became_dormant = ready && peer_state.check_dormancy(&state.timing, now);
- let we_ping = state.local_id() < peer.as_str();
+ let we_ping = crate::swarm::pair::leads(state.local_id(), peer);
let ping_due = peer_state.take_keepalive_due(&state.timing, we_ping, now);
let unanswered = peer_state.take_overdue_sync_reply(now);
(became_dormant, ping_due, unanswered)