Close down banking stage in banking_bench (#6401)
Maybe fixes pthread crash?
This commit is contained in:
parent
ccb4e32ee0
commit
8740bb42c0
|
@ -158,7 +158,7 @@ fn main() {
|
||||||
create_test_recorder(&bank, &blocktree, None);
|
create_test_recorder(&bank, &blocktree, None);
|
||||||
let cluster_info = ClusterInfo::new_with_invalid_keypair(Node::new_localhost().info);
|
let cluster_info = ClusterInfo::new_with_invalid_keypair(Node::new_localhost().info);
|
||||||
let cluster_info = Arc::new(RwLock::new(cluster_info));
|
let cluster_info = Arc::new(RwLock::new(cluster_info));
|
||||||
let _banking_stage = BankingStage::new(
|
let banking_stage = BankingStage::new(
|
||||||
&cluster_info,
|
&cluster_info,
|
||||||
&poh_recorder,
|
&poh_recorder,
|
||||||
verified_receiver,
|
verified_receiver,
|
||||||
|
@ -309,8 +309,11 @@ fn main() {
|
||||||
tx_total / ITERS as u64,
|
tx_total / ITERS as u64,
|
||||||
);
|
);
|
||||||
|
|
||||||
|
drop(verified_sender);
|
||||||
drop(vote_sender);
|
drop(vote_sender);
|
||||||
exit.store(true, Ordering::Relaxed);
|
exit.store(true, Ordering::Relaxed);
|
||||||
|
banking_stage.join().unwrap();
|
||||||
|
debug!("waited for banking_stage");
|
||||||
poh_service.join().unwrap();
|
poh_service.join().unwrap();
|
||||||
sleep(Duration::from_secs(1));
|
sleep(Duration::from_secs(1));
|
||||||
debug!("waited for poh_service");
|
debug!("waited for poh_service");
|
||||||
|
|
Loading…
Reference in New Issue