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

cancel dag net firstly when ls offline

Browse Source
This commit is contained in:
Tsunaou 2024-02-02 20:47:18 +00:00 committed by ob-robot
parent 6fc5c16a15
commit 7b71e1bd5d
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/share/scheduler/ob_tenant_dag_scheduler.cpp
View File

@ -4410,21 +4410,22 @@ int ObTenantDagScheduler::check_ls_compaction_dag_exist_with_cancel(const ObLSID
int ret = OB_SUCCESS;
exist = false;
bool tmp_exist = false;
for (int64_t i = 0; OB_SUCC(ret) && i < ObIDag::MergeDagPrioCnt; ++i) {
tmp_exist = false;
if (OB_FAIL(prio_sche_[ObIDag::MergeDagPrio[i]].check_ls_compaction_dag_exist_with_cancel(ls_id, tmp_exist))) {
LOG_WARN("failed to check ls compaction dag exist", K(ret), K(ls_id));
} else if (tmp_exist) {
exist = true;
}
}
if (OB_FAIL(ret)) {
} else if (FALSE_IT(tmp_exist = false)) {
} else if (OB_FAIL(dag_net_sche_.check_ls_compaction_dag_exist_with_cancel(ls_id, tmp_exist))) {
if (OB_FAIL(dag_net_sche_.check_ls_compaction_dag_exist_with_cancel(ls_id, tmp_exist))) {
LOG_WARN("failed to check ls compaction dag exist", K(ret), K(ls_id));
} else if (tmp_exist) {
exist = true;
}
if (OB_FAIL(ret)) {
} else {
for (int64_t i = 0; OB_SUCC(ret) && i < ObIDag::MergeDagPrioCnt; ++i) {
tmp_exist = false;
if (OB_FAIL(prio_sche_[ObIDag::MergeDagPrio[i]].check_ls_compaction_dag_exist_with_cancel(ls_id, tmp_exist))) {
LOG_WARN("failed to check ls compaction dag exist", K(ret), K(ls_id));
} else if (tmp_exist) {
exist = true;
}
}
}
return ret;
}