diff --git a/src/test/connector.rs b/src/test/connector.rs index 7568053d6f051a511abc2e0e9b4151a8d330d8ad..867ac039411168cffc0d17106ce7cce31c214644 100644 --- a/src/test/connector.rs +++ b/src/test/connector.rs @@ -16,7 +16,8 @@ fn incremental() { let timeout = Duration::from_millis(1_500); let addrs = ["127.0.0.1:7010".parse().unwrap(), "127.0.0.1:7011".parse().unwrap()]; let a = thread::spawn(move || { - let mut x = Connector::Unconfigured(Unconfigured { controller_id: 0 }); + let controller_id = 0; + let mut x = Connector::Unconfigured(Unconfigured { controller_id }); x.configure( b"primitive main(out a, out b) { synchronous { @@ -30,9 +31,11 @@ fn incremental() { x.bind_port(1, PortBinding::Passive(addrs[1])).unwrap(); x.connect(timeout).unwrap(); assert_eq!(0, x.sync(timeout).unwrap()); + println!("\n---------\nLOG CID={}\n{}", controller_id, x.get_mut_logger().unwrap()); }); let b = thread::spawn(move || { - let mut x = Connector::Unconfigured(Unconfigured { controller_id: 1 }); + let controller_id = 1; + let mut x = Connector::Unconfigured(Unconfigured { controller_id }); x.configure( b"primitive main(in a, in b) { synchronous { @@ -45,6 +48,7 @@ fn incremental() { x.bind_port(1, PortBinding::Active(addrs[1])).unwrap(); x.connect(timeout).unwrap(); assert_eq!(0, x.sync(timeout).unwrap()); + println!("\n---------\nLOG CID={}\n{}", controller_id, x.get_mut_logger().unwrap()); }); handle(a.join()); handle(b.join()); @@ -56,7 +60,8 @@ fn duo_positive() { let addrs = ["127.0.0.1:7012".parse().unwrap(), "127.0.0.1:7013".parse().unwrap()]; let a = thread::spawn(move || { let mut x = Connector::Unconfigured(Unconfigured { controller_id: 0 }); - x.configure(b" + x.configure( + b" primitive main(out a, out b) { synchronous {} synchronous {} @@ -68,7 +73,9 @@ fn duo_positive() { msg m = create(0); put(b, m); } - }").unwrap(); + }", + ) + .unwrap(); x.bind_port(0, PortBinding::Passive(addrs[0])).unwrap(); x.bind_port(1, PortBinding::Passive(addrs[1])).unwrap(); x.connect(timeout).unwrap(); @@ -79,7 +86,8 @@ fn duo_positive() { }); let b = thread::spawn(move || { let mut x = Connector::Unconfigured(Unconfigured { controller_id: 1 }); - x.configure(b" + x.configure( + b" primitive main(in a, in b) { while (true) { synchronous { @@ -93,7 +101,9 @@ fn duo_positive() { } } } - }").unwrap(); + }", + ) + .unwrap(); x.bind_port(0, PortBinding::Active(addrs[0])).unwrap(); x.bind_port(1, PortBinding::Active(addrs[1])).unwrap(); x.connect(timeout).unwrap();