diff --git a/util/src/network/host.rs b/util/src/network/host.rs index 75602d27f..146eab2cc 100644 --- a/util/src/network/host.rs +++ b/util/src/network/host.rs @@ -754,7 +754,8 @@ impl Host where Message: Send + Sync + Clone { if let Some(session) = session.clone() { let mut s = session.lock().unwrap(); loop { - match s.readable(io, &self.info.read().unwrap()) { + let session_result = s.readable(io, &self.info.read().unwrap()); + match session_result { Err(e) => { trace!(target: "network", "Session read error: {}:{:?} ({:?}) {:?}", token, s.id(), s.remote_addr(), e); if let UtilError::Network(NetworkError::Disconnect(DisconnectReason::IncompatibleProtocol)) = e { @@ -771,7 +772,6 @@ impl Host where Message: Send + Sync + Clone { self.num_sessions.fetch_add(1, AtomicOrdering::SeqCst); if !s.info.originated { let session_count = self.session_count(); - let reserved_nodes = self.reserved_nodes.read().unwrap(); let (ideal_peers, reserved_only) = { let info = self.info.read().unwrap(); (info.config.ideal_peers, info.config.non_reserved_mode == NonReservedPeerMode::Deny) @@ -779,7 +779,7 @@ impl Host where Message: Send + Sync + Clone { if session_count >= ideal_peers as usize || reserved_only { // only proceed if the connecting peer is reserved. - if !reserved_nodes.contains(s.id().unwrap()) { + if !self.reserved_nodes.read().unwrap().contains(s.id().unwrap()) { s.disconnect(io, DisconnectReason::TooManyPeers); return; }