Display a list of all discovered nodes
This commit is contained in:
parent
5d065133ef
commit
cdcf59ede0
|
@ -239,8 +239,21 @@ 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);
|
||||||
|
|
||||||
|
println!(" Node identifier | Gossip address");
|
||||||
|
println!("-----------------+--------------------");
|
||||||
|
for node in &validators {
|
||||||
|
println!("{:16x} | {}", node.debug_id(), node.contact_info.ncp);
|
||||||
|
}
|
||||||
println!("Nodes: {}", validators.len());
|
println!("Nodes: {}", validators.len());
|
||||||
assert!(validators.len() >= num_nodes);
|
|
||||||
|
if validators.len() < num_nodes {
|
||||||
|
println!(
|
||||||
|
"Error: Insufficient nodes discovered. Expecting {} or more",
|
||||||
|
num_nodes
|
||||||
|
);
|
||||||
|
exit(1);
|
||||||
|
}
|
||||||
|
|
||||||
if matches.is_present("converge_only") {
|
if matches.is_present("converge_only") {
|
||||||
return;
|
return;
|
||||||
|
|
Loading…
Reference in New Issue