Terminate ping thread when save&restore app is closed

Author: georgweiss

core/websocket/src/main/java/org/phoebus/core/websocket/WebSocketClient.java

@@ -35,6 +35,7 @@ public class WebSocketClient implements WebSocket.Listener {
     private final Consumer<CharSequence> onTextCallback;
 
     private final AtomicBoolean attemptReconnect = new AtomicBoolean();
+    private final AtomicBoolean keepPinging = new AtomicBoolean();
     private CountDownLatch pingCountdownLatch;
 
     /**
@@ -90,6 +91,7 @@ public void onOpen(WebSocket webSocket) {
             connectCallback.run();
         }
         logger.log(Level.INFO, "Connected to " + uri);
+        keepPinging.set(true);
         new Thread(new PingRunnable()).start();
     }
 
@@ -134,7 +136,7 @@ public CompletionStage<?> onClose(WebSocket webSocket,
      * is called.
      */
     public void sendPing() {
-        logger.log(Level.FINE, "Sending ping");
+        logger.log(Level.FINE, Thread.currentThread().getName() + " Sending ping");
         webSocket.sendPing(ByteBuffer.allocate(0));
     }
 
@@ -175,6 +177,7 @@ public CompletionStage<?> onText(WebSocket webSocket,
      * @param reason Custom reason text.
      */
     public void close(String reason) {
+        keepPinging.set(false);
         webSocket.sendClose(1000, reason);
     }
 
@@ -197,7 +200,7 @@ private class PingRunnable implements Runnable {
 
         @Override
         public void run() {
-            while (true) {
+            while (keepPinging.get()) {
                 pingCountdownLatch = new CountDownLatch(1);
                 sendPing();
                 try {