diff --git a/Cargo.lock b/Cargo.lock index 813c45e3e7..30e2aa02c9 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -2637,7 +2637,7 @@ dependencies = [ [[package]] name = "jormungandr" -version = "0.15.86" +version = "0.15.87" dependencies = [ "arc-swap", "async-trait", diff --git a/jormungandr/Cargo.toml b/jormungandr/Cargo.toml index 86e5e693e4..36d4f50ef3 100644 --- a/jormungandr/Cargo.toml +++ b/jormungandr/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "jormungandr" -version = "0.15.86" +version = "0.15.87" authors = [ "dev@iohk.io" ] license = "MIT OR Apache-2.0" repository = "https://github.com/input-output-hk/jormungandr" diff --git a/jormungandr/src/fragment/pool.rs b/jormungandr/src/fragment/pool.rs index e09a83afed..dbeeea111e 100644 --- a/jormungandr/src/fragment/pool.rs +++ b/jormungandr/src/fragment/pool.rs @@ -270,7 +270,7 @@ impl Pool { let FragmentSelectionResult { contents, ledger, - rejected_fragments_cnt, + rejected_fragments_cnt: _, } = match selection_alg { FragmentSelectionAlgorithmParams::OldestFirst => { let mut selection_alg = OldestFirst::new(); @@ -286,7 +286,7 @@ impl Pool { .await } }; - self.metrics.add_tx_rejected_cnt(rejected_fragments_cnt); + self.update_metrics(); (contents, ledger) } @@ -301,6 +301,7 @@ impl Pool { let tip = self.tip.get_ref().await; let block_date = get_current_block_date(&tip); let fragment_ids = self.pool.remove_expired_txs(block_date); + self.metrics.add_tx_rejected_cnt(fragment_ids.len()); self.logs.modify_all( fragment_ids,