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

[CP] reset pos if retry

Browse Source
This commit is contained in:
obdev
2024-02-06 23:30:52 +00:00
committed by ob-robot
parent ad6c865e50
commit d07f1639d5
1 changed files with 1 additions and 2 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

@ -446,11 +446,9 @@ int ObTenantStorageCheckpointWriter::get_tablet_with_addr(
ObTabletHandle &tablet_handle) ObTabletHandle &tablet_handle)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObSharedBlockReadInfo read_info; ObSharedBlockReadInfo read_info;
int64_t buf_len; int64_t buf_len;
char *buf = nullptr; char *buf = nullptr;
int64_t pos = 0;
read_info.addr_ = addr_info.new_addr_; read_info.addr_ = addr_info.new_addr_;
// only need load first-level meta // only need load first-level meta
if (addr_info.new_addr_.is_raw_block()) { if (addr_info.new_addr_.is_raw_block()) {
@ -462,6 +460,7 @@ int ObTenantStorageCheckpointWriter::get_tablet_with_addr(
do { do {
ObArenaAllocator allocator("SlogCkptWriter", OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID()); ObArenaAllocator allocator("SlogCkptWriter", OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID());
ObSharedBlockReadHandle block_handle(allocator); ObSharedBlockReadHandle block_handle(allocator);
int64_t pos = 0;
if (OB_FAIL(MTL(ObTenantMetaMemMgr*)->acquire_tablet_from_pool( if (OB_FAIL(MTL(ObTenantMetaMemMgr*)->acquire_tablet_from_pool(
addr_info.tablet_pool_type_, addr_info.tablet_pool_type_,
WashTabletPriority::WTP_LOW, WashTabletPriority::WTP_LOW,