apache#2

panxiaojun233 · Jan 18, 2021 · 0c68ca4 · 0c68ca4
1 parent 7fc0d46
commit 0c68ca4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/...dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/PortUnificationServer.java b/...dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/PortUnificationServer.java
@@ -165,15 +165,17 @@ public void operationComplete(final Future future) throws Exception {
                     }
                     System.out.println("shut operationComplete..");
                     long now = System.currentTimeMillis();
-                    while (now - start > 15000 || channelGroup.size() > 0) {
+                    while (now - start <= 15000 || channelGroup.size() > 0) {
                         try {
                             Thread.sleep(100);
                         } catch (InterruptedException e) {
                         }
                     }
                 }
-            }).await();
+            }).await(15000);
+            System.out.println("close cost:" + (System.currentTimeMillis()-start));
         } catch (InterruptedException e) {
+            System.out.println("Interrupted while shutting down" + e.getMessage());
             logger.warn("Interrupted while shutting down", e);
         }
 

diff --git a/...pc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/GracefulShutdown.java b/...pc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/GracefulShutdown.java
@@ -56,7 +56,7 @@ void secondGoAwayAndClose(ChannelHandlerContext ctx) {
             ctx.write(goAwayFrame);
             ctx.flush();
             //gracefulShutdownTimeoutMillis
-            ctx.close();
+            //ctx.close();
         } catch (Exception e) {
             ctx.fireExceptionCaught(e);
         }