pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-07-24 22:55:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Show reputation changes when dropping peer (#7655)

Browse Source 
* Show reputation changes when dropping peer

* Print all
This commit is contained in:
Pierre Krieger
2020-12-02 17:34:05 +01:00
committed by GitHub
parent 9d43568e4e
commit 3761fe3161
1 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/client/peerset/src/lib.rs
+16 -6
View File
@@ -103,7 +103,7 @@ impl PeersetHandle {
pub fn set_reserved_only(&self, reserved: bool) { pub fn set_reserved_only(&self, reserved: bool) {
let _ = self.tx.unbounded_send(Action::SetReservedOnly(reserved)); let _ = self.tx.unbounded_send(Action::SetReservedOnly(reserved));
} }
/// Set reserved peers to the new set. /// Set reserved peers to the new set.
pub fn set_reserved_peers(&self, peer_ids: HashSet<PeerId>) { pub fn set_reserved_peers(&self, peer_ids: HashSet<PeerId>) {
let _ = self.tx.unbounded_send(Action::SetReservedPeers(peer_ids)); let _ = self.tx.unbounded_send(Action::SetReservedPeers(peer_ids));
@@ -252,7 +252,7 @@ impl Peerset {
fn on_remove_reserved_peer(&mut self, peer_id: PeerId) { fn on_remove_reserved_peer(&mut self, peer_id: PeerId) {
self.on_remove_from_priority_group(RESERVED_NODES, peer_id); self.on_remove_from_priority_group(RESERVED_NODES, peer_id);
} }
fn on_set_reserved_peers(&mut self, peer_ids: HashSet<PeerId>) { fn on_set_reserved_peers(&mut self, peer_ids: HashSet<PeerId>) {
self.on_set_priority_group(RESERVED_NODES, peer_ids); self.on_set_priority_group(RESERVED_NODES, peer_ids);
} }
@@ -357,8 +357,18 @@ impl Peerset {
); );
} }
}, },
peersstate::Peer::NotConnected(mut peer) => peer.add_reputation(change.value), peersstate::Peer::NotConnected(mut peer) => {
peersstate::Peer::Unknown(peer) => peer.discover().add_reputation(change.value), trace!(target: "peerset", "Report {}: {:+} to {}. Reason: {}",
peer_id, change.value, peer.reputation(), change.reason
);
peer.add_reputation(change.value)
},
peersstate::Peer::Unknown(peer) => {
trace!(target: "peerset", "Discover {}: {:+}. Reason: {}",
peer_id, change.value, change.reason
);
peer.discover().add_reputation(change.value)
},
} }
} }
@@ -555,8 +565,6 @@ impl Peerset {
/// Must only be called after the PSM has either generated a `Connect` message with this /// Must only be called after the PSM has either generated a `Connect` message with this
/// `PeerId`, or accepted an incoming connection with this `PeerId`. /// `PeerId`, or accepted an incoming connection with this `PeerId`.
pub fn dropped(&mut self, peer_id: PeerId) { pub fn dropped(&mut self, peer_id: PeerId) {
trace!(target: "peerset", "Dropping {:?}", peer_id);
// We want reputations to be up-to-date before adjusting them. // We want reputations to be up-to-date before adjusting them.
self.update_time(); self.update_time();
@@ -564,6 +572,8 @@ impl Peerset {
peersstate::Peer::Connected(mut entry) => { peersstate::Peer::Connected(mut entry) => {
// Decrease the node's reputation so that we don't try it again and again and again. // Decrease the node's reputation so that we don't try it again and again and again.
entry.add_reputation(DISCONNECT_REPUTATION_CHANGE); entry.add_reputation(DISCONNECT_REPUTATION_CHANGE);
trace!(target: "peerset", "Dropping {}: {:+} to {}",
peer_id, DISCONNECT_REPUTATION_CHANGE, entry.reputation());
entry.disconnect(); entry.disconnect();
} }
peersstate::Peer::NotConnected(_) | peersstate::Peer::Unknown(_) => peersstate::Peer::NotConnected(_) | peersstate::Peer::Unknown(_) =>