Skip to content

Commit

Permalink
test(pinpoint discrepancies): tx rejections
Browse files Browse the repository at this point in the history
reduce slot time to 20 seconds
  • Loading branch information
cong-or committed Dec 9, 2023
1 parent cc97cdc commit c3b6412
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 4 deletions.
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion jormungandr/Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "jormungandr"
version = "0.15.86"
version = "0.15.87"
authors = [ "[email protected]" ]
license = "MIT OR Apache-2.0"
repository = "https://github.com/input-output-hk/jormungandr"
Expand Down
5 changes: 3 additions & 2 deletions jormungandr/src/fragment/pool.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand All @@ -286,7 +286,7 @@ impl Pool {
.await
}
};
self.metrics.add_tx_rejected_cnt(rejected_fragments_cnt);

self.update_metrics();
(contents, ledger)
}
Expand All @@ -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,
Expand Down

0 comments on commit c3b6412

Please sign in to comment.