Changeset 16 for src/main/java/geniusweb/partiesserver/websocket

Timestamp:

06/22/20 16:08:10 (4 years ago)

Author:

bart

Message:

Tries harder to kill parties after deadline

Location:

src/main/java/geniusweb/partiesserver/websocket

Files:

• ActiveThreads.java (added)
• PartySocket.java (modified) (5 diffs)

src/main/java/geniusweb/partiesserver/websocket/PartySocket.java

@@ -44 +44 @@
 public class PartySocket implements ConnectionEnd<Inform, Action> {
         private final static ObjectMapper jackson = new ObjectMapper();
+        private static final int MAX_MESSAGE_SIZE = 20 * 1024 * 1024;
+
         private final Reporter log;
         private final RunningPartiesRepo runningparties;
         private final List<Listener<Inform>> listeners = new CopyOnWriteArrayList<Listener<Inform>>();
-        private static final int MAX_MESSAGE_SIZE = 20 * 1024 * 1024;
+        private final ActiveThreads threads;
 
         // should all be final, except that we can only set them when start is
@@ -66 +68 @@
                 this.runningparties = parties;
                 this.log = reporter;
+                this.threads = new ActiveThreads(log);
         }
 
@@ -128 +131 @@
                         throw new IllegalStateException("Unexpected change of session ID");
                 }
+                if (!threads.isEmpty()) {
+                        log.log(Level.WARNING, "Party " + partyID
+                                        + " is still busy with previous message");
+                }
                 Inform info = jackson.readValue(informmessage, Inform.class);
                 RunningParty party = runningparties.get(partyID);
@@ -135 +142 @@
                         log.log(Level.FINE, "Inform " + partyID + ": " + info);
                         try {
+                                threads.add();
                                 party.inform(info);
+                                threads.remove();
                         } catch (Throwable e) {
-                                log.log(Level.WARNING, "Party failed on inform.", e);
-                                e.printStackTrace();
-                                // severe as someone wants to debug that. Not severe for us
-                                // we don't use jackson.writeValueAsString(e) here because
-                                // CloseReason has 123 char limit.
-                                // The error will be too large to fit and will be truncated
-                                // therefore we send a plain string and hope that enough
-                                // will arrive at the other side (the protocol)
+                                threads.remove();
+                                if (e instanceof ThreadDeath)
+                                        /*
+                                         * ThreadDeath always prints stacktrace anwyay, stacktrace
+                                         * is useless because it contains the thrower's stacktrace
+                                         * instead of a useful message.
+                                         */
+                                        log.log(Level.WARNING,
+                                                        "Party was killed while handling inform.");
+                                else
+                                        log.log(Level.WARNING, "Party failed on inform.", e);
+                                /*
+                                 * severe as someone wants to debug that. Not severe for us we
+                                 * don't use jackson.writeValueAsString(e) here because
+                                 * CloseReason has 123 char limit. The error will be too large
+                                 * to fit and will be truncated therefore we send a plain string
+                                 * and hope that enough will arrive at the other side (the
+                                 * protocol)
+                                 */
                                 session.close(new CloseReason(
                                                 CloseReason.CloseCodes.CLOSED_ABNORMALLY,
@@ -186 +206 @@
         public void onClose() throws IOException {
                 log.log(Level.INFO, "socket closed to " + partyID);
-                /*
-                 * for now just kill the party. Maybe we can do something with reconnect
-                 * but that will be complex.
-                 */
+                if (!threads.isEmpty()) {
+                        log.log(Level.WARNING, "Party " + partyID
+                                        + " failed to terminate. Trying to kill the remaining threads.");
+                        threads.killall();
+                }
                 runningparties.remove(partyID);
                 outstream.stop();