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

refactor: naming fix for multiproof dispatch (#19102)

Browse Source
This commit is contained in:
YK
2025-10-17 23:46:17 +08:00
committed by GitHub
parent 1b830e9ed1
commit d1f6637a5a
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/trie/parallel/src/proof.rs
View File

@@ -101,7 +101,7 @@ impl ParallelProof {
);
self.proof_worker_handle
.queue_storage_proof(input)
.dispatch_storage_proof(input)
.map_err(|e| ParallelStateRootError::Other(e.to_string()))
}

16
crates/trie/parallel/src/proof_task.rs
View File

@@ -958,8 +958,8 @@ impl ProofWorkerHandle {
Self { storage_work_tx, account_work_tx }
}
/// Queue a storage proof computation
pub fn queue_storage_proof(
/// Dispatch a storage proof computation to storage worker pool
pub fn dispatch_storage_proof(
&self,
input: StorageProofInput,
) -> Result<Receiver<StorageProofResult>, ProviderError> {
@@ -988,8 +988,8 @@ impl ProofWorkerHandle {
Ok(rx)
}
/// Internal: Queue blinded storage node request
fn queue_blinded_storage_node(
/// Dispatch blinded storage node request to storage worker pool
pub(crate) fn dispatch_blinded_storage_node(
&self,
account: B256,
path: Nibbles,
@@ -1004,8 +1004,8 @@ impl ProofWorkerHandle {
Ok(rx)
}
/// Internal: Queue blinded account node request
fn queue_blinded_account_node(
/// Dispatch blinded account node request to account worker pool
pub(crate) fn dispatch_blinded_account_node(
&self,
path: Nibbles,
) -> Result<Receiver<TrieNodeProviderResult>, ProviderError> {
@@ -1055,13 +1055,13 @@ impl TrieNodeProvider for ProofTaskTrieNodeProvider {
match self {
Self::AccountNode { handle } => {
let rx = handle
.queue_blinded_account_node(*path)
.dispatch_blinded_account_node(*path)
.map_err(|error| SparseTrieErrorKind::Other(Box::new(error)))?;
rx.recv().map_err(|error| SparseTrieErrorKind::Other(Box::new(error)))?
}
Self::StorageNode { handle, account } => {
let rx = handle
.queue_blinded_storage_node(*account, *path)
.dispatch_blinded_storage_node(*account, *path)
.map_err(|error| SparseTrieErrorKind::Other(Box::new(error)))?;
rx.recv().map_err(|error| SparseTrieErrorKind::Other(Box::new(error)))?
}