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

rm comment

Browse Source
This commit is contained in:
Yong Kang
2025-10-08 12:59:29 +00:00
parent e51707a62c
commit 49410719eb
1 changed files with 0 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -711,19 +711,6 @@ where
Ok(message) => {
match message {
ProofTaskMessage::QueueTask(task) => {
// SAFETY: Storage worker sends cannot fail because:
// 1. Unbounded channel created during initialization (line 595)
// 2. Workers only exit when channel closes (storage_worker_loop recv()
// returns Err)
// 3. Channel only closes when all senders are dropped
// 4. self.storage_work_tx is only dropped on Terminate (line 861)
// 5. If we're processing QueueTask messages, Terminate hasn't occurred
// yet
// Therefore, the channel is guaranteed open with workers receiving.
//
// Same logic applies to account workers (unbounded channel at line 596,
// dropped at line 862).
match task {
ProofTaskKind::StorageProof(input, sender) => {
self.storage_work_tx