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

reuse allocator for rollback

Browse Source
This commit is contained in:
obdev
2023-12-20 06:17:53 +00:00
committed by ob-robot
parent aa9dd269ce
commit 0d242631dd
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/slog_ckpt/ob_tenant_storage_checkpoint_writer.cpp
View File

@ -596,7 +596,7 @@ int ObTenantStorageCheckpointWriter::rollback()
if (!is_inited_ || 0 == tablet_item_addr_info_arr_.count()) { if (!is_inited_ || 0 == tablet_item_addr_info_arr_.count()) {
// there's no new tablet, no need to rollback // there's no new tablet, no need to rollback
} else { } else {
ObArenaAllocator allocator("CkptRollback"); ObArenaAllocator allocator("CkptRollback", OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID());
ObTablet tablet; ObTablet tablet;
for (int64_t i = 0; i < tablet_item_addr_info_arr_.count(); i++) { for (int64_t i = 0; i < tablet_item_addr_info_arr_.count(); i++) {
tablet.reset(); tablet.reset();
@ -608,6 +608,7 @@ int ObTenantStorageCheckpointWriter::rollback()
if (addr_info.need_rollback_) { if (addr_info.need_rollback_) {
rollback_cnt++; rollback_cnt++;
do { do {
allocator.reuse();
if (OB_FAIL(MTL(ObTenantCheckpointSlogHandler*)->read_from_disk( if (OB_FAIL(MTL(ObTenantCheckpointSlogHandler*)->read_from_disk(
addr_info.new_addr_, addr_info.new_addr_,
allocator, allocator,