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

more code

This commit is contained in:
Hongze Cheng 2023-05-15 17:26:00 +08:00
parent 68f07c4bec
commit f8220e8b90
3 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/dnode/vnode/src/tsdb/dev/inc/tsdbFSet.h
View File

@ -58,9 +58,9 @@ typedef struct SSttLvl {
} SSttLvl;
struct STFileSet {
int32_t fid;
STFile *farr[TSDB_FTYPE_MAX]; // file array
SRBTree lvlTree; // level tree of .stt
int32_t fid;
STFileObj *farr[TSDB_FTYPE_MAX]; // file array
SRBTree lvlTree; // level tree of .stt
};
#ifdef __cplusplus

3
source/dnode/vnode/src/tsdb/dev/inc/tsdbFile.h
View File

@ -22,7 +22,8 @@
extern "C" {
#endif
typedef struct STFile STFile;
typedef struct STFile STFile;
typedef struct STFileObj STFileObj;
typedef enum {
TSDB_FTYPE_HEAD = 0, // .head

18
source/dnode/vnode/src/tsdb/dev/tsdbFSet.c
View File

@ -50,7 +50,7 @@ static int32_t add_file(STFileSet *fset, STFile *f) {
// lvl->nstt++;
// lvl->fstt = f;
} else {
fset->farr[f->type] = f;
// fset->farr[f->type] = f;
}
return 0;
@ -69,8 +69,8 @@ int32_t tsdbFileSetToJson(const STFileSet *fset, cJSON *json) {
continue;
}
code = tsdbTFileToJson(fset->farr[ftype], json);
if (code) return code;
// code = tsdbTFileToJson(fset->farr[ftype], json);
// if (code) return code;
}
// each level
@ -103,8 +103,8 @@ int32_t tsdbFileSetFromJson(const cJSON *json, STFileSet *fset) {
}
for (int32_t ftype = TSDB_FTYPE_MIN; ftype < TSDB_FTYPE_MAX; ++ftype) {
int32_t code = tsdbTFileFromJson(json, ftype, &fset->farr[ftype]);
if (code) return code;
// int32_t code = tsdbTFileFromJson(json, ftype, &fset->farr[ftype]->f);
// if (code) return code;
}
// each level
@ -131,11 +131,11 @@ int32_t tsdbFSetEdit(STFileSet *fset, const STFileOp *op) {
if (op->oState.size == 0) {
// create
STFile *f;
code = tsdbTFileCreate(&op->nState, &f);
if (code) return code;
// STFile *f;
// code = tsdbTFileCreate(&op->nState, &f);
// if (code) return code;
add_file(fset, f);
// add_file(fset, f);
} else if (op->nState.size == 0) {
// delete
} else {