From 30b60a976b6ccd155aedea179879255a1b8f77e8 Mon Sep 17 00:00:00 2001 From: Michael Vines Date: Mon, 24 May 2021 08:28:44 -0700 Subject: [PATCH] Avoid ip_echo_server unwrap --- core/src/validator.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/core/src/validator.rs b/core/src/validator.rs index 2efe88e061..5f7f3c1c1e 100644 --- a/core/src/validator.rs +++ b/core/src/validator.rs @@ -278,7 +278,7 @@ pub struct Validator { poh_service: PohService, tpu: Tpu, tvu: Tvu, - ip_echo_server: solana_net_utils::IpEchoServer, + ip_echo_server: Option, } // in the distant future, get rid of ::new()/exit() and use Result properly... @@ -593,7 +593,7 @@ impl Validator { std::thread::park(); } - let ip_echo_server = solana_net_utils::ip_echo_server(node.sockets.ip_echo.unwrap()); + let ip_echo_server = node.sockets.ip_echo.map(solana_net_utils::ip_echo_server); let gossip_service = GossipService::new( &cluster_info, @@ -890,7 +890,9 @@ impl Validator { self.completed_data_sets_service .join() .expect("completed_data_sets_service"); - self.ip_echo_server.shutdown_background(); + if let Some(ip_echo_server) = self.ip_echo_server { + ip_echo_server.shutdown_background(); + } } }