more cases

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

@@ -680,7 +680,7 @@ static int32_t fset_cmpr_fn(const struct STFileSet *pSet1, const struct STFileSe
   return 0;
 }
 
-static int32_t edit_fs(STFileSystem *fs, const TFileOpArray *opArray) {
+static int32_t edit_fs(STFileSystem *fs, const TFileOpArray *opArray, EFEditT etype) {
   int32_t code = 0;
   int32_t lino = 0;
 
@@ -690,6 +690,8 @@ static int32_t edit_fs(STFileSystem *fs, const TFileOpArray *opArray) {
   TFileSetArray  *fsetArray = fs->fSetArrTmp;
   STFileSet      *fset = NULL;
   const STFileOp *op;
+  int32_t         fid = INT32_MIN;
+  TSKEY           now = taosGetTimestampMs();
   TARRAY2_FOREACH_PTR(opArray, op) {
     if (!fset || fset->fid != op->fid) {
       STFileSet tfset = {.fid = op->fid};
@@ -708,6 +710,15 @@ static int32_t edit_fs(STFileSystem *fs, const TFileOpArray *opArray) {
 
     code = tsdbTFileSetEdit(fs->tsdb, fset, op);
     TSDB_CHECK_CODE(code, lino, _exit);
+
+    if (fid != op->fid) {
+      fid = op->fid;
+      if (etype == TSDB_FEDIT_COMMIT) {
+        fset->lastCommit = now;
+      } else if (etype == TSDB_FEDIT_COMPACT) {
+        fset->lastCompact = now;
+      }
+    }
   }
 
   // remove empty empty stt level and empty file set
@@ -864,7 +875,7 @@ int32_t tsdbFSEditBegin(STFileSystem *fs, const TFileOpArray *opArray, EFEditT e
   fs->etype = etype;
 
   // edit
-  code = edit_fs(fs, opArray);
+  code = edit_fs(fs, opArray, etype);
   TSDB_CHECK_CODE(code, lino, _exit);
 
   // save fs
@@ -1288,6 +1299,12 @@ int32_t tsdbFileSetReaderOpen(void *pVnode, struct SFileSetReader **ppReader) {
   return TSDB_CODE_SUCCESS;
 }
 
+extern bool tsdbShouldCompact(const STFileSet *pFileSet);
+
+#ifndef TD_ENTERPRISE
+bool tsdbShouldCompact(const STFileSet *pFileSet) { return false; }
+#endif
+
 static int32_t tsdbFileSetReaderNextNoLock(struct SFileSetReader *pReader) {
   STsdb  *pTsdb = pReader->pTsdb;
   int32_t code = TSDB_CODE_SUCCESS;
@@ -1311,7 +1328,7 @@ static int32_t tsdbFileSetReaderNextNoLock(struct SFileSetReader *pReader) {
   // get file set details
   pReader->fid = pReader->pFileSet->fid;
   tsdbFidKeyRange(pReader->fid, pTsdb->keepCfg.days, pTsdb->keepCfg.precision, &pReader->startTime, &pReader->endTime);
-  pReader->lastCompactTime = 0;  // TODO
+  pReader->lastCompactTime = pReader->pFileSet->lastCompact;
   pReader->totalSize = 0;
   for (int32_t i = 0; i < TSDB_FTYPE_MAX; i++) {
     STFileObj *fobj = pReader->pFileSet->farr[i];
@@ -1375,7 +1392,7 @@ int32_t tsdbFileSetGetEntryField(struct SFileSetReader *pReader, const char *fie
 
   fieldName = "should_compact";
   if (strncmp(field, fieldName, strlen(fieldName) + 1) == 0) {
-    *(char *)value = 0;  // TODO
+    *(char *)value = tsdbShouldCompact(pReader->pFileSet);
     return TSDB_CODE_SUCCESS;
   }
 

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

@@ -273,6 +273,15 @@ int32_t tsdbTFileSetToJson(const STFileSet *fset, cJSON *json) {
     if (code) return code;
   }
 
+  // about compact and commit
+  if (cJSON_AddNumberToObject(json, "last compact", fset->lastCompact) == NULL) {
+    return TSDB_CODE_OUT_OF_MEMORY;
+  }
+
+  if (cJSON_AddNumberToObject(json, "last commit", fset->lastCommit) == NULL) {
+    return TSDB_CODE_OUT_OF_MEMORY;
+  }
+
   return 0;
 }
 
@@ -324,6 +333,20 @@ int32_t tsdbJsonToTFileSet(STsdb *pTsdb, const cJSON *json, STFileSet **fset) {
   } else {
     return TSDB_CODE_FILE_CORRUPTED;
   }
+  // about compact and commit
+  item1 = cJSON_GetObjectItem(json, "last compact");
+  if (cJSON_IsNumber(item1)) {
+    (*fset)->lastCompact = item1->valuedouble;
+  } else {
+    (*fset)->lastCompact = 0;
+  }
+
+  item1 = cJSON_GetObjectItem(json, "last commit");
+  if (cJSON_IsNumber(item1)) {
+    (*fset)->lastCommit = item1->valuedouble;
+  } else {
+    (*fset)->lastCommit = 0;
+  }
 
   return 0;
 }
@@ -467,6 +490,9 @@ int32_t tsdbTFileSetApplyEdit(STsdb *pTsdb, const STFileSet *fset1, STFileSet *f
     }
   }
 
+  fset2->lastCompact = fset1->lastCompact;
+  fset2->lastCommit = fset1->lastCommit;
+
   return 0;
 }
 
@@ -522,6 +548,9 @@ int32_t tsdbTFileSetInitCopy(STsdb *pTsdb, const STFileSet *fset1, STFileSet **f
     if (code) return code;
   }
 
+  (*fset)->lastCompact = fset1->lastCompact;
+  (*fset)->lastCommit = fset1->lastCommit;
+
   return 0;
 }
 
@@ -617,6 +646,9 @@ int32_t tsdbTFileSetInitRef(STsdb *pTsdb, const STFileSet *fset1, STFileSet **fs
     }
   }
 
+  (*fset)->lastCompact = fset1->lastCompact;
+  (*fset)->lastCommit = fset1->lastCommit;
+
   return 0;
 }
 

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

@@ -92,6 +92,8 @@ struct STFileSet {
   int64_t      maxVerValid;
   STFileObj   *farr[TSDB_FTYPE_MAX];  // file array
   TSttLvlArray lvlArr[1];             // level array
+  TSKEY        lastCompact;
+  TSKEY        lastCommit;
 
   bool      mergeScheduled;
   SVATaskID mergeTask;