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

fix MERGE_RESERVE_CTX_ID failed to reserve memory

Browse Source
This commit is contained in:
obdev
2024-02-10 01:00:16 +00:00
committed by ob-robot
parent 7b0e565a49
commit b20d0e2057
3 changed files with 20 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
deps/oblib/src/lib/alloc/ob_malloc_allocator.cpp vendored
View File

@ -586,9 +586,7 @@ int64_t ObMallocAllocator::sync_wash(uint64_t tenant_id, uint64_t from_ctx_id, i
i++) {
int64_t ctx_id = (from_ctx_id + i) % ObCtxIds::MAX_CTX_ID;
auto allocator = get_tenant_ctx_allocator(tenant_id, ctx_id);
if (NULL == allocator) {
// do-nothing
} else {
if (NULL != allocator && !(CTX_ATTR(ctx_id).disable_sync_wash_)) {
washed_size += allocator->sync_wash(wash_size - washed_size);
}
}

5
deps/oblib/src/lib/allocator/ob_ctx_define.h vendored
View File

@ -27,6 +27,7 @@ struct ObCtxAttr
bool enable_dirty_list_ = false;
bool enable_no_log_ = false;
int parallel_ = DEFAULT_CTX_PARALLEL;
bool disable_sync_wash_ = false;
};
struct ObCtxAttrCenter
@ -49,6 +50,10 @@ public:
#define ENABLE_NO_LOG_DEF(name) ctx_attr_[ObCtxIds::name].enable_no_log_ = true;
ENABLE_NO_LOG_DEF(LOGGER_CTX_ID)
#undef ENABLE_NO_LOG_DEF
#define DISABLE_SYNC_WASH_DEF(name) ctx_attr_[ObCtxIds::name].disable_sync_wash_ = true;
DISABLE_SYNC_WASH_DEF(MERGE_RESERVE_CTX_ID)
#undef DISABLE_SYNC_WASH_DEF
}
static ObCtxAttrCenter &instance();
ObCtxAttr attr_of_ctx(int64_t ctx_id) const

14
deps/oblib/unittest/lib/alloc/test_tenant_ctx_allocator.cpp vendored
View File

@ -391,6 +391,20 @@ TEST(TestTenantAllocator, sub_ctx_id)
ASSERT_NE(OB_SUCCESS, malloc_allocator->recycle_tenant_allocator(tenant_id_1));
}
TEST(TestTenantAllocator, MERGE_RESERVE_CTX)
{
const uint64_t tenant_id = 1002;
ObMallocAllocator* malloc_allocator = ObMallocAllocator::get_instance();
ASSERT_EQ(OB_SUCCESS, malloc_allocator->create_and_add_tenant_allocator(tenant_id));
void *ptr_0 = ob_malloc(100L<<10, ObMemAttr(tenant_id, "Test", 0));
void *ptr_1 = ob_malloc(100L<<10, ObMemAttr(tenant_id, "Test", ObCtxIds::MERGE_RESERVE_CTX_ID));
malloc_allocator->sync_wash(tenant_id, 0, INT64_MAX);
AChunk *chunk_0 = AChunk::ptr2chunk(ptr_0);
AChunk *chunk_1 = AChunk::ptr2chunk(ptr_1);
ASSERT_NE(0, chunk_0->washed_size_);
ASSERT_EQ(0, chunk_1->washed_size_);
}
int main(int argc, char *argv[])
{
signal(49, SIG_IGN);