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

Change wash rank allocator type

Browse Source
This commit is contained in:
obdev
2023-04-19 15:15:15 +00:00
committed by ob-robot
parent 7c130dca08
commit b3749c8103
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/blocksstable/ob_tmp_file_cache.cpp
View File

@ -990,13 +990,14 @@ int ObTmpTenantMemBlockManager::wash(const int64_t block_nums,
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
TmpMacroBlockMap::iterator iter; TmpMacroBlockMap::iterator iter;
common::ObArray<ObTmpMacroBlock*> blks; common::ObArray<ObTmpMacroBlock*> blks;
ObArenaAllocator allocator("TmpFileRank");
if (IS_NOT_INIT) { if (IS_NOT_INIT) {
ret = OB_NOT_INIT; ret = OB_NOT_INIT;
STORAGE_LOG(WARN, "ObTmpTenantMemBlockManager has not been inited", K(ret)); STORAGE_LOG(WARN, "ObTmpTenantMemBlockManager has not been inited", K(ret));
} else if (OB_FAIL(wait_write_io_finish())) { } else if (OB_FAIL(wait_write_io_finish())) {
STORAGE_LOG(WARN, "fail to wait previous write io", K(ret)); STORAGE_LOG(WARN, "fail to wait previous write io", K(ret));
} else { } else {
Heap heap(compare_, allocator_); Heap heap(compare_, &allocator);
int64_t cur_time = ObTimeUtility::fast_current_time(); int64_t cur_time = ObTimeUtility::fast_current_time();
for (iter = t_mblk_map_.begin(); OB_SUCC(ret) && iter != t_mblk_map_.end(); ++iter) { for (iter = t_mblk_map_.begin(); OB_SUCC(ret) && iter != t_mblk_map_.end(); ++iter) {
ObTmpMacroBlock *m_blk = iter->second; ObTmpMacroBlock *m_blk = iter->second;