diff --git a/src/test/connector.rs b/src/test/connector.rs index dd2a974d7d461b9da08714d7b38bd060559cdee7..b1bdff833ec5c31a09dae83c000d6a7091233482 100644 --- a/src/test/connector.rs +++ b/src/test/connector.rs @@ -15,7 +15,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 { @@ -29,9 +30,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 { @@ -44,6 +47,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()); @@ -55,7 +59,8 @@ fn duo() { 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 {} @@ -67,7 +72,9 @@ fn duo() { 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(); @@ -78,7 +85,8 @@ fn duo() { }); 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 { @@ -92,7 +100,9 @@ fn duo() { } } } - }").unwrap(); + }", + ) + .unwrap(); x.bind_port(0, PortBinding::Active(addrs[0])).unwrap(); x.bind_port(1, PortBinding::Active(addrs[1])).unwrap(); x.connect(timeout).unwrap();