From 78f9dbda6c008994ce961cda2e515314f7b16560 Mon Sep 17 00:00:00 2001 From: Roman Krasiuk Date: Fri, 8 Mar 2024 21:13:35 +0100 Subject: [PATCH] chore(txpool): update size metrics on every insert & removal of transactions (#7051) --- crates/transaction-pool/src/pool/txpool.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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.