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

convert trans to dist txn during log submitting if transferred

Browse Source
This commit is contained in:
Handora
2024-02-18 08:36:22 +00:00
committed by ob-robot
parent cfdbea52bb
commit 9cb822a19b
5 changed files with 447 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
mittest/simple_server/env/ob_simple_server_helper.cpp vendored
View File

@ -372,6 +372,43 @@ int SimpleServerHelper::remove_tx(uint64_t tenant_id, ObLSID ls_id, ObTransID tx
return ret;
}
int SimpleServerHelper::get_tx_ctx(uint64_t tenant_id,
ObLSID ls_id,
ObTransID tx_id,
ObPartTransCtx *&ctx)
{
int ret = OB_SUCCESS;
MTL_SWITCH(tenant_id) {
ObLSHandle ls_handle;
if (OB_FAIL(MTL(ObLSService*)->get_ls(ls_id,
ls_handle,
ObLSGetMod::STORAGE_MOD))) {
LOG_WARN("get ls failed", KR(ret), K(ls_id));
} else if (OB_FAIL(ls_handle.get_ls()->get_tx_ctx(tx_id, false, ctx))) {
LOG_WARN("fail to get tx ctx", KR(ret), K(ls_id));
}
}
return ret;
}
int SimpleServerHelper::revert_tx_ctx(uint64_t tenant_id,
ObLSID ls_id,
ObPartTransCtx *ctx)
{
int ret = OB_SUCCESS;
MTL_SWITCH(tenant_id) {
ObLSHandle ls_handle;
if (OB_FAIL(MTL(ObLSService*)->get_ls(ls_id,
ls_handle,
ObLSGetMod::STORAGE_MOD))) {
LOG_WARN("get ls failed", KR(ret), K(ls_id));
} else if (OB_FAIL(ls_handle.get_ls()->revert_tx_ctx(ctx))) {
LOG_WARN("fail to revert tx ctx", KR(ret), K(ls_id));
}
}
return ret;
}
int SimpleServerHelper::abort_tx(uint64_t tenant_id, ObLSID ls_id, ObTransID tx_id)
{
int ret = OB_SUCCESS;