wip: in_place_scope

romanz · Nov 21, 2023 · 7e693de · 7e693de
1 parent 67a3a0f
commit 7e693de
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/p2p.rs b/src/p2p.rs
@@ -111,7 +111,7 @@ impl Connection {
                 self.req_send.send(Request::get_blocks(&blockhashes))
             })?;
 
-            rayon::scope(|s| {
+            rayon::in_place_scope(|s| {
                 let (send, receive) = std::sync::mpsc::channel();
 
                 for hash in blockhashes {
@@ -142,6 +142,7 @@ impl Connection {
                 debug!("waiting for {} blocks", blockhashes_len);
                 let result: Result<Vec<_>, std::sync::mpsc::RecvError> =
                     (0..blockhashes_len).map(|_| receive.recv()).collect();
+                debug!("waited for {} blocks", blockhashes_len);
 
                 match result {
                     Ok(result) => {