From 040304870f07a0a1e2282c36d88dcfc8cfb91e1b Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 10 Jan 2023 04:41:53 +0000 Subject: [PATCH] Fix IOcallback omits ret code at write_extra_buf in process_block --- src/storage/blocksstable/ob_micro_block_cache.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/storage/blocksstable/ob_micro_block_cache.cpp b/src/storage/blocksstable/ob_micro_block_cache.cpp index bdcbed0d81..4cd4f9670a 100644 --- a/src/storage/blocksstable/ob_micro_block_cache.cpp +++ b/src/storage/blocksstable/ob_micro_block_cache.cpp @@ -425,8 +425,8 @@ int ObIMicroBlockIOCallback::process_block( block_buf + pos, block_size - pos))) { LOG_WARN("Fail to decompress data with preallocated buffer", K(ret)); - } else if (need_write_extra_buf_ && cache_->write_extra_buf(*read_info_, block_buf, block_size, extra_size, - block_buf + block_size, micro_data)) { + } else if (need_write_extra_buf_ && OB_FAIL(cache_->write_extra_buf(*read_info_, block_buf, block_size, + extra_size, block_buf + block_size, micro_data))) { LOG_WARN("Fail to writer extra buffer of block data", K(ret), K(header), KPC(cache_value)); } else if (FALSE_IT(micro_block = cache_value)) { } else if (OB_FAIL(kvcache->put_kvpair(inst_handle, kvpair, cache_handle, false /* overwrite */))) {