reth_trie_parallel/
storage_root_targets.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
use alloy_primitives::{map::B256HashMap, B256};
use derive_more::{Deref, DerefMut};
use reth_trie::prefix_set::PrefixSet;

/// Target accounts with corresponding prefix sets for storage root calculation.
#[derive(Deref, DerefMut, Debug)]
pub struct StorageRootTargets(B256HashMap<PrefixSet>);

impl StorageRootTargets {
    /// Create new storage root targets from updated post state accounts
    /// and storage prefix sets.
    ///
    /// NOTE: Since updated accounts and prefix sets always overlap,
    /// it's important that iterator over storage prefix sets takes precedence.
    pub fn new(
        changed_accounts: impl IntoIterator<Item = B256>,
        storage_prefix_sets: impl IntoIterator<Item = (B256, PrefixSet)>,
    ) -> Self {
        Self(
            changed_accounts
                .into_iter()
                .map(|address| (address, PrefixSet::default()))
                .chain(storage_prefix_sets)
                .collect(),
        )
    }
}

impl IntoIterator for StorageRootTargets {
    type Item = (B256, PrefixSet);
    type IntoIter = std::collections::hash_map::IntoIter<B256, PrefixSet>;

    fn into_iter(self) -> Self::IntoIter {
        self.0.into_iter()
    }
}

impl rayon::iter::IntoParallelIterator for StorageRootTargets {
    type Iter = rayon::collections::hash_map::IntoIter<B256, PrefixSet>;
    type Item = (B256, PrefixSet);

    fn into_par_iter(self) -> Self::Iter {
        self.0.into_par_iter()
    }
}