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

fix dag sheduler issues of vostest

Browse Source
This commit is contained in:
zhjc1124 2024-09-18 07:47:31 +00:00 committed by ob-robot
parent 4a4d584d2d
commit c73611c4bc
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/omt/ob_multi_tenant.cpp
View File

@ -482,7 +482,7 @@ int ObMultiTenant::init(ObAddr myaddr,
MTL_BIND2(mtl_new_default, compaction::ObTenantTabletScheduler::mtl_init, mtl_start_default, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
MTL_BIND2(mtl_new_default, compaction::ObTenantMediumChecker::mtl_init, nullptr, nullptr, nullptr, mtl_destroy_default);
MTL_BIND2(mtl_new_default, ObTabletTableUpdater::mtl_init, nullptr, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
MTL_BIND2(mtl_new_default, ObTenantDagScheduler::mtl_init, nullptr, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
MTL_BIND2(mtl_new_default, ObTenantDagScheduler::mtl_init, nullptr, mtl_stop_default, mtl_destroy_default, mtl_destroy_default); // destroy earlier for vostest
MTL_BIND2(mtl_new_default, ObTenantFreezeInfoMgr::mtl_init, mtl_start_default, mtl_stop_default, mtl_wait_default, mtl_destroy_default);
MTL_BIND2(mtl_new_default, ObTxLoopWorker::mtl_init, mtl_start_default, mtl_stop_default, mtl_wait_default, mtl_destroy_default); // ObTxLoopWorker
MTL_BIND2(mtl_new_default, compaction::ObTenantCompactionProgressMgr::mtl_init, nullptr, nullptr, nullptr, mtl_destroy_default);

2
src/share/rc/ob_tenant_base.h
View File

@ -289,6 +289,7 @@ using ObPartTransCtxObjPool = common::ObServerObjectPool<transaction::ObPartTran
using ObTableScanIteratorObjPool = common::ObServerObjectPool<oceanbase::storage::ObTableScanIterator>;
#define MTL_MEMBERS \
MTL_LIST( \
share::ObTenantDagScheduler*, \
blocksstable::ObDecodeResourcePool*, \
omt::ObSharedTimer*, \
oceanbase::sql::ObTenantSQLSessionMgr*, \
@ -374,7 +375,6 @@ using ObTableScanIteratorObjPool = common::ObServerObjectPool<oceanbase::storage
compaction::ObTenantMediumChecker*, \
storage::ObTenantCompactionMemPool*, \
TenantCompactionObjMgr \
share::ObTenantDagScheduler*, \
storage::ObStorageHAService*, \
storage::ObTenantFreezeInfoMgr*, \
TenantLSMergeScheduler \