refact
This commit is contained in:
parent
895607f0cb
commit
370857f331
|
@ -68,9 +68,9 @@ typedef struct {
|
||||||
typedef struct {
|
typedef struct {
|
||||||
int version; // version
|
int version; // version
|
||||||
int numOfCols; // Number of columns appended
|
int numOfCols; // Number of columns appended
|
||||||
int tlen; // maximum length of a SDataRow without the header part
|
int tlen; // maximum length of a SDataRow without the header part (sizeof(VarDataOffsetT) + sizeof(VarDataLenT) + (bytes))
|
||||||
uint16_t flen; // First part length in a SDataRow after the header part
|
uint16_t flen; // First part length in a SDataRow after the header part
|
||||||
uint16_t vlen; // pure value part length, excluded the overhead
|
uint16_t vlen; // pure value part length, excluded the overhead (bytes only)
|
||||||
STColumn columns[];
|
STColumn columns[];
|
||||||
} STSchema;
|
} STSchema;
|
||||||
|
|
||||||
|
|
|
@ -31,7 +31,7 @@ typedef struct {
|
||||||
|
|
||||||
static void *tsdbLoopCommit(void *arg);
|
static void *tsdbLoopCommit(void *arg);
|
||||||
|
|
||||||
SCommitQueue tsCommitQueue = {0};
|
static SCommitQueue tsCommitQueue = {0};
|
||||||
|
|
||||||
int tsdbInitCommitQueue() {
|
int tsdbInitCommitQueue() {
|
||||||
int nthreads = tsNumOfCommitThreads;
|
int nthreads = tsNumOfCommitThreads;
|
||||||
|
|
Loading…
Reference in New Issue