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

fix transfer out redo failed to abort param check

Browse Source
This commit is contained in:
obdev 2024-01-15 02:42:51 +00:00 committed by ob-robot
parent 6f88df06c2
commit cf72e15cd1
1 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/storage/tablet/ob_tablet_transfer_tx_ctx.cpp
View File

@ -199,6 +199,9 @@ void ObTransferOutTxCtx::on_commit(const share::SCN &commit_version, const share
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferOutTxCtx on_commit fail", KR(ret), K(commit_version), K(commit_scn), K(tx_id), KPC(this));
}
}
}
}
@ -216,9 +219,9 @@ void ObTransferOutTxCtx::on_abort(const share::SCN &abort_scn)
int64_t active_tx_count = 0;
int64_t op_tx_count = 0;
if (!is_valid()) {
if (!src_ls_id_.is_valid()) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("transfer out tx ctx invalid state", KR(ret), K(tx_id), KP(this));
LOG_WARN("transfer out tx ctx invalid state", KR(ret), K(tx_id), KPC(this));
} else if (OB_FAIL(MTL(ObLSService*)->get_ls(src_ls_id_, ls_handle, ObLSGetMod::STORAGE_MOD))) {
LOG_WARN("fail to get ls", KR(ret), K(tx_id), KP(this));
} else if (OB_UNLIKELY(nullptr == (ls = ls_handle.get_ls()))) {
@ -239,6 +242,9 @@ void ObTransferOutTxCtx::on_abort(const share::SCN &abort_scn)
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferOutTxCtx on_abort fail", KR(ret), K(abort_scn), K(tx_id), KPC(this));
}
}
}
}
@ -460,6 +466,9 @@ void ObTransferMoveTxCtx::on_redo(const share::SCN &redo_scn)
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferMoveTxCtx on_redo fail", KR(ret), K(tx_id), KP(this));
}
}
}
}
@ -502,6 +511,9 @@ void ObTransferMoveTxCtx::on_commit(const share::SCN &commit_version, const shar
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferMoveTxCtx on_commit fail", KR(ret), K(tx_id), KP(this));
}
}
}
}
@ -544,6 +556,9 @@ void ObTransferMoveTxCtx::on_abort(const share::SCN &abort_scn)
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferMoveTxCtx on_abort fail", KR(ret), K(tx_id), KP(this));
}
}
}
}
@ -664,6 +679,9 @@ void ObTransferDestPrepareTxCtx::on_redo(const share::SCN &redo_scn)
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferDestPrepareTxCtx on_redo fail", KR(ret), K(tx_id), KP(this));
}
}
}
}
@ -690,6 +708,9 @@ void ObTransferDestPrepareTxCtx::on_commit(const share::SCN &commit_version, con
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferDestPrepareTxCtx on_commit fail", KR(ret), K(tx_id), KP(this));
}
}
}
}
@ -715,6 +736,9 @@ void ObTransferDestPrepareTxCtx::on_abort(const share::SCN &abort_scn)
break;
} else {
ob_usleep(10 * 1000);
if (REACH_TIME_INTERVAL(10 * 1000L * 1000L)) {
LOG_ERROR("ObTransferDestPrepareTxCtx on_abort fail", KR(ret), K(tx_id), KP(this));
}
}
}
}