diff --git a/substrate/client/transaction-pool/graph/src/listener.rs b/substrate/client/transaction-pool/graph/src/listener.rs index c6a90b0c5b..865255c9c7 100644 --- a/substrate/client/transaction-pool/graph/src/listener.rs +++ b/substrate/client/transaction-pool/graph/src/listener.rs @@ -91,8 +91,12 @@ impl Listene } /// Transaction was removed as invalid. - pub fn invalid(&mut self, tx: &H) { - warn!(target: "txpool", "Extrinsic invalid: {:?}", tx); + pub fn invalid(&mut self, tx: &H, warn: bool) { + if warn { + warn!(target: "txpool", "Extrinsic invalid: {:?}", tx); + } else { + debug!(target: "txpool", "Extrinsic invalid: {:?}", tx); + } self.fire(tx, |watcher| watcher.invalid()); } diff --git a/substrate/client/transaction-pool/graph/src/validated_pool.rs b/substrate/client/transaction-pool/graph/src/validated_pool.rs index 321eed0b62..7f9e407727 100644 --- a/substrate/client/transaction-pool/graph/src/validated_pool.rs +++ b/substrate/client/transaction-pool/graph/src/validated_pool.rs @@ -138,7 +138,7 @@ impl ValidatedPool { Err(err.into()) }, ValidatedTransaction::Unknown(hash, err) => { - self.listener.write().invalid(&hash); + self.listener.write().invalid(&hash, false); Err(err.into()) } } @@ -311,8 +311,8 @@ impl ValidatedPool { match final_status { Status::Future => listener.future(&hash), Status::Ready => listener.ready(&hash, None), - Status::Failed => listener.invalid(&hash), Status::Dropped => listener.dropped(&hash, None), + Status::Failed => listener.invalid(&hash, initial_status.is_some()), } } } @@ -478,7 +478,7 @@ impl ValidatedPool { let mut listener = self.listener.write(); for tx in &invalid { - listener.invalid(&tx.hash); + listener.invalid(&tx.hash, true); } invalid @@ -506,7 +506,7 @@ fn fire_events( base::Imported::Ready { ref promoted, ref failed, ref removed, ref hash } => { listener.ready(hash, None); for f in failed { - listener.invalid(f); + listener.invalid(f, true); } for r in removed { listener.dropped(&r.hash, Some(hash));