From c64a9fb456c3bb44994c2d6671b0604d8e87dc79 Mon Sep 17 00:00:00 2001 From: Greg Fitzgerald Date: Mon, 26 Mar 2018 22:02:05 -0600 Subject: [PATCH] Give Travis a little more time to start threads --- src/accountant_stub.rs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/accountant_stub.rs b/src/accountant_stub.rs index 4498eb52f..8debbeafd 100644 --- a/src/accountant_stub.rs +++ b/src/accountant_stub.rs @@ -140,15 +140,15 @@ mod tests { let exit = Arc::new(AtomicBool::new(false)); let acc = Arc::new(Mutex::new(AccountantSkel::new(acc, sink()))); let threads = AccountantSkel::serve(acc, addr, exit.clone()).unwrap(); - sleep(Duration::from_millis(30)); + sleep(Duration::from_millis(300)); let socket = UdpSocket::bind(send_addr).unwrap(); let mut acc = AccountantStub::new(addr, socket); - //let last_id = acc.get_last_id().unwrap(); - //let sig = acc.transfer(500, &alice.keypair(), bob_pubkey, &last_id) - // .unwrap(); - //acc.wait_on_signature(&sig, &last_id).unwrap(); - //assert_eq!(acc.get_balance(&bob_pubkey).unwrap().unwrap(), 500); + let last_id = acc.get_last_id().unwrap(); + let sig = acc.transfer(500, &alice.keypair(), bob_pubkey, &last_id) + .unwrap(); + acc.wait_on_signature(&sig, &last_id).unwrap(); + assert_eq!(acc.get_balance(&bob_pubkey).unwrap().unwrap(), 500); exit.store(true, Ordering::Relaxed); for t in threads { t.join().expect("join");