mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-08 07:21:00 -05:00
Code Issues Packages Projects Releases Wiki Activity

#289 fix the error handling when xa transaction error in prepare

Browse Source
This commit is contained in:
sunzhengfang
2017-10-20 12:25:01 +08:00
parent 47e2a22bd5
commit b955839b5a
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/NewConnectionRespHandler.java
+1 -1
View File
@@ -42,7 +42,7 @@ public class NewConnectionRespHandler implements ResponseHandler {
lock.lock();
try {
initiated.signal();
}finally {
} finally {
lock.unlock();
}
}
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XARollbackNodesHandler.java
+2 -2
View File
@@ -341,8 +341,8 @@ public class XARollbackNodesHandler extends AbstractRollbackNodesHandler {
session.getSource().write(send);
//partitionly commited,must commit again
} else if (session.getXaState() == TxState.TX_ROLLBACK_FAILED_STATE || session.getXaState() == TxState.TX_PREPARED_STATE
|| session.getXaState() == TxState.TX_PREPARE_UNCONNECT_STATE) {
} else if (session.getXaState() == TxState.TX_ROLLBACK_FAILED_STATE || session.getXaState() == TxState.TX_PREPARED_STATE ||
session.getXaState() == TxState.TX_PREPARE_UNCONNECT_STATE) {
MySQLConnection errConn = session.releaseExcept(session.getXaState());
if (errConn != null) {
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), session.getXaState());