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

[master] TxCtx: skip check server alive by rs if scheduler is local

Browse Source
This commit is contained in:
chinaxing
2024-02-23 10:15:56 +00:00
committed by ob-robot
parent 3dca838f87
commit 8a177eadd3
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/storage/tx/ob_trans_part_ctx.cpp
View File

@ -1537,15 +1537,14 @@ int ObPartTransCtx::check_scheduler_status()
bool is_alive = true;
bool need_check_scheduler = need_to_ask_scheduler_status_();
if (!need_check_scheduler) {
TRANS_LOG(DEBUG, "don't need ask scheduler status", K(ret), K(*this));
} else if (OB_FAIL(check_rs_scheduler_is_alive_(is_alive))) {
TRANS_LOG(WARN, "check rs scheduler is alive error", KR(ret), K(is_alive), "context",
*this);
TRANS_LOG(DEBUG, "don't need ask scheduler status", K(ret), KPC(this));
} else if (exec_info_.scheduler_ != addr_ && OB_FAIL(check_rs_scheduler_is_alive_(is_alive))) {
TRANS_LOG(WARN, "check rs scheduler is alive error", KR(ret), K(is_alive), KPC(this));
// scheduler已宕机
} else if (!is_alive) {
TRANS_LOG(WARN, "scheduler server is not alive, tx ctx will do gc");
TRANS_LOG(WARN, "scheduler server is not alive, tx ctx will do gc", KPC(this));
if (OB_FAIL(gc_ctx_())) {
TRANS_LOG(WARN, "force kill part_ctx error", KR(ret), "context", *this);
TRANS_LOG(WARN, "force kill part_ctx error", KR(ret), KPC(this));
}
} else {
// do nothing