From 0ea13ec528a5f9512dd60951610ea366837f0140 Mon Sep 17 00:00:00 2001
From: Jon Chambers <jon@signal.org>
Date: Tue, 12 Nov 2024 10:02:12 -0500
Subject: [PATCH] Handle static "closed" exceptions

---
 .../textsecuregcm/websocket/WebSocketConnection.java           | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java b/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
index 6ff1a152e..7aa440aa2 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
@@ -32,6 +32,7 @@ import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.concurrent.atomic.LongAdder;
 import org.apache.commons.lang3.StringUtils;
+import org.eclipse.jetty.util.StaticException;
 import org.reactivestreams.Publisher;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -445,6 +446,8 @@ public class WebSocketConnection implements WebSocketConnectionEventListener {
       errorType = "connectionClosed";
     } else if (e instanceof org.eclipse.jetty.io.EofException) {
       errorType = "connectionEof";
+    } else if (e instanceof StaticException staticException && "Closed".equals(staticException.getMessage())) {
+      errorType = "closedStatic";
     } else {
       logger.warn(terminal ? "Send message failure terminated stream" : "Send message failed", e);
       errorType = "other";