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

fix: int ObTmpFileFlushTask::lazy_alloc_and_fill_block_buf_for_data_page_

Browse Source
This commit is contained in:
obdev 2024-09-18 08:40:16 +00:00 committed by ob-robot
parent 2efc3d2e63
commit 2fbb508408
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/storage/tmp_file/ob_tmp_file_flush_ctx.cpp
View File

@ -353,19 +353,9 @@ int ObTmpFileFlushTask::lazy_alloc_and_fill_block_buf_for_data_page_()
} else {
// only copy the size we recorded if we need to flush the last page
// since we do not hold last_page_lock and the last page may be appended
int64_t copy_size = ObTmpFileGlobal::PAGE_SIZE;
if (flush_info.file_size_ != 0) {
if (cur_info_disk_begin_id + cur_info_page_num - 1 != copy_index) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("invalid flush info",
KR(ret), K(cur_info_disk_begin_id), K(cur_info_page_num), K(copy_index), K(flush_info), KPC(this));
} else {
copy_size = flush_info.file_size_ % ObTmpFileGlobal::PAGE_SIZE;
}
}
if (OB_SUCC(ret)) {
MEMCPY(get_data_buf() + copy_index * ObTmpFileGlobal::PAGE_SIZE, page_buf, copy_size);
}
int64_t copy_size = flush_info.file_size_ != 0 && cur_info_disk_begin_id + cur_info_page_num - 1 == copy_index ?
flush_info.file_size_ % ObTmpFileGlobal::PAGE_SIZE : ObTmpFileGlobal::PAGE_SIZE;
MEMCPY(get_data_buf() + copy_index * ObTmpFileGlobal::PAGE_SIZE, page_buf, copy_size);
}
copy_index += 1;
cur_info_virtual_page_id += 1;