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

Lower log level of grandpa until_imported message (#1691)

Browse Source 
* core: gossip: add missing docs

* core: grandpa: lower log level on until_imported
This commit is contained in:
André Silva
2019-02-05 18:37:04 +00:00
committed by Robert Habermeier
parent 1cb02c318b
commit 7c33728510
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/core/finality-grandpa/src/until_imported.rs
+1 -1
View File
@@ -162,7 +162,7 @@ impl<Block: BlockT, Status, I, M> Stream for UntilImported<Block, Status, I, M>
} else { } else {
let next_log = *last_log + LOG_PENDING_INTERVAL; let next_log = *last_log + LOG_PENDING_INTERVAL;
if Instant::now() <= next_log { if Instant::now() <= next_log {
warn!( debug!(
target: "afg", target: "afg",
"Waiting to import block {} before {} votes can be imported. \ "Waiting to import block {} before {} votes can be imported. \
Possible fork?", Possible fork?",
substrate/core/network/src/consensus_gossip.rs
+2 -1
View File
@@ -24,7 +24,6 @@ use rand::{self, seq::SliceRandom};
use lru_cache::LruCache; use lru_cache::LruCache;
use network_libp2p::NodeIndex; use network_libp2p::NodeIndex;
use runtime_primitives::traits::{Block as BlockT, Hash, HashFor}; use runtime_primitives::traits::{Block as BlockT, Hash, HashFor};
use runtime_primitives::generic::BlockId;
pub use message::generic::{Message, ConsensusMessage}; pub use message::generic::{Message, ConsensusMessage};
use protocol::Context; use protocol::Context;
use config::Roles; use config::Roles;
@@ -173,6 +172,8 @@ impl<B: BlockT> ConsensusGossip<B> {
self.peers.remove(&who); self.peers.remove(&who);
} }
/// Prune all existing messages for the given topic and mark it as dead, all
/// new messages for the given topic are ignored.
pub fn collect_garbage_for_topic(&mut self, topic: B::Hash) { pub fn collect_garbage_for_topic(&mut self, topic: B::Hash) {
self.known_dead_topics.insert(topic, ()); self.known_dead_topics.insert(topic, ());
self.collect_garbage(|_| true); self.collect_garbage(|_| true);