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

fix offline core in notify mds abort

Browse Source
This commit is contained in:
obdev 2023-02-10 06:14:28 +00:00 committed by ob-robot
parent dd654cd6f3
commit 9622f5fea7
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5653,7 +5653,7 @@ int ObPartTransCtx::notify_data_source_(const NotifyType notify_type,
const bool is_force_kill)
{
int ret = OB_SUCCESS;
if (is_exiting_ && !is_follower_()) {
if (is_exiting_ && sub_state_.is_force_abort()) {
// do nothing
} else {
ObMulSourceDataNotifyArg arg;
@ -6433,6 +6433,7 @@ int ObPartTransCtx::do_local_abort_tx_()
// if (part_trans_action_ < ObPartTransAction::COMMIT) {
// part_trans_action_ = ObPartTransAction::ABORT;
// }
sub_state_.set_force_abort();
if (OB_FAIL(on_local_abort_tx_())) {
TRANS_LOG(WARN, "local tx abort failed", KR(ret), K(*this));
}
@ -6446,13 +6447,17 @@ int ObPartTransCtx::do_force_kill_tx_()
ObTxBufferNodeArray tmp_array;
if (OB_FAIL(gen_total_mds_array_(tmp_array))) {
if (get_downstream_state() >= ObTxState::COMMIT) {
// do nothing
} else if (OB_FAIL(gen_total_mds_array_(tmp_array))) {
TRANS_LOG(WARN, "gen total mds array failed", KR(ret), K(*this));
} else if (OB_FAIL(notify_data_source_(NotifyType::ON_ABORT,
ctx_tx_data_.get_end_log_ts() /*invalid_scn*/, false,
tmp_array, true /*is_force_kill*/))) {
TRANS_LOG(WARN, "notify data source failed", KR(ret), K(*this));
} else {
}
if (OB_SUCC(ret)) {
trans_kill_();
// Force kill cannot guarantee the consistency, so we just set end_log_ts
// to zero
@ -6461,6 +6466,7 @@ int ObPartTransCtx::do_force_kill_tx_()
if (OB_FAIL(unregister_timeout_task_())) {
TRANS_LOG(WARN, "unregister timer task error", KR(ret), "context", *this);
}
sub_state_.set_force_abort();
// Ignore ret
set_exiting_();
TRANS_LOG(INFO, "transaction killed success", "context", *this);