qos heart question fix apache#3165

CrazyHZM · Jan 8, 2019 · fad88db · fad88db
1 parent 2cbc83f
commit fad88db
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/server/handler/QosProcessHandler.java b/...plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/server/handler/QosProcessHandler.java
@@ -93,6 +93,15 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) t
         }
     }
 
+    @Override
+    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
+        ScheduledFuture<?> future = welcomeFuture;
+        if(future != null && !future.isCancelled()){
+            future.cancel(true);
+        }
+        ctx.close();
+    }
+
     // G for GET, and P for POST
     private static boolean isHttp(int magic) {
         return magic == 'G' || magic == 'P';