+
+ /// This function should be called roughly once every 30 seconds.
+ /// It will send pings to each peer and disconnect those which did not respond to the last round of pings.
+
+ /// Will most likely call send_data on all of the registered descriptors, thus, be very careful with reentrancy issues!
+ pub fn timer_tick_occured(&self) {
+ let mut peers_lock = self.peers.lock().unwrap();
+ {
+ let peers = &mut *peers_lock;
+ let peers_needing_send = &mut peers.peers_needing_send;
+ let node_id_to_descriptor = &mut peers.node_id_to_descriptor;
+ let peers = &mut peers.peers;
+ let mut descriptors_needing_disconnect = Vec::new();
+
+ peers.retain(|descriptor, peer| {
+ if peer.awaiting_pong {
+ peers_needing_send.remove(descriptor);
+ descriptors_needing_disconnect.push(descriptor.clone());
+ match peer.their_node_id {
+ Some(node_id) => {
+ node_id_to_descriptor.remove(&node_id);
+ self.message_handler.chan_handler.peer_disconnected(&node_id, true);
+ }
+ None => {}
+ }
+ return false;
+ }
+
+ if !peer.channel_encryptor.is_ready_for_encryption() {
+ // The peer needs to complete its handshake before we can exchange messages
+ return true;
+ }
+
+ let ping = msgs::Ping {
+ ponglen: 0,
+ byteslen: 64,
+ };
+ peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encode_msg!(&ping)));
+
+ let mut descriptor_clone = descriptor.clone();
+ self.do_attempt_write_data(&mut descriptor_clone, peer);
+
+ peer.awaiting_pong = true;
+ true
+ });
+
+ for mut descriptor in descriptors_needing_disconnect.drain(..) {
+ descriptor.disconnect_socket();
+ }
+ }
+ }