From 5108350710b42f8bc2950395a067dc1d15213ba4 Mon Sep 17 00:00:00 2001 From: Brennan Date: Mon, 13 Feb 2023 12:05:42 -0800 Subject: [PATCH] Remove dead code (#30263) * Remove dead code * Get RPC Peers return vector --- validator/src/bootstrap.rs | 28 +++++++++++----------------- 1 file changed, 11 insertions(+), 17 deletions(-) diff --git a/validator/src/bootstrap.rs b/validator/src/bootstrap.rs index 82afeb75c5..d5ef543760 100644 --- a/validator/src/bootstrap.rs +++ b/validator/src/bootstrap.rs @@ -180,7 +180,7 @@ fn get_rpc_peers( blacklist_timeout: &Instant, retry_reason: &mut Option, bootstrap_config: &RpcBootstrapConfig, -) -> Option> { +) -> Vec { let shred_version = validator_config .expected_shred_version .unwrap_or_else(|| cluster_info.my_shred_version()); @@ -196,7 +196,7 @@ fn get_rpc_peers( exit(1); } info!("Waiting to adopt entrypoint shred version..."); - return None; + return vec![]; } info!( @@ -249,10 +249,9 @@ fn get_rpc_peers( } else { Some("Wait for known rpc peers".to_owned()) }; - return None; + return vec![]; } - - Some(rpc_peers) + rpc_peers } fn check_vote_account( @@ -645,22 +644,17 @@ fn get_rpc_nodes( &mut retry_reason, bootstrap_config, ); - if rpc_peers.is_none() { + if rpc_peers.is_empty() { continue; } - let rpc_peers = rpc_peers.unwrap(); + blacklist_timeout = Instant::now(); if bootstrap_config.no_snapshot_fetch { - if rpc_peers.is_empty() { - retry_reason = Some("No RPC peers available.".to_owned()); - continue; - } else { - let random_peer = &rpc_peers[thread_rng().gen_range(0, rpc_peers.len())]; - return vec![GetRpcNodeResult { - rpc_contact_info: random_peer.clone(), - snapshot_hash: None, - }]; - } + let random_peer = &rpc_peers[thread_rng().gen_range(0, rpc_peers.len())]; + return vec![GetRpcNodeResult { + rpc_contact_info: random_peer.clone(), + snapshot_hash: None, + }]; } let known_validators_to_wait_for = if newer_cluster_snapshot_timeout