perf(l1): parallelize header download with state download during snap sync

CHANGELOG.md

@@ -2,11 +2,16 @@
 
 ## Perf
 
+
 ### 2026-02-06
 
 - Defer KZG blob proof verification from P2P to mempool insertion [#6150](https://github.com/lambdaclass/ethrex/pull/6150)
 - Cache ECDSA sender recovery in transaction structs [#6153](https://github.com/lambdaclass/ethrex/pull/6153)
 
+### 2026-01-30
+
+- Parallelize header download with state download during snap sync [#6059](https://github.com/lambdaclass/ethrex/pull/6059)
+
 ### 2026-01-27
 
 - Optimize prewarmer by grouping transactions by sender [#6047](https://github.com/lambdaclass/ethrex/pull/6047)

crates/networking/p2p/peer_handler.rs

@@ -487,27 +487,31 @@ impl PeerHandler {
             id: request_id,
             block_hashes: block_hashes.to_vec(),
         });
+
         match self.get_random_peer(&SUPPORTED_ETH_CAPABILITIES).await? {
             None => Ok(None),
             Some((peer_id, mut connection)) => {
-                if let Ok(RLPxMessage::BlockBodies(BlockBodies {
-                    id: _,
-                    block_bodies,
-                })) = PeerHandler::make_request(
+                let response = PeerHandler::make_request(
                     &mut self.peer_table,
                     peer_id,
                     &mut connection,
                     request,
                     PEER_REPLY_TIMEOUT,
                 )
-                .await
+                .await;
+
+                if let Ok(RLPxMessage::BlockBodies(BlockBodies {
+                    id: _,
+                    block_bodies,
+                })) = response
                 {
                     // Check that the response is not empty and does not contain more bodies than the ones requested
                     if !block_bodies.is_empty() && block_bodies.len() <= block_hashes_len {
                         self.peer_table.record_success(&peer_id).await?;
                         return Ok(Some((block_bodies, peer_id)));
                     }
                 }
+
                 warn!(
                     "[SYNCING] Didn't receive block bodies from peer, penalizing peer {peer_id}..."
                 );