src/cloud.rs

@@ -339,11 +339,10 @@ impl<D: Device, P: Protocol, S: Socket, TS: TimeSource> GenericCloud<D, P, S, TS
             }
         }
         for addr in del {
+            self.peers.remove(&addr);
             self.pending_inits.remove(&addr);
-            if self.peers.remove(&addr).is_some() {
             self.connect_sock(addr)?;
         }
-        }
         Ok(())
     }
 
@@ -717,15 +716,6 @@ impl<D: Device, P: Protocol, S: Socket, TS: TimeSource> GenericCloud<D, P, S, TS
         let msg_result = if let Some(init) = self.pending_inits.get_mut(&src) {
             init.handle_message(data)
         } else if is_init_message(data.message()) {
-            let mut result = None;
-            if let Some(peer) = self.peers.get_mut(&src) {
-                if peer.crypto.has_init() {
-                    result = Some(peer.crypto.handle_message(data))
-                }
-            }
-            if let Some(result) = result {
-                result
-            } else {
             let mut init = self.crypto.peer_instance(self.create_node_info());
             let msg_result = init.handle_message(data);
             match msg_result {
@@ -735,7 +725,6 @@ impl<D: Device, P: Protocol, S: Socket, TS: TimeSource> GenericCloud<D, P, S, TS
                 }
                 Err(err) => return Err(err)
             }
-            }
         } else if let Some(peer) = self.peers.get_mut(&src) {
             peer.crypto.handle_message(data)
         } else {

src/crypto/mod.rs

@@ -269,10 +269,6 @@ impl<P: Payload> PeerCrypto<P> {
         }
     }
 
-    pub fn has_init(&self) -> bool {
-        self.init.is_some()
-    }
-
     pub fn is_ready(&self) -> bool {
         self.core.is_some()
     }