Skip to content

Commit

Permalink
fix subtract with overflow bug
Browse files Browse the repository at this point in the history
  • Loading branch information
sistemd committed Dec 13, 2024
1 parent 82ff7ca commit cbd71d9
Showing 1 changed file with 12 additions and 2 deletions.
14 changes: 12 additions & 2 deletions crates/storage/src/connection/event.rs
Original file line number Diff line number Diff line change
Expand Up @@ -584,7 +584,7 @@ pub(crate) fn rebuild_running_event_filter(
)?;

let Some(latest) = latest_stmt
.query_row([], |row| row.get::<_, u64>(0))
.query_row([], |row| row.get_block_number(0))
.optional()
.context("Querying latest block number")?
else {
Expand All @@ -600,12 +600,22 @@ pub(crate) fn rebuild_running_event_filter(
.context("Querying last stored event filter to_block")?;

let first_running_event_filter_block = match last_to_block {
// Last stored block was at the end of the running event filter range, no need
// to rebuild.
Some(last_to_block) if last_to_block == latest.get() => {
let next_block = latest + 1;

return Ok(RunningEventFilter {
filter: AggregateBloom::new(next_block),
next_block,
});
}
Some(last_to_block) => BlockNumber::new_or_panic(last_to_block + 1),
// Event filter table is empty, rebuild running filter from the genesis block.
None => BlockNumber::GENESIS,
};

let total_blocks_to_cover = latest - first_running_event_filter_block.get();
let total_blocks_to_cover = latest.get() - first_running_event_filter_block.get();
let mut covered_blocks = 0;
let mut last_progress_report = Instant::now();

Expand Down

0 comments on commit cbd71d9

Please sign in to comment.