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

fix test_io_manager test case

Browse Source
This commit is contained in:
obdev
2024-05-14 13:32:22 +00:00
committed by ob-robot
parent 8849306ffb
commit 03cc19e66b
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/share/io/ob_io_manager.cpp
View File

@ -112,6 +112,7 @@ void ObIOManager::destroy()
server_io_manager_ = nullptr; server_io_manager_ = nullptr;
allocator_.destroy(); allocator_.destroy();
is_inited_ = false; is_inited_ = false;
LOG_INFO("io manager is destroyed");
} }
int ObIOManager::start() int ObIOManager::start()
@ -547,7 +548,7 @@ int ObTenantIOManager::mtl_new(ObTenantIOManager *&io_service)
io_service = nullptr; io_service = nullptr;
if (is_virtual_tenant_id(MTL_ID())) { if (is_virtual_tenant_id(MTL_ID())) {
// do nothing // do nothing
} else if (OB_ISNULL(buf = OB_IO_MANAGER.allocator_.alloc(sizeof(ObTenantIOManager)))) { } else if (OB_ISNULL(buf = ob_malloc(sizeof(ObTenantIOManager), ObMemAttr(MTL_ID(), "IO_MGR")))) {
ret = OB_ALLOCATE_MEMORY_FAILED; ret = OB_ALLOCATE_MEMORY_FAILED;
FLOG_WARN("failed to alloc tenant io mgr", K(ret)); FLOG_WARN("failed to alloc tenant io mgr", K(ret));
} else { } else {
@ -581,7 +582,7 @@ void ObTenantIOManager::mtl_destroy(ObTenantIOManager *&io_service)
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_NOT_NULL(io_service)) { if (OB_NOT_NULL(io_service)) {
io_service->~ObTenantIOManager(); io_service->~ObTenantIOManager();
OB_IO_MANAGER.allocator_.free(io_service); ob_free(io_service);
io_service = nullptr; io_service = nullptr;
FLOG_INFO("mtl destroy tenant io manager success", K(MTL_ID())); FLOG_INFO("mtl destroy tenant io manager success", K(MTL_ID()));
} }