Permit more than the requested amount of nodes

This commit is contained in:
Michael Vines
2018-07-18 04:29:51 +00:00
parent 6ff46540b6
commit 39df087902

View File

@ -225,7 +225,8 @@ fn main() {
let signal = Arc::new(AtomicBool::new(false)); let signal = Arc::new(AtomicBool::new(false));
let mut c_threads = vec![]; let mut c_threads = vec![];
let validators = converge(&leader, &signal, num_nodes, &mut c_threads); let validators = converge(&leader, &signal, num_nodes, &mut c_threads);
assert_eq!(validators.len(), num_nodes); println!("Network has {} node(s)", validators.len());
assert!(validators.len() >= num_nodes);
let mut client = mk_client(&leader); let mut client = mk_client(&leader);
@ -417,6 +418,12 @@ fn converge(
println!("CONVERGED!"); println!("CONVERGED!");
rv.extend(v.into_iter()); rv.extend(v.into_iter());
break; break;
} else {
println!(
"{} node(s) discovered (looking for {} or more)",
v.len(),
num_nodes
);
} }
sleep(Duration::new(1, 0)); sleep(Duration::new(1, 0));
} }