perform client actions in new thread to allow pings during long runni…

…ng processes (qzind#1177)
tresf · Oct 4, 2023 · ee94ad6 · ee94ad6
1 parent cc4454e
commit ee94ad6
Showing 1 changed file with 23 additions and 9 deletions.
diff --git a/src/qz/ws/PrintSocketClient.java b/src/qz/ws/PrintSocketClient.java
@@ -164,20 +164,34 @@ public void onMessage(Session session, Reader reader) throws IOException {
                 }
             }
 
-            processMessage(session, json, connection, request);
-        }
-        catch(UnsatisfiedLinkError | LoaderException e) {
-            log.error("A component is missing or broken, preventing this feature from working", e);
-            sendError(session, UID, "Sorry, this feature is unavailable at this time");
+            //spawn thread to prevent long processes from blocking
+            final String tUID = UID;
+            new Thread(() -> {
+                try {
+                    processMessage(session, json, connection, request);
+                }
+                catch(UnsatisfiedLinkError | LoaderException e) {
+                    log.error("A component is missing or broken, preventing this feature from working", e);
+                    sendError(session, tUID, "Sorry, this feature is unavailable at this time");
+                }
+                catch(JSONException e) {
+                    log.error("Bad JSON: {}", e.getMessage());
+                    sendError(session, tUID, e);
+                }
+                catch(InvalidPathException | FileSystemException e) {
+                    log.error("FileIO exception occurred", e);
+                    sendError(session, tUID, String.format("FileIO exception occurred: %s: %s", e.getClass().getSimpleName(), e.getMessage()));
+                }
+                catch(Exception e) {
+                    log.error("Problem processing message", e);
+                    sendError(session, tUID, e);
+                }
+            }).start();
         }
         catch(JSONException e) {
             log.error("Bad JSON: {}", e.getMessage());
             sendError(session, UID, e);
         }
-        catch(InvalidPathException | FileSystemException e) {
-            log.error("FileIO exception occurred", e);
-            sendError(session, UID, String.format("FileIO exception occurred: %s: %s", e.getClass().getSimpleName(), e.getMessage()));
-        }
         catch(Exception e) {
             log.error("Problem processing message", e);
             sendError(session, UID, e);