From 3306179d916acefa980be2a4606ff428136ab9dd Mon Sep 17 00:00:00 2001 From: Yong Kang Date: Fri, 17 Oct 2025 02:43:24 +0000 Subject: [PATCH 1/3] refactor: naming fix --- crates/trie/parallel/src/proof_task.rs | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/crates/trie/parallel/src/proof_task.rs b/crates/trie/parallel/src/proof_task.rs index 5c26f6d99c3..619387d8143 100644 --- a/crates/trie/parallel/src/proof_task.rs +++ b/crates/trie/parallel/src/proof_task.rs @@ -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, ProviderError> { @@ -988,8 +988,8 @@ impl ProofWorkerHandle { Ok(rx) } - /// Internal: Queue blinded storage node request - fn queue_blinded_storage_node( + /// Internal: Dispatch blinded storage node request to storage worker pool + 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( + /// Internal: Dispatch blinded account node request to account worker pool + fn dispatch_blinded_account_node( &self, path: Nibbles, ) -> Result, 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)))? } From 4ba880ff686d610033361c4e898febc31d020097 Mon Sep 17 00:00:00 2001 From: Yong Kang Date: Fri, 17 Oct 2025 02:48:10 +0000 Subject: [PATCH 2/3] compile --- crates/trie/parallel/src/proof.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crates/trie/parallel/src/proof.rs b/crates/trie/parallel/src/proof.rs index ffa7aa4dc31..3ea5994488a 100644 --- a/crates/trie/parallel/src/proof.rs +++ b/crates/trie/parallel/src/proof.rs @@ -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())) } From 77e1a17996074f5001ca6652aca1d092b1ecaab9 Mon Sep 17 00:00:00 2001 From: Yong Kang Date: Fri, 17 Oct 2025 02:48:26 +0000 Subject: [PATCH 3/3] refactor(trie): make dispatch functions public and update documentation --- crates/trie/parallel/src/proof_task.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/crates/trie/parallel/src/proof_task.rs b/crates/trie/parallel/src/proof_task.rs index 619387d8143..b66b7bbaa4f 100644 --- a/crates/trie/parallel/src/proof_task.rs +++ b/crates/trie/parallel/src/proof_task.rs @@ -988,8 +988,8 @@ impl ProofWorkerHandle { Ok(rx) } - /// Internal: Dispatch blinded storage node request to storage worker pool - fn dispatch_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: Dispatch blinded account node request to account worker pool - fn dispatch_blinded_account_node( + /// Dispatch blinded account node request to account worker pool + pub(crate) fn dispatch_blinded_account_node( &self, path: Nibbles, ) -> Result, ProviderError> {