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

Make pushing consensus message loglevel trace (#5342)

Browse Source
This commit is contained in:
ddorgan
2020-03-21 15:49:51 +00:00
committed by GitHub
parent 22f88bf9d1
commit 56264ad1fc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/client/network-gossip/src/state_machine.rs
+2 -2
View File
@@ -20,7 +20,7 @@ use std::collections::{HashMap, HashSet, hash_map::Entry};
use std::sync::Arc;
use std::iter;
use std::time;
use log::{trace, debug};
use log::trace;
use futures::channel::mpsc;
use lru::LruCache;
use libp2p::PeerId;
@@ -399,7 +399,7 @@ impl<B: BlockT> ConsensusGossip<B> {
if let Some(ref mut peer) = self.peers.get_mut(&who) {
peer.known_messages.insert(message_hash);
if let Entry::Occupied(mut entry) = self.live_message_sinks.entry((engine_id, topic)) {
debug!(target: "gossip", "Pushing consensus message to sinks for {}.", topic);
trace!(target: "gossip", "Pushing consensus message to sinks for {}.", topic);
entry.get_mut().retain(|sink| {
if let Err(e) = sink.unbounded_send(TopicNotification {
message: message.clone(),