pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-11 10:41:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Always accept incoming connections (#2101)

Browse Source
This commit is contained in:
Pierre Krieger
2019-03-24 11:48:54 +01:00
committed by Arkadiy Paronyan
parent a1f3b0b529
commit b6c54b5c40
1 changed files with 1 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/core/network-libp2p/src/custom_proto/behaviour.rs
+1 -16
View File
@@ -563,7 +563,7 @@ where
match (self.peers.entry(peer_id), connected_point) {
(Entry::Occupied(mut entry), connected_point) => {
match mem::replace(entry.get_mut(), PeerState::Poisoned) {
PeerState::Requested => {
PeerState::Requested | PeerState::PendingRequest { .. } => {
debug!(target: "sub-libp2p", "Libp2p => Connected({:?}): Connection \
requested by PSM (through {:?})", entry.key(), connected_point);
debug!(target: "sub-libp2p", "Handler({:?}) <= Enable", entry.key());
@@ -573,21 +573,6 @@ where
});
*entry.into_mut() = PeerState::Enabled { open: false, connected_point };
}
PeerState::PendingRequest { timer } => {
debug!(target: "sub-libp2p", "Libp2p => Connected({:?}): Connection \
requested by PSM (through {:?}) but node is banned", entry.key(),
connected_point);
debug!(target: "sub-libp2p", "Handler({:?}) <= Disable", entry.key());
self.events.push(NetworkBehaviourAction::SendEvent {
peer_id: entry.key().clone(),
event: CustomProtoHandlerIn::Disable,
});
*entry.into_mut() = PeerState::DisabledPendingEnable {
open: false,
connected_point,
timer,
};
}
st @ _ => {
// This is a serious bug either in this state machine or in libp2p.
error!(target: "sub-libp2p", "Received inject_connected for \