feat(l1): parallel state sync + rebuild state trie in background

cmd/ethrex/ethrex.rs

@@ -235,8 +235,10 @@ async fn main() {
         .expect("Node record could not be created from local node");
     // Create Kademlia Table here so we can access it from rpc server (for syncing)
     let peer_table = peer_table(signer.clone());
+    // Create a cancellation_token for long_living tasks
+    let cancel_token = tokio_util::sync::CancellationToken::new();
     // Create SyncManager
-    let syncer = SyncManager::new(peer_table.clone(), sync_mode);
+    let syncer = SyncManager::new(peer_table.clone(), sync_mode, cancel_token.clone());
 
     // TODO: Check every module starts properly.
     let tracker = TaskTracker::new();
@@ -304,6 +306,7 @@ async fn main() {
         _ = tokio::signal::ctrl_c() => {
             info!("Server shut down started...");
             info!("Storing known peers at {:?}...", peers_file);
+            cancel_token.cancel();
             store_known_peers(peer_table, peers_file).await;
             tokio::time::sleep(Duration::from_secs(1)).await;
             info!("Server shutting down!");

crates/networking/p2p/peer_handler.rs

@@ -207,14 +207,15 @@ impl PeerHandler {
         &self,
         state_root: H256,
         start: H256,
+        limit: H256,
     ) -> Option<(Vec<H256>, Vec<AccountState>, bool)> {
         for _ in 0..REQUEST_RETRY_ATTEMPTS {
             let request_id = rand::random();
             let request = RLPxMessage::GetAccountRange(GetAccountRange {
                 id: request_id,
                 root_hash: state_root,
                 starting_hash: start,
-                limit_hash: HASH_MAX,
+                limit_hash: limit,
                 response_bytes: MAX_RESPONSE_BYTES,
             });
             let peer = self.get_peer_channel_with_retry(Capability::Snap).await?;

crates/networking/p2p/rlpx/utils.rs

@@ -71,10 +71,10 @@ pub(crate) fn log_peer_debug(node: &Node, text: &str) {
 }
 
 pub(crate) fn log_peer_error(node: &Node, text: &str) {
-    error!("[{0}]: {1}", node, text)
+    //error!("[{0}]: {1}", node, text)
 }
 pub(crate) fn log_peer_warn(node: &Node, text: &str) {
-    warn!("[{0}]: {1}", node, text)
+    //warn!("[{0}]: {1}", node, text)
 }
 
 #[cfg(test)]