1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
crate::ix!(); impl SendPings for PeerManager { fn send_pings(&mut self) { let mut peer_map = self.peer_map.get_mut(); for (ref k,ref mut v) in peer_map.iter_mut() { if v.is_some() { v.get().ping_queued.store(true, atomic::Ordering::Relaxed); } } } }