bubble up Outbound Err's and Responses even if the peer disconnected

sigp · Sep 18, 2024 · 5fa8c80 · 5fa8c80
1 parent 14789bd
commit 5fa8c80
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/beacon_node/lighthouse_network/src/service/mod.rs b/beacon_node/lighthouse_network/src/service/mod.rs
@@ -1399,7 +1399,10 @@ impl<E: EthSpec> Network<E> {
         let peer_id = event.peer_id;
 
         // Do not permit Inbound events from peers that are being disconnected, or RPC requests.
-        if !self.peer_manager().is_connected(&peer_id) {
+        if !self.peer_manager().is_connected(&peer_id)
+            && (matches!(event.message, Err(HandlerErr::Inbound { .. }))
+                || matches!(event.message, Ok(RPCReceived::Request(..))))
+        {
             debug!(
                 self.log,
                 "Ignoring rpc message of disconnecting peer";