From 5c3ceb8355796d299c324f321ae09764d25a65d2 Mon Sep 17 00:00:00 2001 From: Anatoly Yakovenko Date: Wed, 23 May 2018 22:04:19 +0000 Subject: [PATCH] aws demo2 --- src/bin/multinode-demo.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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()