add checking whether finish or not

starcoinorg · Aug 31, 2024 · 37051a4 · 37051a4
1 parent 1ae1eba
commit 37051a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sync/src/parallel/sender.rs b/sync/src/parallel/sender.rs
@@ -153,7 +153,7 @@ impl DagBlockSender {
 
         self.executors.retain(|worker| {
             if let ExecuteState::Closed = worker.state {
-                worker.handle.is_finished()
+                !worker.handle.is_finished()
             } else {
                 true
             }