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

server shutdown commit not registered retry

Browse Source
This commit is contained in:
chinaxing
2023-06-13 11:12:18 +00:00
committed by ob-robot
parent cf733ea64f
commit 37716d6d43
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/storage/tx/ob_trans_service_v4.cpp
View File

@ -252,11 +252,11 @@ int ObTransService::do_commit_tx_slowpath_(ObTxDesc &tx)
// build msg fail won't cause commit fail, later driven by retry timer // build msg fail won't cause commit fail, later driven by retry timer
} else if (OB_TMP_FAIL(rpc_->post_msg(tx.coord_id_, commit_msg))) { } else if (OB_TMP_FAIL(rpc_->post_msg(tx.coord_id_, commit_msg))) {
TRANS_LOG(WARN, "post tx commit msg fail", K(tmp_ret), K(tx), K(commit_msg)); TRANS_LOG(WARN, "post tx commit msg fail", K(tmp_ret), K(tx), K(commit_msg));
if (is_location_service_renew_error(tmp_ret)) { if (DELETED_UNRETRYABLE_ERROR(tmp_ret)) {
// send msg fail won't cause commit fail, later driven by retry timer
} else if (DELETED_UNRETRYABLE_ERROR(tmp_ret)) {
ret = tx.commit_times_ > 0 ? OB_TRANS_UNKNOWN : OB_TRANS_KILLED; ret = tx.commit_times_ > 0 ? OB_TRANS_UNKNOWN : OB_TRANS_KILLED;
} else { ret = tmp_ret; } } else {
// retryable error : location incorrect, server shutdown etc.
}
} else { } else {
post_succ = true; post_succ = true;
++tx.commit_times_; ++tx.commit_times_;