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

only docs

This commit is contained in:
rusefillc 2022-12-17 09:37:03 -05:00
parent 247d5e1892
commit 850415ad6c
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
java_console/io/src/main/java/com/rusefi/io/ConnectionWatchdog.java
View File

@ -18,25 +18,26 @@ public class ConnectionWatchdog {
private final Timer reconnectTimer; private final Timer reconnectTimer;
private static boolean isCreated; private static boolean isCreated;
private ConnectionWatchdog(int timeoutMs, Runnable action) { private ConnectionWatchdog(int timeoutMs, Runnable restartAction) {
reconnectTimer = new Timer(timeoutMs, e -> { reconnectTimer = new Timer(timeoutMs, e -> {
action.run(); restartAction.run();
// mark alive right after restart attempt
onDataArrived(); onDataArrived();
}); });
} }
public synchronized static void init(LinkManager linkManager) { public synchronized static void init(LinkManager linkManager) {
final AtomicBoolean isPending = new AtomicBoolean(); final AtomicBoolean isRestartPending = new AtomicBoolean();
if (isCreated) if (isCreated)
return; // only one instance is needed return; // only one instance is needed
isCreated = true; isCreated = true;
new ConnectionWatchdog(Timeouts.CONNECTION_RESTART_DELAY, () -> { new ConnectionWatchdog(Timeouts.CONNECTION_RESTART_DELAY, () -> {
if (isPending.compareAndSet(false, true)) { if (isRestartPending.compareAndSet(false, true)) {
linkManager.execute(() -> { linkManager.execute(() -> {
log.info("ConnectionWatchdog.reconnectTimer restarting: " + Timeouts.CONNECTION_RESTART_DELAY); log.info("ConnectionWatchdog.reconnectTimer restarting: " + Timeouts.CONNECTION_RESTART_DELAY);
linkManager.restart(); linkManager.restart();
isPending.set(false); isRestartPending.set(false);
}); });
} else { } else {
log.info("restart already pending..."); log.info("restart already pending...");