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

validator-discovery: some extra logs (#3157)

Browse Source 
* remove duplicate logging

* validator-discovery: add extra logging
This commit is contained in:
Andronik Ordian
2021-06-03 16:17:24 +02:00
committed by GitHub
parent 53de6871e0
commit bd66121324
3 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/network/bridge/src/lib.rs
+2
View File
@@ -436,6 +436,8 @@ where
if !rep.is_benefit() { if !rep.is_benefit() {
tracing::debug!( tracing::debug!(
target: LOG_TARGET, target: LOG_TARGET,
?peer,
?rep,
action = "ReportPeer" action = "ReportPeer"
); );
} }
polkadot/node/network/bridge/src/network.rs
-6
View File
@@ -211,12 +211,6 @@ impl Network for Arc<NetworkService<Block, Hash>> {
fn start_send(self: Pin<&mut Self>, action: NetworkAction) -> SubsystemResult<()> { fn start_send(self: Pin<&mut Self>, action: NetworkAction) -> SubsystemResult<()> {
match action { match action {
NetworkAction::ReputationChange(peer, cost_benefit) => { NetworkAction::ReputationChange(peer, cost_benefit) => {
tracing::debug!(
target: LOG_TARGET,
"Changing reputation: {:?} for {}",
cost_benefit,
peer
);
self.0.report_peer(peer, cost_benefit.into_base_rep()) self.0.report_peer(peer, cost_benefit.into_base_rep())
} }
NetworkAction::DisconnectPeer(peer, peer_set) => self NetworkAction::DisconnectPeer(peer, peer_set) => self
polkadot/node/network/bridge/src/validator_discovery.rs
+12 -2
View File
@@ -89,6 +89,7 @@ impl<N: Network, AD: AuthorityDiscovery> Service<N, AD> {
// collect multiaddress of validators // collect multiaddress of validators
let mut failed_to_resolve: usize = 0; let mut failed_to_resolve: usize = 0;
let mut newly_requested = HashSet::new(); let mut newly_requested = HashSet::new();
let requested = validator_ids.len();
for authority in validator_ids.into_iter() { for authority in validator_ids.into_iter() {
let result = authority_discovery_service.get_addresses_by_authority_id(authority.clone()).await; let result = authority_discovery_service.get_addresses_by_authority_id(authority.clone()).await;
if let Some(addresses) = result { if let Some(addresses) = result {
@@ -101,15 +102,24 @@ impl<N: Network, AD: AuthorityDiscovery> Service<N, AD> {
let state = &mut self.state[peer_set]; let state = &mut self.state[peer_set];
// clean up revoked requests // clean up revoked requests
let multiaddr_to_remove = state.previously_requested let multiaddr_to_remove: HashSet<_> = state.previously_requested
.difference(&newly_requested) .difference(&newly_requested)
.cloned() .cloned()
.collect(); .collect();
let multiaddr_to_add = newly_requested.difference(&state.previously_requested) let multiaddr_to_add: HashSet<_> = newly_requested.difference(&state.previously_requested)
.cloned() .cloned()
.collect(); .collect();
state.previously_requested = newly_requested; state.previously_requested = newly_requested;
tracing::debug!(
target: LOG_TARGET,
?peer_set,
?requested,
added = multiaddr_to_add.len(),
removed = multiaddr_to_remove.len(),
?failed_to_resolve,
"New ConnectToValidators request",
);
// ask the network to connect to these nodes and not disconnect // ask the network to connect to these nodes and not disconnect
// from them until removed from the set // from them until removed from the set
if let Err(e) = network_service.add_to_peers_set( if let Err(e) = network_service.add_to_peers_set(