diff options
Diffstat (limited to 'src/swarm/peer.rs')
| -rw-r--r-- | src/swarm/peer.rs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs index adde444..836a967 100644 --- a/src/swarm/peer.rs +++ b/src/swarm/peer.rs @@ -171,7 +171,7 @@ pub(crate) async fn remember_peer(state: &AppState, peer: &str) { let mut peer_states = state.peer_states.write().await; if !peer_states.contains_key(peer) { - peer_states.entry(peer.to_owned()).or_default(); + peer_states.insert(peer.to_owned(), state.new_peer_state(peer)); info!( peer = %peer, peer_count = peer_states.len(), @@ -410,8 +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 = crate::swarm::pair::leads(state.local_id(), peer); - let ping_due = peer_state.take_keepalive_due(&state.timing, we_ping, now); + let ping_due = peer_state.take_keepalive_due(&state.timing, now); let unanswered = peer_state.take_overdue_sync_reply(now); (became_dormant, ping_due, unanswered) }; |
