diff options
Diffstat (limited to 'src/swarm/peer/handshake.rs')
| -rw-r--r-- | src/swarm/peer/handshake.rs | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/swarm/peer/handshake.rs b/src/swarm/peer/handshake.rs index 7e494c6..109a42f 100644 --- a/src/swarm/peer/handshake.rs +++ b/src/swarm/peer/handshake.rs @@ -314,27 +314,27 @@ pub(super) async fn establish_peer( ) -> Result<()> { let expected_swarm = state.swarm_id().await; - if let Some(expected) = &expected_swarm { - if expected != &swarm_id { - bail!( - "Incompatible swarm at {peer}: expected {}, received {}", - expected, - swarm_id - ); - } + if let Some(expected) = &expected_swarm + && expected != &swarm_id + { + bail!( + "Incompatible swarm at {peer}: expected {}, received {}", + expected, + swarm_id + ); } let peer_state_mutex = state.get_or_create_peer_state(peer).await; let mut peer_state = peer_state_mutex.lock().await; - if let Standing::Member { swarm_id: existing } = &peer_state.standing { - if existing != &swarm_id { - bail!( - "Peer {peer} changed swarm identity from {} to {}", - existing, - swarm_id - ); - } + if let Standing::Member { swarm_id: existing } = &peer_state.standing + && existing != &swarm_id + { + bail!( + "Peer {peer} changed swarm identity from {} to {}", + existing, + swarm_id + ); } // Lock order: peer mutex -> lifecycle. |