From 850415ad6c51c77d565ea598c71729b0ffaa570a Mon Sep 17 00:00:00 2001 From: rusefillc Date: Sat, 17 Dec 2022 09:37:03 -0500 Subject: [PATCH] only docs --- .../main/java/com/rusefi/io/ConnectionWatchdog.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/java_console/io/src/main/java/com/rusefi/io/ConnectionWatchdog.java b/java_console/io/src/main/java/com/rusefi/io/ConnectionWatchdog.java index 6f60278195..8b96cad3e3 100644 --- a/java_console/io/src/main/java/com/rusefi/io/ConnectionWatchdog.java +++ b/java_console/io/src/main/java/com/rusefi/io/ConnectionWatchdog.java @@ -18,25 +18,26 @@ public class ConnectionWatchdog { private final Timer reconnectTimer; private static boolean isCreated; - private ConnectionWatchdog(int timeoutMs, Runnable action) { + private ConnectionWatchdog(int timeoutMs, Runnable restartAction) { reconnectTimer = new Timer(timeoutMs, e -> { - action.run(); + restartAction.run(); + // mark alive right after restart attempt onDataArrived(); }); } public synchronized static void init(LinkManager linkManager) { - final AtomicBoolean isPending = new AtomicBoolean(); + final AtomicBoolean isRestartPending = new AtomicBoolean(); if (isCreated) return; // only one instance is needed isCreated = true; new ConnectionWatchdog(Timeouts.CONNECTION_RESTART_DELAY, () -> { - if (isPending.compareAndSet(false, true)) { + if (isRestartPending.compareAndSet(false, true)) { linkManager.execute(() -> { log.info("ConnectionWatchdog.reconnectTimer restarting: " + Timeouts.CONNECTION_RESTART_DELAY); linkManager.restart(); - isPending.set(false); + isRestartPending.set(false); }); } else { log.info("restart already pending...");