jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(tree): use MultiProofTargets for PrefetchProofs (#13717)

Browse Source
This commit is contained in:
Dan Cline
2025-01-09 15:27:50 -05:00
committed by GitHub
parent 1f78b9e7e4
commit 986c75434a
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
crates/engine/tree/src/tree/root.rs
View File

@ -1,6 +1,6 @@
//! State root task related functionality. //! State root task related functionality.
use alloy_primitives::{map::HashSet, Address}; use alloy_primitives::map::HashSet;
use derive_more::derive::Deref; use derive_more::derive::Deref;
use rayon::iter::{ParallelBridge, ParallelIterator}; use rayon::iter::{ParallelBridge, ParallelIterator};
use reth_errors::{ProviderError, ProviderResult}; use reth_errors::{ProviderError, ProviderResult};
@ -101,7 +101,7 @@ impl<Factory> StateRootConfig<Factory> {
#[derive(Debug)] #[derive(Debug)]
pub enum StateRootMessage<BPF: BlindedProviderFactory> { pub enum StateRootMessage<BPF: BlindedProviderFactory> {
/// Prefetch proof targets /// Prefetch proof targets
PrefetchProofs(HashSet<Address>), PrefetchProofs(MultiProofTargets),
/// New state update from transaction execution /// New state update from transaction execution
StateUpdate(EvmState), StateUpdate(EvmState),
/// Proof calculation completed for a specific state update /// Proof calculation completed for a specific state update
@ -340,21 +340,19 @@ where
fn on_prefetch_proof( fn on_prefetch_proof(
scope: &rayon::Scope<'env>, scope: &rayon::Scope<'env>,
config: StateRootConfig<Factory>, config: StateRootConfig<Factory>,
targets: HashSet<Address>, targets: MultiProofTargets,
fetched_proof_targets: &mut MultiProofTargets, fetched_proof_targets: &mut MultiProofTargets,
proof_sequence_number: u64, proof_sequence_number: u64,
state_root_message_sender: Sender<StateRootMessage<BPF>>, state_root_message_sender: Sender<StateRootMessage<BPF>>,
thread_pool: Arc<rayon::ThreadPool>, thread_pool: Arc<rayon::ThreadPool>,
) { ) {
let proof_targets = extend_multi_proof_targets_ref(fetched_proof_targets, &targets);
targets.into_iter().map(|address| (keccak256(address), Default::default())).collect();
extend_multi_proof_targets_ref(fetched_proof_targets, &proof_targets);
Self::spawn_multiproof( Self::spawn_multiproof(
scope, scope,
config, config,
Default::default(), Default::default(),
proof_targets, targets,
proof_sequence_number, proof_sequence_number,
state_root_message_sender, state_root_message_sender,
thread_pool, thread_pool,