github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-04-08 03:01:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore: simplify subtrie hashes parallel loop (#21871)

Browse Source
This commit is contained in:
DaniPopes
2026-02-06 15:31:03 +01:00
committed by GitHub
parent 25003be018
commit 6f7486a61e
1 changed files with 14 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
crates/trie/sparse-parallel/src/trie.rs
View File

@@ -870,26 +870,21 @@ impl SparseTrie for ParallelSparseTrie {
#[cfg(feature = "std")]
// Update subtrie hashes in parallel
{
use rayon::iter::{IntoParallelIterator, ParallelIterator};
use rayon::prelude::*;
let branch_node_masks = &self.branch_node_masks;
let updated_subtries: Vec<_> = changed_subtries
.into_par_iter()
.map(|mut changed_subtrie| {
#[cfg(feature = "metrics")]
let start = std::time::Instant::now();
changed_subtrie.subtrie.update_hashes(
&mut changed_subtrie.prefix_set,
&mut changed_subtrie.update_actions_buf,
branch_node_masks,
);
#[cfg(feature = "metrics")]
self.metrics.subtrie_hash_update_latency.record(start.elapsed());
changed_subtrie
})
.collect();
changed_subtries.par_iter_mut().for_each(|changed_subtrie| {
#[cfg(feature = "metrics")]
let start = std::time::Instant::now();
changed_subtrie.subtrie.update_hashes(
&mut changed_subtrie.prefix_set,
&mut changed_subtrie.update_actions_buf,
&self.branch_node_masks,
);
#[cfg(feature = "metrics")]
self.metrics.subtrie_hash_update_latency.record(start.elapsed());
});
self.insert_changed_subtries(updated_subtries);
self.insert_changed_subtries(changed_subtries);
}
}
@@ -2813,7 +2808,7 @@ impl SparseSubtrie {
/// # Panics
///
/// If the node at the root path does not exist.
#[instrument(level = "trace", target = "trie::parallel_sparse", skip_all, fields(root = ?self.path), ret)]
#[instrument(level = "debug", target = "trie::parallel_sparse", skip_all, fields(root = ?self.path), ret)]
fn update_hashes(
&mut self,
prefix_set: &mut PrefixSet,