diff --git a/jetty-websocket/websocket-tests/src/main/java/org/eclipse/jetty/websocket/tests/AbstractTrackingEndpoint.java b/jetty-websocket/websocket-tests/src/main/java/org/eclipse/jetty/websocket/tests/AbstractTrackingEndpoint.java index f4986e0abaf..40579a39c9f 100644 --- a/jetty-websocket/websocket-tests/src/main/java/org/eclipse/jetty/websocket/tests/AbstractTrackingEndpoint.java +++ b/jetty-websocket/websocket-tests/src/main/java/org/eclipse/jetty/websocket/tests/AbstractTrackingEndpoint.java @@ -112,9 +112,13 @@ public abstract class AbstractTrackingEndpoint LOG.debug("onWSClose({}, {})", statusCode, reason); } CloseInfo close = new CloseInfo(statusCode, reason); - boolean closeTracked = closeInfo.compareAndSet(null, close); + if (closeInfo.compareAndSet(null, close) == false) + { + LOG.warn("onClose should only happen once - Original Close: " + closeInfo.get()); + LOG.warn("onClose should only happen once - Extra/Excess Close: " + close); + fail("onClose should only happen once!"); + } this.closeLatch.countDown(); - assertTrue("Close only happened once", closeTracked); } protected void onWSError(Throwable cause)