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

add transfer no kill tx standby read case

Browse Source
This commit is contained in:
obdev
2024-02-09 20:15:35 +00:00
committed by ob-robot
parent ebec14b042
commit 90b7dfe88d
3 changed files with 55 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3891,6 +3891,12 @@ int ObPartTransCtx::submit_log_impl_(const ObTxLogType log_type)
}
if (OB_SWITCHING_TO_FOLLOWER_GRACEFULLY == ERRSIM_DELAY_TX_SUBMIT_LOG && 1002 == MTL_ID() && 1001 == ls_id_.id()) {
ret = ERRSIM_DELAY_TX_SUBMIT_LOG;
} else if (ERRSIM_DELAY_TX_SUBMIT_LOG < int(-9999)) {
// reject trans_id and tenant id to contorl trans sate
ret = process_errsim_for_standby_read_(int(ERRSIM_DELAY_TX_SUBMIT_LOG),
OB_SWITCHING_TO_FOLLOWER_GRACEFULLY);
TRANS_LOG(INFO, "reject delay tx submit log when submit commit log",
K(ret), K(ERRSIM_DELAY_TX_SUBMIT_LOG));
}
if (OB_SUCC(ret) && mt_ctx_.is_prepared()) {
ret = submit_commit_log_();
@ -6803,6 +6809,23 @@ int ObPartTransCtx::errism_dup_table_redo_sync_()
return ret;
}
int ObPartTransCtx::process_errsim_for_standby_read_(int err_code, int ret_code)
{
// reject trans_id and tenant id to contorl trans sate
int ret = OB_SUCCESS;
int64_t rej_code = abs(err_code);
int64_t rej_tenant_id = rej_code % 10000;
int64_t rej_trans_id = (rej_code - rej_tenant_id) / 10000;
if (trans_id_.get_id() == rej_trans_id && MTL_ID() == rej_tenant_id) {
ret = ret_code;
TRANS_LOG(INFO, "reject special code for control trans state", K(ret), K(err_code),
K(rej_code), K(rej_tenant_id), K(rej_trans_id), K(trans_id_));
}
return ret;
}
OB_NOINLINE int ObPartTransCtx::errism_submit_prepare_log_()
{
@ -6812,6 +6835,10 @@ OB_NOINLINE int ObPartTransCtx::errism_submit_prepare_log_()
ret = ERRSIM_DELAY_TX_SUBMIT_LOG;
} else if (OB_BLOCK_FROZEN == ERRSIM_DELAY_TX_SUBMIT_LOG && !is_root()) {
ret = ERRSIM_DELAY_TX_SUBMIT_LOG;
} else if (ERRSIM_DELAY_TX_SUBMIT_LOG < int(-9999)) {
// reject trans_id and tenant id to contorl trans sate
ret = process_errsim_for_standby_read_(int(ERRSIM_DELAY_TX_SUBMIT_LOG), OB_NOT_MASTER);
TRANS_LOG(INFO, "reject delay tx submit log", K(ret), K(ERRSIM_DELAY_TX_SUBMIT_LOG));
}
#ifdef ERRSIM
@ -8109,6 +8136,15 @@ int ObPartTransCtx::tx_keepalive_response_(const int64_t status)
if (OB_SWITCHING_TO_FOLLOWER_GRACEFULLY == ERRSIM_DELAY_TX_SUBMIT_LOG) {
return ret;
} else if (ERRSIM_DELAY_TX_SUBMIT_LOG < int(-9999)) {
// reject trans_id and tenant id to contorl trans sate
ret = process_errsim_for_standby_read_(int(ERRSIM_DELAY_TX_SUBMIT_LOG),
OB_SWITCHING_TO_FOLLOWER_GRACEFULLY);
if (OB_FAIL(ret)) {
return ret;
TRANS_LOG(INFO, "reject delay tx submit log when response to keepalive",
K(ret), K(ERRSIM_DELAY_TX_SUBMIT_LOG));
}
}
if ((OB_TRANS_CTX_NOT_EXIST == status || OB_TRANS_ROLLBACKED == status ||

1
src/storage/tx/ob_trans_part_ctx.h
View File

@ -885,6 +885,7 @@ private:
int build_and_post_ask_state_msg_(const share::SCN &snapshot,
const share::ObLSID &ori_ls_id, const ObAddr &ori_addr);
int check_ls_state_(const SCN &snapshot, const ObLSID &ls_id, const ObStandbyCheckInfo &check_info);
int process_errsim_for_standby_read_(int err_code, int ret_code);
int get_ls_replica_readable_scn_(const ObLSID &ls_id, SCN &snapshot_version);
int submit_redo_log_for_freeze_(bool &try_submit, const uint32_t freeze_clock);
void print_first_mvcc_callback_();

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

@ -703,6 +703,15 @@ int ObPartTransCtx::handle_tx_2pc_prepare_resp(const Ob2pcPrepareRespMsg &msg)
if (OB_NOT_INIT == ERRSIM_DELAY_TX_COMMIT) {
return ret;
} else if (ERRSIM_DELAY_TX_COMMIT < int(-9999)) {
// reject trans_id and tenant id to contorl trans sate
ret = process_errsim_for_standby_read_(int(ERRSIM_DELAY_TX_COMMIT),
OB_NOT_INIT);
if (OB_FAIL(ret)) {
return ret;
TRANS_LOG(INFO, "reject delay tx commit",
K(ret), K(ERRSIM_DELAY_TX_COMMIT));
}
}
ObTwoPhaseCommitMsgType msg_type = switch_msg_type_(msg.get_msg_type());
@ -850,6 +859,15 @@ int ObPartTransCtx::handle_tx_2pc_pre_commit_req(const Ob2pcPreCommitReqMsg &msg
if (OB_NOT_SUPPORTED == ERRSIM_DELAY_TX_COMMIT) {
return ret;
} else if (ERRSIM_DELAY_TX_COMMIT < int(-9999)) {
// reject trans_id and tenant id to contorl trans sate
ret = process_errsim_for_standby_read_(int(ERRSIM_DELAY_TX_COMMIT),
OB_NOT_SUPPORTED);
if (OB_FAIL(ret)) {
return ret;
TRANS_LOG(INFO, "reject delay tx commit when pre commit",
K(ret), K(ERRSIM_DELAY_TX_COMMIT));
}
}
ObTwoPhaseCommitMsgType msg_type = switch_msg_type_(msg.get_msg_type());