From e0535c7298f7b4323e752fa1098034cd4971c911 Mon Sep 17 00:00:00 2001 From: rusefi Date: Wed, 8 Jul 2020 01:11:04 -0400 Subject: [PATCH] race conditions are cool --- .../rusefi/io/TcpCommunicationIntegrationTest.java | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/java_console/ui/src/test/java/com/rusefi/io/TcpCommunicationIntegrationTest.java b/java_console/ui/src/test/java/com/rusefi/io/TcpCommunicationIntegrationTest.java index a5ae112bba..ee0d0c4627 100644 --- a/java_console/ui/src/test/java/com/rusefi/io/TcpCommunicationIntegrationTest.java +++ b/java_console/ui/src/test/java/com/rusefi/io/TcpCommunicationIntegrationTest.java @@ -57,7 +57,10 @@ public class TcpCommunicationIntegrationTest { int value = 239; ConfigurationImage serverImage = prepareImage(value, iniField); int port = 6100; - BinaryProtocolServer server = createVirtualController(serverImage, port, null); + + CountDownLatch serverCreated = new CountDownLatch(1); + BinaryProtocolServer server = createVirtualController(serverImage, port, parameter -> serverCreated.countDown()); + assertTrue(serverCreated.await(30, TimeUnit.SECONDS)); CountDownLatch connectionEstablishedCountDownLatch = new CountDownLatch(1); @@ -94,12 +97,7 @@ public class TcpCommunicationIntegrationTest { int controllerPort = 6102; CountDownLatch serverCreated = new CountDownLatch(1); - BinaryProtocolServer server = createVirtualController(serverImage, controllerPort, new Listener() { - @Override - public void onResult(Object parameter) { - serverCreated.countDown(); - } - }); + BinaryProtocolServer server = createVirtualController(serverImage, controllerPort, parameter -> serverCreated.countDown()); assertTrue(serverCreated.await(30, TimeUnit.SECONDS)); int proxyPort = 6103;