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

[CP] reset pos if retry

Browse Source 
Co-authored-by: liuzizhuo <liuzizhuo@bankofbeijing.com.cn>
Co-authored-by: BOBChenRH <chenruohao@bankofbeijing.com.cn>
This commit is contained in:
boger001 2023-11-24 04:40:53 +00:00 committed by ant-ob-hengtang
parent a666fa9757
commit 11b39c0ba5
1 changed files with 1 additions and 2 deletions
Show Stats 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,