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

set trans_type for the participant with upstream and empty part_arry

Browse Source
This commit is contained in:
obdev 2022-11-07 16:40:19 +00:00 committed by wangzelin.wzl
parent 4811eda0b1
commit 05fd6fcff7
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3198,7 +3198,7 @@ int ObPartTransCtx::get_log_cb_(const bool need_final_cb, ObTxLogCb *&log_cb)
if (free_cbs_.is_empty()) {
ret = OB_TX_NOLOGCB;
//TRANS_LOG(INFO, "all log cbs are busy now, try again later", K(ret), K(*this));
} else if (free_cbs_.get_size() == RESERVE_LOG_CALLBACK_COUNT_FOR_FREEZING &&
} else if (free_cbs_.get_size() <= RESERVE_LOG_CALLBACK_COUNT_FOR_FREEZING &&
ATOMIC_LOAD(&is_submitting_redo_log_for_freeze_) == false) {
ret = OB_TX_NOLOGCB;
//TRANS_LOG(INFO, "reserve log callback for freezing, try again later", K(ret), K(*this));
@ -3874,6 +3874,8 @@ int ObPartTransCtx::replay_commit_info(const ObTxCommitInfoLog &commit_info_log,
// }
if (exec_info_.participants_.count() > 1) {
exec_info_.trans_type_ = TransType::DIST_TRANS;
} else if (exec_info_.upstream_.is_valid()) {
exec_info_.trans_type_ = TransType::DIST_TRANS;
} else if (is_sub2pc()) {
exec_info_.trans_type_ = TransType::DIST_TRANS;
} else {