xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

more refact

This commit is contained in:
Hongze Cheng 2022-05-09 06:30:45 +00:00
parent fba58c763f
commit ede0d49163
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/vnode/src/tsdb/tsdbMemTable2.c
View File

@ -204,13 +204,14 @@ int32_t tsdbInsertData2(SMemTable *pMemTb, int64_t version, const SVSubmitBlk *p
// do insert data to SMemData // do insert data to SMemData
SMemSkipListNode *forwards[SL_MAX_LEVEL]; SMemSkipListNode *forwards[SL_MAX_LEVEL];
SMemSkipListNode *pNode; SMemSkipListNode *pNode;
int32_t iRow;
STsdbRow tRow = {.version = version}; STsdbRow tRow = {.version = version};
SEncoder ec = {0}; SEncoder ec = {0};
SDecoder dc = {0}; SDecoder dc = {0};
tDecoderInit(&dc, pSubmitBlk->pData, pSubmitBlk->nData); tDecoderInit(&dc, pSubmitBlk->pData, pSubmitBlk->nData);
tsdbMemSkipListCursorInit(pMemTb->pSlc, &pMemData->sl); tsdbMemSkipListCursorInit(pMemTb->pSlc, &pMemData->sl);
for (;;) { for (iRow = 0;; iRow++) {
if (tDecodeIsEnd(&dc)) break; if (tDecodeIsEnd(&dc)) break;
// decode row // decode row