jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(net/peer): remove the duplicated disconnect logic (#9162)

Browse Source 
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
Delweng
2024-06-28 23:15:40 +08:00
committed by GitHub
parent 3bf3b9e3ec
commit 9a2cfe5a5c
1 changed files with 8 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
crates/net/network/src/peers.rs
View File

@ -325,15 +325,6 @@ impl PeersManager {
peer.state = PeerConnectionState::In; peer.state = PeerConnectionState::In;
is_trusted = is_trusted || peer.is_trusted(); is_trusted = is_trusted || peer.is_trusted();
// if a peer is not trusted and we don't have capacity for more inbound connections,
// disconnecting the peer
if !is_trusted && !has_in_capacity {
self.queued_actions.push_back(PeerAction::Disconnect {
peer_id,
reason: Some(DisconnectReason::TooManyPeers),
});
}
} }
Entry::Vacant(entry) => { Entry::Vacant(entry) => {
// peer is missing in the table, we add it but mark it as to be removed after // peer is missing in the table, we add it but mark it as to be removed after
@ -342,16 +333,16 @@ impl PeersManager {
peer.remove_after_disconnect = true; peer.remove_after_disconnect = true;
entry.insert(peer); entry.insert(peer);
self.queued_actions.push_back(PeerAction::PeerAdded(peer_id)); self.queued_actions.push_back(PeerAction::PeerAdded(peer_id));
// disconnect the peer if we don't have capacity for more inbound connections
if !is_trusted && !has_in_capacity {
self.queued_actions.push_back(PeerAction::Disconnect {
peer_id,
reason: Some(DisconnectReason::TooManyPeers),
});
}
} }
} }
// disconnect the peer if we don't have capacity for more inbound connections
if !is_trusted && !has_in_capacity {
self.queued_actions.push_back(PeerAction::Disconnect {
peer_id,
reason: Some(DisconnectReason::TooManyPeers),
});
}
} }
/// Bans the peer temporarily with the configured ban timeout /// Bans the peer temporarily with the configured ban timeout