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-04-23 18:00:02 +08:00
parent 651ca6aca2
commit 50319f2630
3 changed files with 31 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
source/dnode/vnode/src/tsdb/dev/inc/tsdbDataFReaderWriter.h
View File

@ -23,10 +23,22 @@ extern "C" {
#endif
// SDataFileReader =============================================
typedef struct SDataFileReader SDataFileReader;
typedef struct SDataFileReader SDataFileReader;
typedef struct SDataFileReaderConfig SDataFileReaderConfig;
// SDataFileWriter =============================================
typedef struct SDataFileWriter SDataFileWriter;
typedef struct SDataFileWriter SDataFileWriter;
typedef struct SDataFileWriterConfig SDataFileWriterConfig;
struct SDataFileReaderConfig {
STsdb *pTsdb;
// TODO
};
struct SDataFileWriterConfig {
STsdb *pTsdb;
// TODO
};
#ifdef __cplusplus
}

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

@ -27,9 +27,9 @@ typedef struct SFileOp SFileOp;
typedef struct SSttLvl SSttLvl;
typedef enum {
TSDB_FOP_EXTEND = -2,
TSDB_FOP_NONE = 0,
TSDB_FOP_EXTEND,
TSDB_FOP_CREATE,
TSDB_FOP_NONE,
TSDB_FOP_DELETE,
TSDB_FOP_TRUNCATE,
} tsdb_fop_t;
@ -47,17 +47,17 @@ struct SFileOp {
};
struct SSttLvl {
int32_t level;
int32_t nStt;
struct STFile *fSttList;
int32_t level;
int32_t nStt;
STFile *fSttList;
LISTD(SSttLvl) listNode;
};
struct SFileSet {
int32_t fid;
int64_t nextid;
struct STFile *farr[TSDB_FTYPE_MAX]; // file array
SSttLvl lvl0; // level 0 of .stt
int32_t fid;
int64_t nextid;
STFile *farr[TSDB_FTYPE_MAX]; // file array
SSttLvl lvl0; // level 0 of .stt
};
#ifdef __cplusplus

15
source/dnode/vnode/src/tsdb/dev/tsdbDataFReaderWriter.c
View File

@ -15,11 +15,12 @@
#include "dev.h"
// struct SDataFReader {
// STsdb *pTsdb;
// // TODO
// };
// SDataFileReader =============================================
struct SDataFileReader {
// TODO
};
// struct SDataFWriter {
// STsdb *pTsdb;
// };
// SDataFileWriter =============================================
struct SDataFileWriter {
// TODO
};