more

source/dnode/vnode/src/inc/tsdb.h

@@ -518,6 +518,12 @@ struct SRowMerger {
   SArray   *pArray;  // SArray<SColVal>
 };
 
+struct STsdbFSState {
+  SDelFile *pDelFile;
+  SArray   *aDFileSet;  // SArray<aDFileSet>
+  SDelFile  delFile;
+};
+
 struct STsdbFS {
   STsdb         *pTsdb;
   TdThreadRwlock lock;

source/dnode/vnode/src/tsdb/tsdbCommit.c

@@ -735,6 +735,9 @@ static int32_t tsdbCommitMemoryData(SCommitter *pCommitter, STbData *pTbData) {
     code = tBlockDataAppendRow(pBlockData, pRow, NULL);
     if (code) goto _err;
 
+    pBlock->minVersion = TMIN(pBlock->minVersion, tsdbRowKey(pRow).version);
+    pBlock->maxVersion = TMAX(pBlock->maxVersion, tsdbRowKey(pRow).version);
+
     tsdbTbDataIterNext(pIter);
     pRow = tsdbTbDataIterGet(pIter);
 
@@ -743,6 +746,10 @@ static int32_t tsdbCommitMemoryData(SCommitter *pCommitter, STbData *pTbData) {
     }
   }
 
+  if (pBlockData->nRow > 0) {
+    // write the block to file
+  }
+
 _exit:
   if (pRow) {
     pCommitter->nextKey = TMIN(pCommitter->nextKey, tsdbRowKey(pRow).ts);

source/dnode/vnode/src/tsdb/tsdbFS.c

@@ -15,12 +15,6 @@
 
 #include "tsdb.h"
 
-struct STsdbFSState {
-  SDelFile *pDelFile;
-  SArray   *aDFileSet;  // SArray<aDFileSet>
-  SDelFile  delFile;
-};
-
 // =================================================================================================
 static int32_t tsdbDelFileToJson(const void *pObj, SJson *pJson) {
   int32_t   code = 0;