aws demo2

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<JoinHandle<()>>,
 ) -> Vec<ReplicatedData> {
     //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()