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

prevent clear log submitted after participant has been local aborted

Browse Source
This commit is contained in:
chinaxing
2023-12-18 20:21:59 +00:00
committed by ob-robot
parent 1afcf22f6a
commit e10a5c7351
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/tx/ob_tx_2pc_msg_handler.cpp
View File

@ -966,7 +966,10 @@ int ObPartTransCtx::handle_tx_2pc_clear_req(const Ob2pcClearReqMsg &msg)
ObTwoPhaseCommitMsgType msg_type = switch_msg_type_(msg.get_msg_type());
msg_2pc_cache_ = &msg;
if (OB_FAIL(set_2pc_request_id_(msg.request_id_))) {
if (is_exiting()) {
ret = OB_TRANS_CTX_NOT_EXIST;
TRANS_LOG(WARN, "trans ctx is exiting", K(ret), K(msg), KPC(this));
} else if (OB_FAIL(set_2pc_request_id_(msg.request_id_))) {
TRANS_LOG(WARN, "set request id failed", KR(ret), K(msg), K(*this));
} else if (OB_FAIL(handle_2pc_req(msg_type))) {
TRANS_LOG(WARN, "handle 2pc request failed", KR(ret), K(msg), K(*this));