github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-02-19 03:04:27 -05:00
Code Issues Packages Projects Releases Wiki Activity

perf(engine): use par_bridge_buffered instead of par_bridge for storage trie updates (#21827)

Browse Source 
Co-authored-by: Amp <amp@ampcode.com>
This commit is contained in:
Matthias Seitz
2026-02-04 23:07:14 +01:00
committed by GitHub
parent 9a026ec1cf
commit 97588a07a4
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
crates/engine/tree/src/tree/payload_processor/sparse_trie.rs
View File

@@ -10,7 +10,7 @@ use crate::tree::{
use alloy_primitives::B256;
use alloy_rlp::{Decodable, Encodable};
use crossbeam_channel::{Receiver as CrossbeamReceiver, Sender as CrossbeamSender};
use rayon::iter::{IntoParallelRefMutIterator, ParallelBridge, ParallelIterator};
use rayon::iter::{IntoParallelRefMutIterator, ParallelIterator};
use reth_primitives_traits::{Account, ParallelBridgeBuffered};
use reth_revm::state::EvmState;
use reth_trie::{
@@ -533,17 +533,18 @@ where
fn process_leaf_updates(&mut self) -> SparseTrieResult<()> {
self.pending_updates = 0;
// Start with processing all storage updates in parallel.
// Process all storage updates in parallel, skipping tries with no pending updates.
let storage_results = self
.storage_updates
.iter_mut()
.filter(|(_, updates)| !updates.is_empty())
.map(|(address, updates)| {
let trie = self.trie.take_or_create_storage_trie(address);
let fetched = self.fetched_storage_targets.remove(address).unwrap_or_default();
(address, updates, fetched, trie)
})
.par_bridge()
.par_bridge_buffered()
.map(|(address, updates, mut fetched, mut trie)| {
let mut targets = Vec::new();