Skip to content
Snippets Groups Projects
Commit 26a53ac0 authored by Nikolay Volf's avatar Nikolay Volf Committed by Tomasz Drwięga
Browse files

add debug logs (#4657)

parent 482ca522
No related merge requests found
...@@ -205,6 +205,7 @@ impl<Block, B, E, RA, A> ProposerInner<Block, SubstrateClient<B, E, Block, RA>, ...@@ -205,6 +205,7 @@ impl<Block, B, E, RA, A> ProposerInner<Block, SubstrateClient<B, E, Block, RA>,
let pending_iterator = self.transaction_pool.ready(); let pending_iterator = self.transaction_pool.ready();
debug!("Attempting to push transactions from the pool."); debug!("Attempting to push transactions from the pool.");
debug!("Pool status: {:?}", self.transaction_pool.status());
for pending_tx in pending_iterator { for pending_tx in pending_iterator {
if (self.now)() > deadline { if (self.now)() > deadline {
debug!( debug!(
......
...@@ -470,12 +470,15 @@ impl<B: ChainApi> ValidatedPool<B> { ...@@ -470,12 +470,15 @@ impl<B: ChainApi> ValidatedPool<B> {
return vec![] return vec![]
} }
debug!(target: "txpool", "Removing invalid transactions: {:?}", hashes);
// temporarily ban invalid transactions // temporarily ban invalid transactions
debug!(target: "txpool", "Banning invalid transactions: {:?}", hashes);
self.rotator.ban(&time::Instant::now(), hashes.iter().cloned()); self.rotator.ban(&time::Instant::now(), hashes.iter().cloned());
let invalid = self.pool.write().remove_subtree(hashes); let invalid = self.pool.write().remove_subtree(hashes);
debug!(target: "txpool", "Removed invalid transactions: {:?}", invalid);
let mut listener = self.listener.write(); let mut listener = self.listener.write();
for tx in &invalid { for tx in &invalid {
listener.invalid(&tx.hash, true); listener.invalid(&tx.hash, true);
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment