mirror of
https://github.com/actiontech/dble.git
synced 2026-01-04 20:01:32 -06:00
[inner-2222] clear the 'sendData' resource in the transaction correctly (cherry pick from #3702)
This commit is contained in:
@@ -60,6 +60,10 @@ public class TransactionHandlerManager {
|
||||
}
|
||||
}
|
||||
|
||||
public NormalTransactionHandler getNormalTransactionHandler() {
|
||||
return (NormalTransactionHandler) normalHandler;
|
||||
}
|
||||
|
||||
public void commit() {
|
||||
if (xaTxId != null) {
|
||||
xaHandler.commit();
|
||||
|
||||
@@ -34,7 +34,7 @@ public class CommitStage implements TransactionStage {
|
||||
if (session.closed()) {
|
||||
return null;
|
||||
}
|
||||
|
||||
session.getTransactionManager().getNormalTransactionHandler().clearResources();
|
||||
if (isFail) {
|
||||
session.setFinishedCommitTime();
|
||||
session.setResponseTime(false);
|
||||
|
||||
@@ -31,7 +31,7 @@ public class RollbackStage implements TransactionStage {
|
||||
if (session.closed()) {
|
||||
return null;
|
||||
}
|
||||
|
||||
session.getTransactionManager().getNormalTransactionHandler().clearResources();
|
||||
session.setResponseTime(false);
|
||||
if (isFail) {
|
||||
session.getSource().write(sendData);
|
||||
|
||||
Reference in New Issue
Block a user