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

Add defensive programming for possible nullptr in tenant_list to DtlIntermResultMonitor

Browse Source
This commit is contained in:
obdev
2023-10-24 09:09:44 +00:00
committed by ob-robot
parent 9002ba2ba2
commit 855e46c517
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/observer/virtual_table/ob_all_virtual_dtl_interm_result_monitor.cpp
View File

@ -232,10 +232,10 @@ int ObAllDtlIntermResultMonitor::fill_scanner()
} else {
uint64_t cur_tenant_id = MTL_ID();
if(is_sys_tenant(cur_tenant_id)) {
omt::TenantList &list = GCTX.omt_->get_tenant_list();
uint64_t tmp_tenant_id = 0;
for (omt::TenantList::iterator it = list.begin(); it != list.end() && OB_SUCC(ret); it++) {
tmp_tenant_id = (*it)->id();
omt::TenantIdList all_tenants;
GCTX.omt_->get_tenant_ids(all_tenants);
for (int i = 0; i < all_tenants.size(); ++i) {
uint64_t tmp_tenant_id = all_tenants[i];
if(!is_virtual_tenant_id(tmp_tenant_id)) {
ObDTLIntermResultMonitorInfoGetter monitor_getter(scanner_, *allocator_, output_column_ids_,
cur_row_, *addr_, ipstr, tmp_tenant_id);
@ -243,6 +243,10 @@ int ObAllDtlIntermResultMonitor::fill_scanner()
if (OB_FAIL(MTL(ObDTLIntermResultManager*)->generate_monitor_info_rows(monitor_getter))) {
SERVER_LOG(WARN, "generate monitor info array failed", K(ret));
}
} else {
// During the iteration process, tenants may be deleted,
// so we need to ignore the error code of MTL_SWITCH.
ret = OB_SUCCESS;
}
}
}