From 8740bb42c043877ac1930eb53fc2bcd17a44dbe2 Mon Sep 17 00:00:00 2001 From: sakridge Date: Wed, 16 Oct 2019 14:45:05 -0700 Subject: [PATCH] Close down banking stage in banking_bench (#6401) Maybe fixes pthread crash? --- banking_bench/src/main.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/banking_bench/src/main.rs b/banking_bench/src/main.rs index 82d38f8ea8..c53d5f2124 100644 --- a/banking_bench/src/main.rs +++ b/banking_bench/src/main.rs @@ -158,7 +158,7 @@ fn main() { create_test_recorder(&bank, &blocktree, None); let cluster_info = ClusterInfo::new_with_invalid_keypair(Node::new_localhost().info); let cluster_info = Arc::new(RwLock::new(cluster_info)); - let _banking_stage = BankingStage::new( + let banking_stage = BankingStage::new( &cluster_info, &poh_recorder, verified_receiver, @@ -309,8 +309,11 @@ fn main() { tx_total / ITERS as u64, ); + drop(verified_sender); drop(vote_sender); exit.store(true, Ordering::Relaxed); + banking_stage.join().unwrap(); + debug!("waited for banking_stage"); poh_service.join().unwrap(); sleep(Duration::from_secs(1)); debug!("waited for poh_service");