github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-04-08 03:01:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat(stages): add more logs to Execution (#9524)

Browse Source
This commit is contained in:
Alexey Shekhirin
2024-07-15 16:58:38 +01:00
committed by GitHub
parent b51aff3b73
commit 5734b1727f
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crates/stages/api/src/pipeline/mod.rs
View File

@@ -420,6 +420,8 @@ where
};
}
let provider_rw = self.provider_factory.provider_rw()?;
self.event_sender.notify(PipelineEvent::Run {
pipeline_stages_progress: PipelineStagesProgress {
current: stage_index + 1,
@@ -430,7 +432,6 @@ where
target,
});
let provider_rw = self.provider_factory.provider_rw()?;
match stage.execute(&provider_rw, exec_input) {
Ok(out @ ExecOutput { checkpoint, done }) => {
made_progress |=

5
crates/stages/stages/src/stages/execution.rs
View File

@@ -209,6 +209,7 @@ where
let static_file_producer = if self.prune_modes.receipts.is_none() &&
self.prune_modes.receipts_log_filter.is_empty()
{
debug!(target: "sync::stages::execution", start = start_block, "Preparing static file producer");
let mut producer = prepare_static_file_producer(provider, start_block)?;
// Since there might be a database <-> static file inconsistency (read
// `prepare_static_file_producer` for context), we commit the change straight away.
@@ -545,6 +546,8 @@ fn calculate_gas_used_from_headers(
provider: &StaticFileProvider,
range: RangeInclusive<BlockNumber>,
) -> Result<u64, ProviderError> {
debug!(target: "sync::stages::execution", ?range, "Calculating gas used from headers");
let mut gas_total = 0;
let start = Instant::now();
@@ -559,7 +562,7 @@ fn calculate_gas_used_from_headers(
}
let duration = start.elapsed();
trace!(target: "sync::stages::execution", ?range, ?duration, "Time elapsed in calculate_gas_used_from_headers");
debug!(target: "sync::stages::execution", ?range, ?duration, "Finished calculating gas used from headers");
Ok(gas_total)
}