diff --git a/src/tpu.rs b/src/tpu.rs index 8ce230aa9..4136e2d65 100644 --- a/src/tpu.rs +++ b/src/tpu.rs @@ -80,13 +80,8 @@ impl Tpu { None => RecordStage::new(signal_receiver, &bank.last_id()), }; - let (write_stage, blob_receiver) = WriteStage::new( - bank.clone(), - exit.clone(), - blob_recycler.clone(), - writer, - entry_receiver, - ); + let (write_stage, blob_receiver) = + WriteStage::new(bank.clone(), blob_recycler.clone(), writer, entry_receiver); let tpu = Tpu { fetch_stage, diff --git a/src/write_stage.rs b/src/write_stage.rs index eba6e9e53..a892e4b0a 100644 --- a/src/write_stage.rs +++ b/src/write_stage.rs @@ -11,7 +11,6 @@ use result::{Error, Result}; use service::Service; use std::collections::VecDeque; use std::io::Write; -use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::mpsc::{channel, Receiver, RecvTimeoutError}; use std::sync::Arc; use std::thread::{self, Builder, JoinHandle}; @@ -46,7 +45,6 @@ impl WriteStage { /// Create a new WriteStage for writing and broadcasting entries. pub fn new( bank: Arc, - exit: Arc, blob_recycler: BlobRecycler, writer: W, entry_receiver: Receiver>, @@ -65,15 +63,10 @@ impl WriteStage { ) { match e { Error::RecvTimeoutError(RecvTimeoutError::Disconnected) => break, - Error::SendError => break, + Error::SendError => (), // Ignore when downstream stage exists prematurely. _ => error!("{:?}", e), } }; - - if exit.load(Ordering::Relaxed) { - info!("broadcat_service exiting"); - break; - } } }) .unwrap();