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

chore: don't include spans for noops (#22538)

Browse Source
This commit is contained in:
Arsenii Kulikov
2026-02-24 20:21:38 +04:00
committed by GitHub
parent d340114d52
commit aed9014e1e
1 changed files with 34 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

70
crates/engine/tree/src/tree/payload_processor/sparse_trie.rs
View File

@@ -428,12 +428,12 @@ where
})
}
#[instrument(
level = "debug",
target = "engine::tree::payload_processor::sparse_trie",
skip_all
)]
fn process_new_updates(&mut self) -> SparseTrieResult<()> {
if self.pending_updates == 0 {
return Ok(());
}
let _span = debug_span!("process_new_updates").entered();
self.pending_updates = 0;
// Firstly apply all new storage and account updates to the tries.
@@ -656,39 +656,37 @@ where
Ok(())
}
#[instrument(
level = "debug",
target = "engine::tree::payload_processor::sparse_trie",
skip_all
)]
fn dispatch_pending_targets(&mut self) {
if !self.pending_targets.is_empty() {
let (targets, chunking_length) = self.pending_targets.take();
dispatch_with_chunking(
targets,
chunking_length,
self.chunk_size,
self.max_targets_for_chunking,
self.proof_worker_handle.available_account_workers(),
self.proof_worker_handle.available_storage_workers(),
MultiProofTargetsV2::chunks,
|proof_targets| {
if let Err(e) = self.proof_worker_handle.dispatch_account_multiproof(
AccountMultiproofInput {
targets: proof_targets,
proof_result_sender: ProofResultContext::new(
self.proof_result_tx.clone(),
0,
HashedPostState::default(),
Instant::now(),
),
},
) {
error!("failed to dispatch account multiproof: {e:?}");
}
},
);
if self.pending_targets.is_empty() {
return;
}
let _span = debug_span!("dispatch_pending_targets").entered();
let (targets, chunking_length) = self.pending_targets.take();
dispatch_with_chunking(
targets,
chunking_length,
self.chunk_size,
self.max_targets_for_chunking,
self.proof_worker_handle.available_account_workers(),
self.proof_worker_handle.available_storage_workers(),
MultiProofTargetsV2::chunks,
|proof_targets| {
if let Err(e) =
self.proof_worker_handle.dispatch_account_multiproof(AccountMultiproofInput {
targets: proof_targets,
proof_result_sender: ProofResultContext::new(
self.proof_result_tx.clone(),
0,
HashedPostState::default(),
Instant::now(),
),
})
{
error!("failed to dispatch account multiproof: {e:?}");
}
},
);
}
}