[inner-1591] fix hang

smarticeberg · Jan 10, 2022 · a61f981 · a61f981
1 parent 3e60ef0
commit a61f981
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/ddl/BaseDDLHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/ddl/BaseDDLHandler.java
@@ -288,13 +288,11 @@ public void connectionClose(@NotNull AbstractService service, String closeReason
         lock.lock();
         try {
             responseService.setResponseHandler(null);
-            if (writeToClientFlag.compareAndSet(false, true)) {
-                setErrPkg(errMsg0, ErrorCode.ER_ABORTING_CONNECTION);
-                if (decrementToZero(node, STATUS_CONN_CLOSE)) {
-                    specialHandling(false, this.getErrMsg());
-                    this.err.setPacketId(session.getShardingService().nextPacketId());
-                    handleEndPacket(this.err);
-                }
+            setErrPkg(errMsg0, ErrorCode.ER_ABORTING_CONNECTION);
+            if (decrementToZero(node, STATUS_CONN_CLOSE) && writeToClientFlag.compareAndSet(false, true)) {
+                specialHandling(false, this.getErrMsg());
+                this.err.setPacketId(session.getShardingService().nextPacketId());
+                handleEndPacket(this.err);
             }
         } finally {
             lock.unlock();