From 6a8a97f644cc063f2fb5aa293a1e6e4716a7c19c Mon Sep 17 00:00:00 2001 From: Michael Vines Date: Mon, 4 Mar 2019 19:46:24 -0800 Subject: [PATCH] Remove dead code --- core/src/broadcast_stage.rs | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/core/src/broadcast_stage.rs b/core/src/broadcast_stage.rs index 404237aafa..50331c88fb 100644 --- a/core/src/broadcast_stage.rs +++ b/core/src/broadcast_stage.rs @@ -24,9 +24,7 @@ use std::time::{Duration, Instant}; #[derive(Debug, PartialEq, Eq, Clone)] pub enum BroadcastStageReturnType { - LeaderRotation, ChannelDisconnected, - ExitSignal, } struct Broadcast { @@ -179,7 +177,6 @@ impl BroadcastStage { sock: &UdpSocket, cluster_info: &Arc>, receiver: &Receiver, - exit_signal: &Arc, blocktree: &Arc, ) -> BroadcastStageReturnType { let me = cluster_info.read().unwrap().my_data().clone(); @@ -191,9 +188,6 @@ impl BroadcastStage { }; loop { - if exit_signal.load(Ordering::Relaxed) { - return BroadcastStageReturnType::ExitSignal; - } if let Err(e) = broadcast.run(&cluster_info, receiver, sock, blocktree) { match e { Error::RecvTimeoutError(RecvTimeoutError::Disconnected) | Error::SendError => { @@ -233,13 +227,12 @@ impl BroadcastStage { exit_sender: Arc, blocktree: &Arc, ) -> Self { - let exit_signal = Arc::new(AtomicBool::new(false)); let blocktree = blocktree.clone(); let thread_hdl = Builder::new() .name("solana-broadcaster".to_string()) .spawn(move || { let _exit = Finalizer::new(exit_sender); - Self::run(&sock, &cluster_info, &receiver, &exit_signal, &blocktree) + Self::run(&sock, &cluster_info, &receiver, &blocktree) }) .unwrap();