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

Disable page cache when read tmp file in direct load

Browse Source
This commit is contained in:
suz-yang 2024-02-19 07:19:57 +00:00 committed by ob-robot
parent d35d341522
commit fc6792c103
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/direct_load/ob_direct_load_tmp_file.cpp
View File

@ -246,6 +246,7 @@ int ObDirectLoadTmpFileIOHandle::pread(char *buf, int64_t size, int64_t offset)
io_info_.size_ = size;
io_info_.buf_ = buf;
io_info_.io_desc_.set_wait_event(ObWaitEventIds::DB_FILE_DATA_READ);
io_info_.disable_page_cache_ = true;
while (OB_SUCC(ret)) {
if (OB_FAIL(check_status())) {
LOG_WARN("fail to check status", KR(ret));
@ -282,6 +283,7 @@ int ObDirectLoadTmpFileIOHandle::write(char *buf, int64_t size)
io_info_.buf_ = buf;
io_info_.size_ = size;
io_info_.io_desc_.set_wait_event(ObWaitEventIds::DB_FILE_INDEX_BUILD_WRITE);
io_info_.disable_page_cache_ = false;
while (OB_SUCC(ret)) {
if (OB_FAIL(check_status())) {
LOG_WARN("fail to check status", KR(ret));
@ -335,6 +337,7 @@ int ObDirectLoadTmpFileIOHandle::aio_pread(char *buf, int64_t size, int64_t offs
io_info_.size_ = size;
io_info_.buf_ = buf;
io_info_.io_desc_.set_wait_event(ObWaitEventIds::DB_FILE_DATA_READ);
io_info_.disable_page_cache_ = true;
while (OB_SUCC(ret)) {
if (OB_FAIL(check_status())) {
LOG_WARN("fail to check status", KR(ret));
@ -371,6 +374,7 @@ int ObDirectLoadTmpFileIOHandle::aio_write(char *buf, int64_t size)
io_info_.size_ = size;
io_info_.buf_ = buf;
io_info_.io_desc_.set_wait_event(ObWaitEventIds::DB_FILE_INDEX_BUILD_WRITE);
io_info_.disable_page_cache_ = false;
while (OB_SUCC(ret)) {
if (OB_FAIL(check_status())) {
LOG_WARN("fail to check status", KR(ret));