Don't panic again when waiting for a panicked validator thread
This commit is contained in:
parent
4cdb9a73f8
commit
af1a2e83bc
|
@ -563,13 +563,20 @@ fn main() {
|
||||||
|
|
||||||
// Stop the sampling threads so it will collect the stats
|
// Stop the sampling threads so it will collect the stats
|
||||||
exit_signal.store(true, Ordering::Relaxed);
|
exit_signal.store(true, Ordering::Relaxed);
|
||||||
|
|
||||||
|
println!("Waiting for validator threads...");
|
||||||
for t in v_threads {
|
for t in v_threads {
|
||||||
t.join().unwrap();
|
if let Err(err) = t.join() {
|
||||||
|
println!(" join() failed with: {:?}", err);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// join the tx send threads
|
// join the tx send threads
|
||||||
|
println!("Waiting for transmit threads...");
|
||||||
for t in s_threads {
|
for t in s_threads {
|
||||||
t.join().unwrap();
|
if let Err(err) = t.join() {
|
||||||
|
println!(" join() failed with: {:?}", err);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
let balance = client.poll_get_balance(&id.pubkey()).unwrap_or(-1);
|
let balance = client.poll_get_balance(&id.pubkey()).unwrap_or(-1);
|
||||||
|
|
Loading…
Reference in New Issue