From 9bd63867aaaaccf1f6252ce3c67efb26d1eb64c9 Mon Sep 17 00:00:00 2001 From: Greg Fitzgerald Date: Thu, 5 Jul 2018 15:52:19 -0600 Subject: [PATCH] No longer need to ignore downstream send errors By removing the exit variables, the downstream stages wait for upstream stages to drop their senders before exiting. --- src/banking_stage.rs | 1 - src/write_stage.rs | 1 - 2 files changed, 2 deletions(-) diff --git a/src/banking_stage.rs b/src/banking_stage.rs index 94f79d78fa..f7d39c31e7 100644 --- a/src/banking_stage.rs +++ b/src/banking_stage.rs @@ -48,7 +48,6 @@ impl BankingStage { match e { Error::RecvTimeoutError(RecvTimeoutError::Disconnected) => break, Error::RecvTimeoutError(RecvTimeoutError::Timeout) => (), - Error::SendError => (), // Ignore when downstream stage exits prematurely. _ => error!("{:?}", e), } } diff --git a/src/write_stage.rs b/src/write_stage.rs index ba48b3ccb2..241e22dbb4 100644 --- a/src/write_stage.rs +++ b/src/write_stage.rs @@ -64,7 +64,6 @@ impl WriteStage { match e { Error::RecvTimeoutError(RecvTimeoutError::Disconnected) => break, Error::RecvTimeoutError(RecvTimeoutError::Timeout) => (), - Error::SendError => (), // Ignore when downstream stage exits prematurely. _ => error!("{:?}", e), } };