Skip to content

Commit

Permalink
[consensus] Add universal committer pipelined tests (#15937)
Browse files Browse the repository at this point in the history
To help with the review, the test scenarios are the same as in
universal_committer_tests.rs & base_committer_tests.rs. Just a different
result with number of leaders being committed due to pipelining.
  • Loading branch information
arun-koshy authored Feb 10, 2024
1 parent 67e52ff commit 237f0cf
Show file tree
Hide file tree
Showing 3 changed files with 795 additions and 1 deletion.
2 changes: 1 addition & 1 deletion consensus/core/src/base_committer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -176,7 +176,7 @@ impl BaseCommitter {

/// Return the wave in which the specified round belongs. This takes into
/// account the round offset for when pipelining is enabled.
fn wave_number(&self, round: Round) -> WaveNumber {
pub(crate) fn wave_number(&self, round: Round) -> WaveNumber {
round.saturating_sub(self.options.round_offset) / self.options.wave_length
}

Expand Down
Loading

0 comments on commit 237f0cf

Please sign in to comment.