Compare commits

...

1 Commits

Author SHA1 Message Date
klkvr
ae9042a5fb wip 2026-04-23 21:25:48 +04:00

View File

@@ -534,7 +534,7 @@ where
let mut handle = ensure_ok!(self.spawn_payload_processor(
env.clone(),
txs,
provider_builder,
provider_builder.clone(),
overlay_factory.clone(),
strategy,
));
@@ -764,10 +764,19 @@ where
}
let (root, updates) = ensure_ok_post_block!(
Self::compute_state_root_serial(overlay_factory.clone(), &hashed_state),
Self::compute_state_root_serial_with_provider(
provider_builder.clone(),
&hashed_state
),
block
);
self.compare_trie_updates_with_serial(
overlay_factory.clone(),
&hashed_state,
updates.clone(),
);
if state_root_task_failed {
self.metrics.block_validation.state_root_task_fallback_success_total.increment(1);
}
@@ -1126,6 +1135,14 @@ where
.root_with_updates()?)
}
fn compute_state_root_serial_with_provider(
provider_builder: StateProviderBuilder<N, P>,
hashed_state: &LazyHashedPostState,
) -> ProviderResult<(B256, TrieUpdates)> {
let provider = provider_builder.build()?;
provider.state_root_with_updates(hashed_state.get().clone())
}
/// Awaits the state root from the background task, with an optional timeout fallback.
///
/// If a timeout is configured (`state_root_task_timeout`), this method first waits for the