From 8c74dc19a2275c5738cbb70476c511a2f9733420 Mon Sep 17 00:00:00 2001 From: Tyshawn Date: Sun, 31 Jul 2022 20:30:27 +0800 Subject: [PATCH] [CP] [CP][BUG.FIX] fix eating return code in tmp file. --- src/storage/blocksstable/ob_tmp_file.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/storage/blocksstable/ob_tmp_file.cpp b/src/storage/blocksstable/ob_tmp_file.cpp index bd97e7e05a..7d9d602815 100644 --- a/src/storage/blocksstable/ob_tmp_file.cpp +++ b/src/storage/blocksstable/ob_tmp_file.cpp @@ -621,7 +621,7 @@ int ObTmpFile::aio_read_without_lock(const ObTmpFileIOInfo &io_info, int64_t &of ret = OB_ITER_END; } else if (OB_FAIL(handle.prepare_read(io_info.size_, offset, io_info.io_desc_, io_info.buf_, this))) { STORAGE_LOG(WARN, "fail to prepare read io handle", K(ret), K(io_info), K(offset)); - } else if (once_aio_read_batch_without_lock(io_info, offset, handle)) { + } else if (OB_FAIL(once_aio_read_batch_without_lock(io_info, offset, handle))) { STORAGE_LOG(WARN, "fail to read one batch", K(ret), K(offset), K(handle)); } else { handle.set_last_read_offset(offset); @@ -648,7 +648,7 @@ int ObTmpFile::once_aio_read_batch( STORAGE_LOG(WARN, "unexpected error, null tmp file extent", K(ret), KP(tmp), K(io_info)); } else if (OB_UNLIKELY(remain_size > 0 && offset >= tmp->get_global_end())) { ret = OB_ITER_END; - } else if (once_aio_read_batch_without_lock(io_info, offset, handle)) { + } else if (OB_FAIL(once_aio_read_batch_without_lock(io_info, offset, handle))) { STORAGE_LOG(WARN, "fail to read one batch", K(ret), K(offset), K(handle)); } else { handle.set_last_read_offset(offset); -- GitLab