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

feat: tsdb multi-version

This commit is contained in:
Hongze Cheng 2022-05-31 10:20:58 +00:00
parent 6f10b88f58
commit 671f613c02
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/inc/tsdb.h
View File

@ -857,8 +857,8 @@ static FORCE_INLINE int tsdbUnLockFS(STsdbFS *pFs) {
} }
struct TSDBROW { struct TSDBROW {
int64_t version; int64_t version;
STSRow2 *pRow; STSRow2 tsRow;
}; };
struct TSDBKEY { struct TSDBKEY {

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

@ -81,6 +81,7 @@ int32_t tsdbInsertTableData2(STsdb *pTsdb, int64_t version, SVSubmitBlk *pSubmit
int32_t code = 0; int32_t code = 0;
SMemTable *pMemTable = (SMemTable *)pTsdb->mem; // TODO SMemTable *pMemTable = (SMemTable *)pTsdb->mem; // TODO
SMemData *pMemData; SMemData *pMemData;
TSDBROW row = {.version = version};
ASSERT(pMemTable); ASSERT(pMemTable);
@ -95,6 +96,15 @@ int32_t tsdbInsertTableData2(STsdb *pTsdb, int64_t version, SVSubmitBlk *pSubmit
} }
// do insert // do insert
uint32_t n = 0;
uint8_t *p = pSubmitBlk->pData;
while (n < pSubmitBlk->nData) {
n += tGetTSRow(p + n, &row.tsRow);
ASSERT(n <= pSubmitBlk->nData);
// TODO
}
return code; return code;