diff --git a/crates/engine/tree/src/tree/payload_processor/sparse_trie.rs b/crates/engine/tree/src/tree/payload_processor/sparse_trie.rs index 5fdf213b63..34418fd148 100644 --- a/crates/engine/tree/src/tree/payload_processor/sparse_trie.rs +++ b/crates/engine/tree/src/tree/payload_processor/sparse_trie.rs @@ -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:?}"); + } + }, + ); } }