From a4a6bd03e7e83ce082f145a1a01223f59b619f59 Mon Sep 17 00:00:00 2001 From: Greg Wilkins Date: Sun, 17 Feb 2019 18:11:23 +0900 Subject: [PATCH] Fix from review use the new close(Throwable) in endpoint --- .../eclipse/jetty/websocket/core/internal/FrameFlusher.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/core/internal/FrameFlusher.java b/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/core/internal/FrameFlusher.java index 2f5caa6349d..a437263538a 100644 --- a/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/core/internal/FrameFlusher.java +++ b/jetty-websocket/websocket-core/src/main/java/org/eclipse/jetty/websocket/core/internal/FrameFlusher.java @@ -263,10 +263,7 @@ public class FrameFlusher extends IteratingCallback entry.release(); } entries.clear(); - if (endPoint instanceof AbstractEndPoint) - ((AbstractEndPoint)endPoint).close(failure); - else - endPoint.close(); + endPoint.close(failure); } private void releaseAggregate()