diff --git a/crates/transaction-pool/src/pool/txpool.rs b/crates/transaction-pool/src/pool/txpool.rs index 9c2bfc91a9..91e1f1022a 100644 --- a/crates/transaction-pool/src/pool/txpool.rs +++ b/crates/transaction-pool/src/pool/txpool.rs @@ -540,6 +540,9 @@ impl TxPool { AddedTransaction::Parked { transaction, subpool: move_to, replaced } }; + // Update size metrics after adding and potentially moving transactions. + self.update_size_metrics(); + Ok(res) } Err(err) => { @@ -648,7 +651,10 @@ impl TxPool { &mut self, hashes: Vec, ) -> Vec>> { - hashes.into_iter().filter_map(|hash| self.remove_transaction_by_hash(&hash)).collect() + let txs = + hashes.into_iter().filter_map(|hash| self.remove_transaction_by_hash(&hash)).collect(); + self.update_size_metrics(); + txs } /// Remove the transaction from the __entire__ pool.