github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-29 17:18:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

chore(pipeline): unwind tracing target (#1933)

Browse Source
This commit is contained in:
Roman Krasiuk
2023-03-23 18:29:47 +02:00
committed by GitHub
parent 56f219fc94
commit b34ab3dc1f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/stages/src/pipeline/mod.rs
View File

@@ -235,12 +235,12 @@ impl<DB: Database, U: SyncStateUpdater> Pipeline<DB, U> {
let mut stage_progress = stage_id.get_progress(tx.deref())?.unwrap_or_default();
if stage_progress < to {
debug!(from = %stage_progress, %to, "Unwind point too far for stage");
debug!(target: "sync::pipeline", from = %stage_progress, %to, "Unwind point too far for stage");
self.listeners.notify(PipelineEvent::Skipped { stage_id });
return Ok(())
}
debug!(from = %stage_progress, %to, ?bad_block, "Starting unwind");
debug!(target: "sync::pipeline", from = %stage_progress, %to, ?bad_block, "Starting unwind");
while stage_progress > to {
let input = UnwindInput { stage_progress, unwind_to: to, bad_block };
self.listeners.notify(PipelineEvent::Unwinding { stage_id, input });