summaryrefslogtreecommitdiffstats
path: root/src/swarm/peer.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/swarm/peer.rs')
-rw-r--r--src/swarm/peer.rs5
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)
};