fix 🐛: Fix for BlocksByRange timeout (increased timeout, source still…

… needs to be determined) ISSUE: #48
AnduroProject · Nov 27, 2024 · b85001a · b85001a
1 parent 84324f9
commit b85001a
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 6 deletions.
diff --git a/app/src/network/mod.rs b/app/src/network/mod.rs
@@ -283,6 +283,9 @@ impl NetworkBackend {
                         info!("Responding to rpc...");
                         self.swarm.behaviour_mut().eth2_rpc.send_response(peer_id, (connection_id, substream_id), payload);
                     }
+                    Some(_) => {
+                        debug!("Unhandled message");
+                    }
                     None => {
                         // channel shut down, nothing to do
                     }
@@ -293,7 +296,7 @@ impl NetworkBackend {
                         message_id: id,
                         message,
                     })) => {
-                        tracing::debug!(
+                        debug!(
                             "Got message: '{}' with id: {id} from peer: {peer_id}",
                             String::from_utf8_lossy(&message.data),
                         );
@@ -345,10 +348,12 @@ impl NetworkBackend {
                             Ok(RPCReceived::EndOfStream(request_id, _)) => {
                                 rpc_response_channels.remove(request_id);
                             }
-                            Err(HandlerErr::Inbound { id: _, proto: _, error: _ }) => {
+                            Err(HandlerErr::Inbound { id: err_stream_id, proto: _, error: stream_error }) => {
                                 // not sure what to do with this, ignore for now
+                                warn!("Inbound error: {:?}", stream_error);
                             }
-                            Err(HandlerErr::Outbound { id: _, proto: _, error: _ }) => {
+                            Err(HandlerErr::Outbound { id: stream_id, proto: _, error: stream_err }) => {
+                                warn!("Outbound error: {:?}", stream_err);
                             }
                         }
 
@@ -450,8 +455,8 @@ fn create_swarm() -> Result<Swarm<MyBehaviour>, Error> {
 
             let network_params = NetworkParams {
                 max_chunk_size: 1024 * 1024_usize,
-                ttfb_timeout: Duration::from_secs(15),
-                resp_timeout: Duration::from_secs(15),
+                ttfb_timeout: Duration::from_secs(180),
+                resp_timeout: Duration::from_secs(180),
             };
 
             let drain = slog::Discard;

diff --git a/app/src/network/rpc/mod.rs b/app/src/network/rpc/mod.rs
@@ -190,6 +190,7 @@ impl<Id: ReqId, TSpec: EthSpec> RPC<Id, TSpec> {
             }
         };
 
+        tracing::debug!("Pushing RPC request to swarm request_id: {:?}, request_id: {:?}", request_id, peer_id);
         self.events.push(event);
     }
 

diff --git a/etc/config/chain.json b/etc/config/chain.json
@@ -38,5 +38,5 @@
         "powTargetTimespan": 12000,
         "powTargetSpacing": 1000
     },
-    "isValidator": true
+    "isValidator": false
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -190,6 +190,7 @@ impl<Id: ReqId, TSpec: EthSpec> RPC<Id, TSpec> { @@
                 }
             };
+            tracing::debug!("Pushing RPC request to swarm request_id: {:?}, request_id: {:?}", request_id, peer_id);
             self.events.push(event);
         }
@@ Expand Down @@