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

skip hidden tablet checking logic

Browse Source
This commit is contained in:
hiddenbomb
2023-03-08 15:13:22 +00:00
committed by ob-robot
parent 4d7352d040
commit a0edc1b86f
1 changed files with 31 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/storage/tablet/ob_tablet_create_delete_helper.cpp
View File

@ -1751,20 +1751,44 @@ int ObTabletCreateDeleteHelper::ensure_skip_create_all_tablets_safe(
{
int ret = OB_SUCCESS;
ObTabletHandle tablet_handle;
ObSArray<int64_t> skip_idx;
for (int64_t i = 0; OB_SUCC(ret) && i < arg.tablets_.count(); ++i) {
const ObCreateTabletInfo &info = arg.tablets_.at(i);
const ObTabletID &data_tablet_id = info.data_tablet_id_;
if (is_mixed_tablets(info) || is_pure_data_tablets(info)) {
if (is_contain(skip_idx, i)) {
// do nothing
LOG_INFO("pure aux tablet info should be skipped", K(ret), K(info));
} else if (is_mixed_tablets(info) || is_pure_data_tablets(info)) {
// data tablet already checked, can ignore
} else if (OB_FAIL(ls_.replay_get_tablet(data_tablet_id, scn, tablet_handle))) {
if (OB_TABLET_NOT_EXIST != ret && OB_EAGAIN != ret) {
LOG_WARN("failed to replay get tablet", K(ret), K(data_tablet_id), K(scn));
} else if (OB_TABLET_NOT_EXIST == ret) {
// data tablet is deleted after log_ts of this transaction, safe to skip creation
ret = OB_SUCCESS;
} else if (is_pure_aux_tablets(info) || is_pure_hidden_tablets(info)) {
if (is_pure_hidden_tablets(info)) {
// If hidden tablets and related lob tablets are created simultaneously,
// upper layer ensures that hidden tablet info occurs before lob tablets(as aux tablet info).
// So here we only need to find aux info which is related to hidden tablets,
// and the related aux tablet info will be skipped later.
for (int64_t j = 0; OB_SUCC(ret) && j < info.tablet_ids_.count(); ++j) {
int64_t aux_idx = -1;
if (find_related_aux_info(arg, info.tablet_ids_.at(j), aux_idx)) {
if (OB_FAIL(skip_idx.push_back(aux_idx))) {
LOG_WARN("failed to push back skip idx", K(ret), K(aux_idx));
}
}
}
}
if (OB_FAIL(ret)) {
} else if (OB_FAIL(ls_.replay_get_tablet(data_tablet_id, scn, tablet_handle))) {
if (OB_TABLET_NOT_EXIST != ret && OB_EAGAIN != ret) {
LOG_WARN("failed to replay get tablet", K(ret), K(data_tablet_id), K(scn));
} else if (OB_TABLET_NOT_EXIST == ret) {
// data tablet is deleted after log_ts of this transaction, safe to skip creation
ret = OB_SUCCESS;
}
}
}
}
return ret;
}