Fix netty close when init count is 0 (#12737)

apache · Jul 17, 2023 · 630e14a · 630e14a
1 parent bd76d04
commit 630e14a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...-api/src/main/java/org/apache/dubbo/remoting/api/connection/AbstractConnectionClient.java b/...-api/src/main/java/org/apache/dubbo/remoting/api/connection/AbstractConnectionClient.java
@@ -49,6 +49,9 @@ public abstract class AbstractConnectionClient extends AbstractClient {
 
     protected AbstractConnectionClient(URL url, ChannelHandler handler) throws RemotingException {
         super(url, handler);
+    }
+
+    public final void increase() {
         COUNTER_UPDATER.set(this, 1L);
     }
 

diff --git a/...etty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyConnectionClient.java b/...etty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyConnectionClient.java
@@ -89,6 +89,7 @@ protected void initConnectionClient() {
         this.channel = new AtomicReference<>();
         this.closePromise = new DefaultPromise<>(GlobalEventExecutor.INSTANCE);
         this.init = new AtomicBoolean(false);
+        this.increase();
     }
 
     @Override