diff --git a/java_console/io/src/main/java/com/rusefi/proxy/client/LocalApplicationProxy.java b/java_console/io/src/main/java/com/rusefi/proxy/client/LocalApplicationProxy.java index 6cc09abb09..4275020081 100644 --- a/java_console/io/src/main/java/com/rusefi/proxy/client/LocalApplicationProxy.java +++ b/java_console/io/src/main/java/com/rusefi/proxy/client/LocalApplicationProxy.java @@ -33,6 +33,7 @@ import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicLong; import static com.devexperts.logging.Logging.getLogging; +import static com.rusefi.Timeouts.BINARY_IO_TIMEOUT; import static com.rusefi.Timeouts.SECOND; import static com.rusefi.binaryprotocol.BinaryProtocol.sleep; @@ -111,7 +112,7 @@ public class LocalApplicationProxy implements Closeable { try { while (true) { sleep(context.gaugePokingPeriod()); - if (isTimeForApplicationToConnect(lastActivity.get(), SECOND * 5)) { + if (isTimeForApplicationToConnect(lastActivity.get(), BINARY_IO_TIMEOUT / 2)) { byte[] commandPacket = GetOutputsCommand.createRequest(); // we do not really need the data, we just need to take response from the socket authenticatorToProxyStream.sendAndGetPacket(commandPacket, "Gauge Poker", false); diff --git a/java_console/io/src/test/java/com/rusefi/TestHelper.java b/java_console/io/src/test/java/com/rusefi/TestHelper.java index 3b65c18833..a272ea9a95 100644 --- a/java_console/io/src/test/java/com/rusefi/TestHelper.java +++ b/java_console/io/src/test/java/com/rusefi/TestHelper.java @@ -105,6 +105,7 @@ public class TestHelper { public static void assertLatch(String message, CountDownLatch reconnectCounter) throws InterruptedException { assertTrue(message, reconnectCounter.await(READ_IMAGE_TIMEOUT, TimeUnit.MILLISECONDS)); + System.out.println(message + " is good"); } public static void assertLatch(CountDownLatch reconnectCounter) throws InterruptedException {