reset fail state when last xa transaction fail to execute. (#1512)

actiontech · Nov 21, 2019 · fd62e7a · fd62e7a
1 parent 28c8819
commit fd62e7a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeHandler.java
@@ -26,7 +26,7 @@ public abstract class MultiNodeHandler implements ResponseHandler {
     private static final Logger LOGGER = LoggerFactory.getLogger(MultiNodeHandler.class);
     protected final ReentrantLock lock = new ReentrantLock();
     protected final NonBlockingSession session;
-    private AtomicBoolean isFailed = new AtomicBoolean(false);
+    protected AtomicBoolean isFailed = new AtomicBoolean(false);
     protected volatile String error;
     protected byte packetId;
     protected final AtomicBoolean errorResponse = new AtomicBoolean(false);

diff --git a/...com/actiontech/dble/backend/mysql/nio/handler/transaction/AbstractCommitNodesHandler.java b/...com/actiontech/dble/backend/mysql/nio/handler/transaction/AbstractCommitNodesHandler.java
@@ -67,6 +67,7 @@ public void reset() {
         firstResponsed = false;
         unResponseRrns.clear();
         packetId = 0;
+        isFailed.set(false);
     }
 
     public void debugCommitDelay() {