pub struct ArenaParallelSparseTrie { /* private fields */ }Expand description
An arena-based sparse trie whose subtries can be mutated in parallel.
§Structure
Uses arena allocation (slotmap::SlotMap) for node storage with direct index-based child
pointers, avoiding the per-node hashing overhead of a HashMap-based trie. The trie is split
into two tiers:
- Upper trie (
upper_arena): Contains nodes whose path is shorter thanUPPER_TRIE_MAX_DEPTHnibbles. These are the root and its immediate children. - Lower subtries (
ArenaSparseSubtrie): Each child of an upper-trie branch at the depth boundary becomes the root of its own subtrie, stored as anArenaSparseNode::Subtriechild in the upper arena. Each subtrie owns its own arena, enabling lock-free parallel mutation.
Node placement is determined by path length (not counting a branch’s short key):
- Paths with <
UPPER_TRIE_MAX_DEPTHnibbles live inupper_arena. - Paths with ≥
UPPER_TRIE_MAX_DEPTHnibbles live in a subtrie.
§Node Revealing
Nodes are lazily revealed from proof data via SparseTrie::reveal_nodes. Each node is
placed into the upper arena or delegated to its subtrie based on path depth. Unrevealed
children are stored as ArenaSparseNodeBranchChild::Blinded with their RLP encoding.
When multiple subtries have pending reveals, they are processed in parallel using rayon
(controlled by ArenaParallelismThresholds::min_revealed_nodes).
§Leaf Operations
Leaf updates and removals are applied via SparseTrie::update_leaves. The method walks
the upper trie to route each update to the correct subtrie, then processes subtries in
parallel when the update count exceeds ArenaParallelismThresholds::min_updates.
SparseTrie::update_leaf and SparseTrie::remove_leaf are not yet implemented.
After updates, structural changes (branch collapse, subtrie unwrapping) are handled by propagating dirty state back up through the upper trie.
§Root Hash Calculation
Root hash computation follows a bottom-up approach:
SparseTrie::update_subtrie_hashes: Takes dirty subtries from the upper arena and hashes them in parallel (when dirty leaf count meetsArenaParallelismThresholds::min_dirty_leaves), then walks the upper trie to restore hashed subtries and inline-hash any remaining dirty nodes.SparseTrie::root: Callsupdate_subtrie_hashes, then RLP-encodes the full upper trie depth-first to produce the root hash.
Each node tracks its state via ArenaSparseNodeState (Revealed, Cached, or Dirty)
so only modified subtrees are recomputed.
§Pruning
SparseTrie::prune removes revealed nodes that are not ancestors of any retained leaf.
Pruned nodes are replaced with ArenaSparseNodeBranchChild::Blinded entries using their
cached RLP. Subtries are pruned in parallel when their leaf count exceeds
ArenaParallelismThresholds::min_leaves_for_prune.
Implementations§
Source§impl ArenaParallelSparseTrie
impl ArenaParallelSparseTrie
Sourcepub const fn with_parallelism_thresholds(
self,
thresholds: ArenaParallelismThresholds,
) -> Self
pub const fn with_parallelism_thresholds( self, thresholds: ArenaParallelismThresholds, ) -> Self
Sets the thresholds that control when parallelism is used during operations.
Trait Implementations§
Source§impl Clone for ArenaParallelSparseTrie
impl Clone for ArenaParallelSparseTrie
Source§fn clone(&self) -> ArenaParallelSparseTrie
fn clone(&self) -> ArenaParallelSparseTrie
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ArenaParallelSparseTrie
impl Debug for ArenaParallelSparseTrie
Source§impl Default for ArenaParallelSparseTrie
impl Default for ArenaParallelSparseTrie
Source§impl Drop for ArenaParallelSparseTrie
Available on debug-assertions enabled only.
impl Drop for ArenaParallelSparseTrie
Source§impl SparseTrie for ArenaParallelSparseTrie
impl SparseTrie for ArenaParallelSparseTrie
Source§fn set_root(
&mut self,
root: TrieNodeV2,
masks: Option<BranchNodeMasks>,
retain_updates: bool,
) -> SparseTrieResult<()>
fn set_root( &mut self, root: TrieNodeV2, masks: Option<BranchNodeMasks>, retain_updates: bool, ) -> SparseTrieResult<()>
Source§fn set_updates(&mut self, retain_updates: bool)
fn set_updates(&mut self, retain_updates: bool)
Source§fn reserve_nodes(&mut self, additional: usize)
fn reserve_nodes(&mut self, additional: usize)
Source§fn reveal_nodes(
&mut self,
nodes: &mut [ProofTrieNodeV2],
) -> SparseTrieResult<()>
fn reveal_nodes( &mut self, nodes: &mut [ProofTrieNodeV2], ) -> SparseTrieResult<()>
Source§fn update_leaf<P: TrieNodeProvider>(
&mut self,
_full_path: Nibbles,
_value: Vec<u8>,
_provider: P,
) -> SparseTrieResult<()>
fn update_leaf<P: TrieNodeProvider>( &mut self, _full_path: Nibbles, _value: Vec<u8>, _provider: P, ) -> SparseTrieResult<()>
Source§fn remove_leaf<P: TrieNodeProvider>(
&mut self,
_full_path: &Nibbles,
_provider: P,
) -> SparseTrieResult<()>
fn remove_leaf<P: TrieNodeProvider>( &mut self, _full_path: &Nibbles, _provider: P, ) -> SparseTrieResult<()>
Source§fn is_root_cached(&self) -> bool
fn is_root_cached(&self) -> bool
Source§fn update_subtrie_hashes(&mut self)
fn update_subtrie_hashes(&mut self)
Source§fn get_leaf_value(&self, full_path: &Nibbles) -> Option<&Vec<u8>>
fn get_leaf_value(&self, full_path: &Nibbles) -> Option<&Vec<u8>>
Source§fn find_leaf(
&self,
full_path: &Nibbles,
expected_value: Option<&Vec<u8>>,
) -> Result<LeafLookup, LeafLookupError>
fn find_leaf( &self, full_path: &Nibbles, expected_value: Option<&Vec<u8>>, ) -> Result<LeafLookup, LeafLookupError>
Source§fn updates_ref(&self) -> Cow<'_, SparseTrieUpdates>
fn updates_ref(&self) -> Cow<'_, SparseTrieUpdates>
Source§fn take_updates(&mut self) -> SparseTrieUpdates
fn take_updates(&mut self) -> SparseTrieUpdates
Source§fn wipe(&mut self)
fn wipe(&mut self)
Source§fn clear(&mut self)
fn clear(&mut self)
crate::SparseNode::Empty is inserted at the root. Read moreSource§fn shrink_nodes_to(&mut self, _size: usize)
fn shrink_nodes_to(&mut self, _size: usize)
Source§fn shrink_values_to(&mut self, _size: usize)
fn shrink_values_to(&mut self, _size: usize)
Source§fn size_hint(&self) -> usize
fn size_hint(&self) -> usize
Source§fn memory_size(&self) -> usize
fn memory_size(&self) -> usize
Source§fn prune(&mut self, retained_leaves: &[Nibbles]) -> usize
fn prune(&mut self, retained_leaves: &[Nibbles]) -> usize
Source§fn update_leaves(
&mut self,
updates: &mut B256Map<LeafUpdate>,
proof_required_fn: impl FnMut(B256, u8),
) -> SparseTrieResult<()>
fn update_leaves( &mut self, updates: &mut B256Map<LeafUpdate>, proof_required_fn: impl FnMut(B256, u8), ) -> SparseTrieResult<()>
Source§fn take_debug_recorder(&mut self) -> TrieDebugRecorder
fn take_debug_recorder(&mut self) -> TrieDebugRecorder
Source§fn commit_updates(
&mut self,
_updated: &HashMap<Nibbles, BranchNodeCompact>,
_removed: &HashSet<Nibbles>,
)
fn commit_updates( &mut self, _updated: &HashMap<Nibbles, BranchNodeCompact>, _removed: &HashSet<Nibbles>, )
Source§fn with_root(
self,
root: TrieNodeV2,
masks: Option<BranchNodeMasks>,
retain_updates: bool,
) -> SparseTrieResult<Self>
fn with_root( self, root: TrieNodeV2, masks: Option<BranchNodeMasks>, retain_updates: bool, ) -> SparseTrieResult<Self>
Source§fn with_updates(self, retain_updates: bool) -> Self
fn with_updates(self, retain_updates: bool) -> Self
Source§fn reveal_node(
&mut self,
path: Nibbles,
node: TrieNodeV2,
masks: Option<BranchNodeMasks>,
) -> SparseTrieResult<()>
fn reveal_node( &mut self, path: Nibbles, node: TrieNodeV2, masks: Option<BranchNodeMasks>, ) -> SparseTrieResult<()>
reveal_nodes. Read moreAuto Trait Implementations§
impl Freeze for ArenaParallelSparseTrie
impl RefUnwindSafe for ArenaParallelSparseTrie
impl Send for ArenaParallelSparseTrie
impl Sync for ArenaParallelSparseTrie
impl Unpin for ArenaParallelSparseTrie
impl UnsafeUnpin for ArenaParallelSparseTrie
impl UnwindSafe for ArenaParallelSparseTrie
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<TxEnv, T> FromRecoveredTx<&T> for TxEnvwhere
TxEnv: FromRecoveredTx<T>,
impl<TxEnv, T> FromRecoveredTx<&T> for TxEnvwhere
TxEnv: FromRecoveredTx<T>,
§fn from_recovered_tx(tx: &&T, sender: Address) -> TxEnv
fn from_recovered_tx(tx: &&T, sender: Address) -> TxEnv
TxEnv] from a transaction and a sender address.§impl<TxEnv, T> FromTxWithEncoded<&T> for TxEnvwhere
TxEnv: FromTxWithEncoded<T>,
impl<TxEnv, T> FromTxWithEncoded<&T> for TxEnvwhere
TxEnv: FromTxWithEncoded<T>,
§fn from_encoded_tx(tx: &&T, sender: Address, encoded: Bytes) -> TxEnv
fn from_encoded_tx(tx: &&T, sender: Address, encoded: Bytes) -> TxEnv
TxEnv] from a transaction, its sender, and encoded transaction bytes.§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self, then passes self.as_mut() into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self, then passes self.deref() into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut() only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref() only in debug builds, and is erased in release
builds.§impl<T> TryConv for T
impl<T> TryConv for T
§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
§fn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
impl<T> MaybeDebug for Twhere
T: Debug,
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 352 bytes