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

mysql ended,session status

Browse Source
This commit is contained in:
yanhuqing
2020-04-02 14:43:15 +08:00
parent 1198d76a1a
commit cdb84f71aa
1 changed files with 5 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java
+5 -11
View File
@@ -438,7 +438,7 @@ public class XACommitNodesHandler extends AbstractCommitNodesHandler {
if (conn instanceof MySQLConnection) {
MySQLConnection mysqlCon = (MySQLConnection) conn;
LOGGER.info(reason + mysqlCon);
if (mysqlCon.getXaStatus() == TxState.TX_STARTED_STATE) {
if (mysqlCon.getXaStatus() == TxState.TX_STARTED_STATE || mysqlCon.getXaStatus() == TxState.TX_ENDED_STATE) {
mysqlCon.close();
mysqlCon.setXaStatus(TxState.TX_CONN_QUIT);
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), mysqlCon);
@@ -446,16 +446,7 @@ public class XACommitNodesHandler extends AbstractCommitNodesHandler {
session.setXaState(TxState.TX_ENDED_STATE);
nextParse();
}
} else if (mysqlCon.getXaStatus() == TxState.TX_ENDED_STATE) {
mysqlCon.close();
mysqlCon.setXaStatus(TxState.TX_CONN_QUIT);
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), mysqlCon);
if (finished) {
session.setXaState(TxState.TX_PREPARING_STATE);
nextParse();
}
// 'xa prepare' connectionClose,conn has quit
} else if (mysqlCon.getXaStatus() == TxState.TX_PREPARING_STATE) {
} else if (mysqlCon.getXaStatus() == TxState.TX_PREPARING_STATE) { // 'xa prepare' connectionClose,conn has quit
mysqlCon.setXaStatus(TxState.TX_PREPARE_UNCONNECT_STATE);
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), mysqlCon);
session.setXaState(TxState.TX_PREPARE_UNCONNECT_STATE);
@@ -491,6 +482,7 @@ public class XACommitNodesHandler extends AbstractCommitNodesHandler {
private void cleanAndFeedback(boolean isSuccess) {
if (session.getXaState() == TxState.TX_INITIALIZE_STATE) { // clear all resources
LOGGER.debug("normal cleanAndFeedback");
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), TxState.TX_COMMITTED_STATE);
session.cancelableStatusSet(NonBlockingSession.CANCEL_STATUS_INIT);
session.clearResources(false);
@@ -505,6 +497,7 @@ public class XACommitNodesHandler extends AbstractCommitNodesHandler {
} else if (session.getXaState() == TxState.TX_COMMIT_FAILED_STATE) {
boolean isAllRelease = session.releaseNormalConns();
if (session.isKilled()) {
LOGGER.debug("session killed cleanAndFeedback");
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), session.getXaState());
setResponseTime(false);
session.clearSavepoint();
@@ -540,6 +533,7 @@ public class XACommitNodesHandler extends AbstractCommitNodesHandler {
}
}
} else {
LOGGER.debug("session connections all released");
XAStateLog.saveXARecoveryLog(session.getSessionXaID(), TxState.TX_COMMITTED_STATE);
session.setXaState(TxState.TX_INITIALIZE_STATE);
session.cancelableStatusSet(NonBlockingSession.CANCEL_STATUS_INIT);