From 49e7c002bb14cb657907e8765895f5282642745d Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Tue, 29 Nov 2022 16:37:48 +0800 Subject: [PATCH] refact more code --- source/dnode/vnode/src/tsdb/tsdbMemTable.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbMemTable.c b/source/dnode/vnode/src/tsdb/tsdbMemTable.c index 274047e61d..6bb4111be5 100644 --- a/source/dnode/vnode/src/tsdb/tsdbMemTable.c +++ b/source/dnode/vnode/src/tsdb/tsdbMemTable.c @@ -541,17 +541,17 @@ _exit: static int32_t tsdbInsertTableDataImpl(SMemTable *pMemTable, STbData *pTbData, int64_t version, SSubmitTbData *pSubmitTbData, SSubmitBlkRsp *pRsp) { int32_t code = 0; - // SSubmitBlkIter blkIter = {0}; + + SRow **rows = (SRow **)TARRAY_DATA(pSubmitTbData->aRowP); TSDBKEY key = {.version = version}; SMemSkipListNode *pos[SL_MAX_LEVEL]; TSDBROW row = tsdbRowFromTSRow(version, NULL); - int32_t nRow = taosArrayGetSize(pSubmitTbData->aRowP); + int32_t nRow = TARRAY_SIZE(pSubmitTbData->aRowP); int32_t iRow = 0; SRow *pLastRow = NULL; // backward put first data - row.pTSRow = taosArrayGetP(pSubmitTbData->aRowP, iRow); - + row.pTSRow = rows[iRow]; key.ts = row.pTSRow->ts; iRow++; tbDataMovePosTo(pTbData, pos, &key, SL_MOVE_BACKWARD); @@ -571,7 +571,7 @@ static int32_t tsdbInsertTableDataImpl(SMemTable *pMemTable, STbData *pTbData, i } while (iRow < nRow) { - row.pTSRow = taosArrayGetP(pSubmitTbData->aRowP, iRow); + row.pTSRow = rows[iRow]; key.ts = row.pTSRow->ts; if (SL_NODE_FORWARD(pos[0], 0) != pTbData->sl.pTail) {