remove pointless node length check

dos/src/main.rs

@@ -793,14 +793,7 @@ fn main() {
                 DEFAULT_TPU_CONNECTION_POOL_SIZE,
             ),
         };
-        let (client, num_clients) = get_client(&validators, Arc::new(connection_cache));
-        if validators.len() < num_clients {
-            eprintln!(
-                "Error: Insufficient nodes discovered.  Expecting {} or more",
-                validators.len()
-            );
-            exit(1);
-        }
+        let client = get_client(&validators, Arc::new(connection_cache));
         (gossip_nodes, Some(client))
     } else {
         (vec![], None)

gossip/Cargo.toml

@@ -41,7 +41,6 @@ solana-measure = { workspace = true }
 solana-metrics = { workspace = true }
 solana-net-utils = { workspace = true }
 solana-perf = { workspace = true }
-solana-quic-client = { workspace = true }
 solana-rayon-threadlimit = { workspace = true }
 solana-runtime = { workspace = true }
 solana-sdk = { workspace = true }

gossip/src/gossip_service.rs

@@ -197,44 +197,39 @@ pub fn discover(
     ))
 }
 
+/// Creates a TpuClient by selecting a valid node at random
 pub fn get_client(
     nodes: &[ContactInfo],
     connection_cache: Arc<ConnectionCache>,
-) -> (TpuClientWrapper, usize) {
+) -> TpuClientWrapper {
     let select = thread_rng().gen_range(0..nodes.len());
 
     let rpc_pubsub_url = format!("ws://{}/", nodes[select].rpc_pubsub().unwrap());
     let rpc_url = format!("http://{}", nodes[select].rpc().unwrap());
 
     match &*connection_cache {
-        ConnectionCache::Quic(cache) => {
-            let client = TpuClientWrapper::Quic(
-                TpuClient::new_with_connection_cache(
-                    Arc::new(RpcClient::new(rpc_url)),
-                    rpc_pubsub_url.as_str(),
-                    TpuClientConfig::default(),
-                    cache.clone(),
-                )
-                .unwrap_or_else(|err| {
-                    panic!("Could not create TpuClient with Quic Cache {err:?}");
-                }),
-            );
-            (client, nodes.len())
-        }
-        ConnectionCache::Udp(cache) => {
-            let client = TpuClientWrapper::Udp(
-                TpuClient::new_with_connection_cache(
-                    Arc::new(RpcClient::new(rpc_url)),
-                    rpc_pubsub_url.as_str(),
-                    TpuClientConfig::default(),
-                    cache.clone(),
-                )
-                .unwrap_or_else(|err| {
-                    panic!("Could not create TpuClient with Udp Cache {err:?}");
-                }),
-            );
-            (client, nodes.len())
-        }
+        ConnectionCache::Quic(cache) => TpuClientWrapper::Quic(
+            TpuClient::new_with_connection_cache(
+                Arc::new(RpcClient::new(rpc_url)),
+                rpc_pubsub_url.as_str(),
+                TpuClientConfig::default(),
+                cache.clone(),
+            )
+            .unwrap_or_else(|err| {
+                panic!("Could not create TpuClient with Quic Cache {err:?}");
+            }),
+        ),
+        ConnectionCache::Udp(cache) => TpuClientWrapper::Udp(
+            TpuClient::new_with_connection_cache(
+                Arc::new(RpcClient::new(rpc_url)),
+                rpc_pubsub_url.as_str(),
+                TpuClientConfig::default(),
+                cache.clone(),
+            )
+            .unwrap_or_else(|err| {
+                panic!("Could not create TpuClient with Udp Cache {err:?}");
+            }),
+        ),
     }
 }