From 3d45b04da8504c6abc50e4717532f15095a1db13 Mon Sep 17 00:00:00 2001 From: Anatoly Yakovenko Date: Tue, 17 Jul 2018 11:45:52 -0700 Subject: [PATCH] review comments --- src/fullnode.rs | 9 +++++---- tests/multinode.rs | 5 +++-- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/src/fullnode.rs b/src/fullnode.rs index 62ffee8232..f4ee21e5bd 100644 --- a/src/fullnode.rs +++ b/src/fullnode.rs @@ -347,6 +347,7 @@ mod tests { use crdt::TestNode; use fullnode::FullNode; use mint::Mint; + use service::Service; use signature::{KeyPair, KeyPairUtil}; use std::sync::atomic::AtomicBool; use std::sync::Arc; @@ -360,7 +361,7 @@ mod tests { let entry = tn.data.clone(); let v = FullNode::new_validator(kp, bank, 0, None, tn, &entry, exit); v.exit(); - v.close().unwrap(); + v.join().unwrap(); } #[test] fn validator_parallel_exit() { @@ -375,10 +376,10 @@ mod tests { FullNode::new_validator(kp, bank, 0, None, tn, &entry, exit) }) .collect(); - //each validator can exit in parallel to speed many sequential calls to `close` + //each validator can exit in parallel to speed many sequential calls to `join` vals.iter().for_each(|v| v.exit()); - //while close is called sequentially, the above exit call notified all the + //while join is called sequentially, the above exit call notified all the //validators to exit from all their threads - vals.into_iter().for_each(|v| v.close().unwrap()); + vals.into_iter().for_each(|v| v.join().unwrap()); } } diff --git a/tests/multinode.rs b/tests/multinode.rs index 6f303b7173..9b2886d48f 100644 --- a/tests/multinode.rs +++ b/tests/multinode.rs @@ -11,6 +11,7 @@ use solana::fullnode::{FullNode, LedgerFile}; use solana::logger; use solana::mint::Mint; use solana::ncp::Ncp; +use solana::service::Service; use solana::signature::{KeyPair, KeyPairUtil, PublicKey}; use solana::streamer::default_window; use solana::thin_client::ThinClient; @@ -469,9 +470,9 @@ fn test_multi_node_dynamic_network() { } server.exit(); for (_, node) in validators { - node.close().unwrap(); + node.join().unwrap(); } - server.close().unwrap(); + server.join().unwrap(); std::fs::remove_file(ledger_path).unwrap(); }