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

[4.1][xa] refine for xa heartbeat

Browse Source
This commit is contained in:
obdev
2022-12-06 10:06:13 +00:00
committed by ob-robot
parent 94e421cf6e
commit 9ded1c6d28
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2115,7 +2115,8 @@ int ObXACtx::try_heartbeat()
const int64_t now = ObTimeUtility::current_time(); const int64_t now = ObTimeUtility::current_time();
if (original_sche_addr_ != GCTX.self_addr()) { if (original_sche_addr_ != GCTX.self_addr()) {
// temproray scheduler, do nothing // temproray scheduler, do nothing
} else if (OB_ISNULL(xa_branch_info_) && xa_trans_state_ > ObXATransState::IDLE) { } else if (OB_ISNULL(xa_branch_info_)
&& (ObXATransState::IDLE < xa_trans_state_ || ObXATransState::UNKNOWN == xa_trans_state_)) {
// do nothing // do nothing
} else if (OB_ISNULL(xa_branch_info_)) { } else if (OB_ISNULL(xa_branch_info_)) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;