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

Forgot to handle Banned in inject_connected (#2107)

Browse Source 
* Forgot to handle Banned in inject_connected

* Also add debug for the state
This commit is contained in:
Pierre Krieger
2019-03-25 14:48:43 +01:00
committed by Gav Wood
parent c6addc9bd5
commit 4fe70ee639
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/core/network-libp2p/src/custom_proto/behaviour.rs
+3 -2
View File
@@ -571,7 +571,8 @@ where
match (self.peers.entry(peer_id), connected_point) { match (self.peers.entry(peer_id), connected_point) {
(Entry::Occupied(mut entry), connected_point) => { (Entry::Occupied(mut entry), connected_point) => {
match mem::replace(entry.get_mut(), PeerState::Poisoned) { match mem::replace(entry.get_mut(), PeerState::Poisoned) {
PeerState::Requested | PeerState::PendingRequest { .. } => { PeerState::Requested | PeerState::PendingRequest { .. } |
PeerState::Banned { .. } => {
debug!(target: "sub-libp2p", "Libp2p => Connected({:?}): Connection \ debug!(target: "sub-libp2p", "Libp2p => Connected({:?}): Connection \
requested by PSM (through {:?})", entry.key(), connected_point); requested by PSM (through {:?})", entry.key(), connected_point);
debug!(target: "sub-libp2p", "Handler({:?}) <= Enable", entry.key()); debug!(target: "sub-libp2p", "Handler({:?}) <= Enable", entry.key());
@@ -584,7 +585,7 @@ where
st @ _ => { st @ _ => {
// This is a serious bug either in this state machine or in libp2p. // This is a serious bug either in this state machine or in libp2p.
error!(target: "sub-libp2p", "Received inject_connected for \ error!(target: "sub-libp2p", "Received inject_connected for \
already-connected node"); already-connected node; state is {:?}", st);
*entry.into_mut() = st; *entry.into_mut() = st;
return return
} }