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

minor changes

This commit is contained in:
Shengliang Guan 2021-11-05 16:04:02 +08:00
parent 88d7b970ae
commit 248cdbbc2a
3 changed files with 23 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
include/common/taosmsg.h
View File

@ -697,8 +697,9 @@ typedef struct {
} SStatusRsp; } SStatusRsp;
typedef struct { typedef struct {
uint16_t port; int32_t id;
char fqdn[TSDB_FQDN_LEN]; uint16_t port; // node sync Port
char fqdn[TSDB_FQDN_LEN]; // node FQDN
} SReplica; } SReplica;
typedef struct { typedef struct {
@ -719,8 +720,8 @@ typedef struct {
int8_t cacheLastRow; int8_t cacheLastRow;
int8_t update; int8_t update;
int8_t walLevel; int8_t walLevel;
int8_t replica;
int8_t quorum; int8_t quorum;
int8_t replica;
int8_t selfIndex; int8_t selfIndex;
SReplica replicas[TSDB_MAX_REPLICA]; SReplica replicas[TSDB_MAX_REPLICA];
} SCreateVnodeMsg, SAlterVnodeMsg; } SCreateVnodeMsg, SAlterVnodeMsg;

1
include/server/mnode/mnode.h
View File

@ -26,6 +26,7 @@ typedef struct SMnodeMsg SMnodeMsg;
typedef struct { typedef struct {
int8_t replica; int8_t replica;
int8_t selfIndex;
SReplica replicas[TSDB_MAX_REPLICA]; SReplica replicas[TSDB_MAX_REPLICA];
} SMnodeCfg; } SMnodeCfg;

35
include/server/vnode/vnode.h
View File

@ -27,23 +27,24 @@ extern "C" {
typedef struct SVnode SVnode; typedef struct SVnode SVnode;
typedef struct { typedef struct {
char db[TSDB_FULL_DB_NAME_LEN]; char db[TSDB_FULL_DB_NAME_LEN];
int32_t cacheBlockSize; // MB int32_t cacheBlockSize; // MB
int32_t totalBlocks; int32_t totalBlocks;
int32_t daysPerFile; int32_t daysPerFile;
int32_t daysToKeep0; int32_t daysToKeep0;
int32_t daysToKeep1; int32_t daysToKeep1;
int32_t daysToKeep2; int32_t daysToKeep2;
int32_t minRowsPerFileBlock; int32_t minRowsPerFileBlock;
int32_t maxRowsPerFileBlock; int32_t maxRowsPerFileBlock;
int8_t precision; // time resolution int8_t precision; // time resolution
int8_t compression; int8_t compression;
int8_t cacheLastRow; int8_t cacheLastRow;
int8_t update; int8_t update;
int8_t quorum; int8_t quorum;
int8_t replica; int8_t replica;
int8_t walLevel; int8_t selfIndex;
int32_t fsyncPeriod; // millisecond int8_t walLevel;
int32_t fsyncPeriod; // millisecond
SReplica replicas[TSDB_MAX_REPLICA]; SReplica replicas[TSDB_MAX_REPLICA];
} SVnodeCfg; } SVnodeCfg;