chore: dont gossip to disconnected nodes if there are no connected no…

…des available
ethereum · Nov 27, 2023 · 1047c77 · 1047c77
1 parent e09953b
commit 1047c77
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 36 deletions.
diff --git a/portalnet/src/gossip.rs b/portalnet/src/gossip.rs
@@ -52,18 +52,6 @@ pub fn propagate_gossip_cross_thread<TContentKey: OverlayContentKey>(
         })
         .collect();
 
-    if all_nodes.is_empty() {
-        warn!("No connected nodes, using disconnected nodes for gossip.");
-        all_nodes = kbuckets
-            .buckets_iter()
-            .flat_map(|kbucket| {
-                kbucket
-                    .iter()
-                    .collect::<Vec<&kbucket::Node<NodeId, Node>>>()
-            })
-            .collect();
-    }
-
     if all_nodes.is_empty() {
         // If there are no nodes whatsoever in the routing table the gossip cannot proceed.
         warn!("No nodes in routing table, gossip cannot proceed.");
@@ -142,18 +130,6 @@ pub async fn trace_propagate_gossip_cross_thread<TContentKey: OverlayContentKey>
             })
             .collect();
 
-        if all_nodes.is_empty() {
-            warn!("No connected nodes, using disconnected nodes for gossip.");
-            all_nodes = kbuckets
-                .buckets_iter()
-                .flat_map(|kbucket| {
-                    kbucket
-                        .iter()
-                        .collect::<Vec<&kbucket::Node<NodeId, Node>>>()
-                })
-                .collect();
-        }
-
         if all_nodes.is_empty() {
             // If there are no nodes whatsoever in the routing table the gossip cannot proceed.
             warn!("No nodes in routing table, gossip cannot proceed.");

diff --git a/portalnet/src/overlay_service.rs b/portalnet/src/overlay_service.rs
@@ -2528,18 +2528,6 @@ where
         };
 
         let mut closest_enrs = self.closest_connected_nodes(&target_key, query_config.num_results);
-        if closest_enrs.is_empty() {
-            // If there are no connected nodes, use the closest nodes regardless of connectivity.
-            warn!("No connected nodes, using disconnected nodes for query.");
-            closest_enrs = self
-                .kbuckets
-                .write()
-                .closest_values(&target_key)
-                .map(|closest| closest.value.enr)
-                .take(query_config.num_results)
-                .collect();
-        }
-
         if closest_enrs.is_empty() {
             // If there are no nodes whatsoever in the routing table the query cannot proceed.
             warn!("No nodes in routing table, query cannot proceed.");