diff --git a/src/bin/multinode-demo.rs b/src/bin/multinode-demo.rs index 015c878433..174c086c26 100644 --- a/src/bin/multinode-demo.rs +++ b/src/bin/multinode-demo.rs @@ -164,6 +164,7 @@ fn main() { sleep(Duration::new(1, 0)); } for val in validators { + println!("Checking balance on {} ...", val.events_addr); let mut client = mk_client(&client_addr, &val); let mut tx_count = client.transaction_count(); duration = now.elapsed(); @@ -213,6 +214,7 @@ fn converge( threads: &mut Vec>, ) -> Vec { //lets spy on the network + let daddr = "0.0.0.0:0".parse().unwrap(); let (spy, spy_gossip) = spy_node(client_addr); let me = spy.id.clone(); let mut spy_crdt = Crdt::new(spy); @@ -240,7 +242,7 @@ fn converge( .table .values() .into_iter() - .filter(|x| x.id != me) + .filter(|x| x.requests_addr != daddr) .map(|x| x.clone()) .collect(); v.clone()