github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-02-19 03:04:27 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(stages): skip sender unwind when fully pruned (#21988)

Browse Source
This commit is contained in:
Dan Cline
2026-02-09 17:36:20 +00:00
committed by GitHub
parent 5f7ecc6187
commit c558c1d10f
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
crates/stages/stages/src/stages/sender_recovery.rs
View File

@@ -202,13 +202,16 @@ where
) -> Result<UnwindOutput, StageError> {
let (_, unwind_to, _) = input.unwind_block_range_with_threshold(self.commit_threshold);
// Lookup the next tx id after unwind_to block (first tx to remove)
let unwind_tx_from = provider
.block_body_indices(unwind_to)?
.ok_or(ProviderError::BlockBodyIndicesNotFound(unwind_to))?
.next_tx_num();
if self.prune_mode.is_none_or(|mode| !mode.is_full()) {
// Lookup the next tx id after unwind_to block (first tx to remove)
let unwind_tx_from = provider
.block_body_indices(unwind_to)?
.ok_or(ProviderError::BlockBodyIndicesNotFound(unwind_to))?
.next_tx_num();
EitherWriter::new_senders(provider, unwind_to)?.prune_senders(unwind_tx_from, unwind_to)?;
EitherWriter::new_senders(provider, unwind_to)?
.prune_senders(unwind_tx_from, unwind_to)?;
}
Ok(UnwindOutput {
checkpoint: StageCheckpoint::new(unwind_to)