From f27613754aec124315c081929c422311eae4a2e4 Mon Sep 17 00:00:00 2001 From: Michael Vines Date: Mon, 30 Jul 2018 10:55:05 -0700 Subject: [PATCH] Report number of nodes found on failure too --- src/bin/bench-tps.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/bin/bench-tps.rs b/src/bin/bench-tps.rs index 1a4b90ce92..708cc79238 100644 --- a/src/bin/bench-tps.rs +++ b/src/bin/bench-tps.rs @@ -656,10 +656,10 @@ fn converge( gossip_send_socket, exit_signal.clone(), ).expect("DataReplicator::new"); - let mut rv = vec![]; + let mut v: Vec = vec![]; //wait for the network to converge, 30 seconds should be plenty for _ in 0..30 { - let v: Vec = spy_ref + v = spy_ref .read() .unwrap() .table @@ -670,7 +670,6 @@ fn converge( .collect(); if v.len() >= num_nodes { println!("CONVERGED!"); - rv.extend(v.into_iter()); break; } else { println!( @@ -682,7 +681,7 @@ fn converge( sleep(Duration::new(1, 0)); } threads.extend(ncp.thread_hdls().into_iter()); - rv + v } fn read_leader(path: &str) -> Config {