hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[4.1][xa] stop tx before release tx for loosely coupled xa trans in heartbeat test

Browse Source
This commit is contained in:
obdev
2022-11-30 07:06:36 +00:00
committed by ob-robot
parent 69d9941a08
commit c4a040967a
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/tx/ob_xa_ctx.cpp
View File

@ -2141,6 +2141,9 @@ int ObXACtx::try_heartbeat()
// exit only // exit only
// no need to delete xa records // no need to delete xa records
// if xa records exist, we can rely on garbage collection // if xa records exist, we can rely on garbage collection
if (OB_FAIL(MTL(ObTransService*)->stop_tx(*tx_desc_))) {
TRANS_LOG(WARN, "fail to stop transaction", K(ret), K(*this));
}
(void)set_exiting_(); (void)set_exiting_();
} else if (now > branch_info.last_hb_ts_ + XA_HB_THRESHOLD) { } else if (now > branch_info.last_hb_ts_ + XA_HB_THRESHOLD) {
branch_info.unrespond_msg_cnt_++; branch_info.unrespond_msg_cnt_++;