rusefi
/
custom-board-bundle-sample-fork-of-rusefi
mirror of https://github.com/rusefi/custom-board-bundle-sample-fork-of-rusefi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

gauge poking is needed after local application is disconnected same as before it's connected

This commit is contained in:
rusefillc 2020-10-09 00:51:34 -04:00
parent 92f4e1ba22
commit 06aff23a71
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
java_console/io/src/main/java/com/rusefi/proxy/client/LocalApplicationProxy.java
View File

@ -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);

1
java_console/io/src/test/java/com/rusefi/TestHelper.java
View File

@ -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 {