From 22b80c55bf3251856c0eff143713311c7b635181 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Mon, 12 Jun 2023 10:27:22 +0800 Subject: [PATCH] refact code --- source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c b/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c index 00914f7d12..9aac10cf8f 100644 --- a/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c +++ b/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c @@ -1209,6 +1209,8 @@ _exit: } static int32_t tsdbDataFileDoWriteTombBlk(SDataFileWriter *writer) { + ASSERT(TARRAY2_SIZE(writer->tombBlkArray) == 0); + int32_t code = 0; int32_t lino = 0; @@ -1216,12 +1218,10 @@ static int32_t tsdbDataFileDoWriteTombBlk(SDataFileWriter *writer) { writer->tombFooter->tombBlkPtr->offset = writer->files[ftype].size; writer->tombFooter->tombBlkPtr->size = TARRAY2_DATA_LEN(writer->tombBlkArray); - if (writer->tombFooter->tombBlkPtr->size) { - code = tsdbWriteFile(writer->fd[ftype], writer->tombFooter->tombBlkPtr->offset, - (const uint8_t *)TARRAY2_DATA(writer->tombBlkArray), writer->tombFooter->tombBlkPtr->size); - TSDB_CHECK_CODE(code, lino, _exit); - writer->files[ftype].size += writer->tombFooter->tombBlkPtr->size; - } + code = tsdbWriteFile(writer->fd[ftype], writer->tombFooter->tombBlkPtr->offset, + (const uint8_t *)TARRAY2_DATA(writer->tombBlkArray), writer->tombFooter->tombBlkPtr->size); + TSDB_CHECK_CODE(code, lino, _exit); + writer->files[ftype].size += writer->tombFooter->tombBlkPtr->size; _exit: if (code) { -- GitLab