tglobal.h 7.4 KB
Newer Older
H
hzcheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

S
slguan 已提交
16 17
#ifndef TDENGINE_COMMON_GLOBAL_H
#define TDENGINE_COMMON_GLOBAL_H
H
hzcheng 已提交
18

H
Hongze Cheng 已提交
19 20
#include "taosdef.h"

H
hzcheng 已提交
21 22 23 24
#ifdef __cplusplus
extern "C" {
#endif

S
Shengliang Guan 已提交
25 26 27 28 29
// cluster
extern char     tsFirst[];
extern char     tsSecond[];
extern char     tsLocalFqdn[];
extern char     tsLocalEp[];
J
jtao1735 已提交
30
extern uint16_t tsServerPort;
S
slguan 已提交
31
extern uint16_t tsDnodeShellPort;
J
jtao1735 已提交
32
extern uint16_t tsDnodeDnodePort;
S
slguan 已提交
33
extern uint16_t tsSyncPort;
H
Hui Li 已提交
34
extern uint16_t tsArbitratorPort;
S
Shengliang Guan 已提交
35 36
extern int32_t  tsStatusInterval;
extern int32_t  tsNumOfMnodes;
S
Shengliang Guan 已提交
37 38
extern int8_t   tsEnableVnodeBak;
extern int8_t   tsEnableTelemetryReporting;
H
Hui Li 已提交
39
extern char     tsEmail[];
S
TD-2324  
Shengliang Guan 已提交
40
extern char     tsArbitrator[];
S
TD-2680  
Shengliang Guan 已提交
41
extern int8_t   tsArbOnline;
42
extern int64_t  tsArbOnlineTimestamp;
D
dapan1121 已提交
43
extern int32_t  tsDnodeId;
44
extern int64_t  tsDnodeStartTime;
S
Shengliang Guan 已提交
45 46 47 48

// common
extern int      tsRpcTimer;
extern int      tsRpcMaxTime;
张宏权 已提交
49
extern int      tsRpcForceTcp; // all commands go to tcp protocol if this is enabled
S
Shengliang Guan 已提交
50 51 52 53 54
extern int32_t  tsMaxConnections;
extern int32_t  tsMaxShellConns;
extern int32_t  tsShellActivityTimer;
extern uint32_t tsMaxTmrCtrl;
extern float    tsNumOfThreadsPerCore;
S
TD-2067  
Shengliang Guan 已提交
55
extern int32_t  tsNumOfCommitThreads;
56
extern float    tsRatioOfQueryCores;
S
Shengliang Guan 已提交
57
extern int8_t   tsDaylight;
S
Shengliang Guan 已提交
58 59
extern char     tsTimezone[];
extern char     tsLocale[];
H
Haojun Liao 已提交
60
extern char     tsCharset[];            // default encode string
S
Shengliang Guan 已提交
61
extern int8_t   tsEnableCoreFile;
S
Shengliang Guan 已提交
62
extern int32_t  tsCompressMsgSize;
63
extern int32_t  tsCompressColData;
64
extern int32_t  tsMaxNumOfDistinctResults;
65
extern char     tsTempDir[];
S
Shengliang Guan 已提交
66

H
Haojun Liao 已提交
67
//query buffer management
68 69
extern int32_t  tsQueryBufferSize;      // maximum allowed usage buffer size in MB for each data node during query processing
extern int64_t  tsQueryBufferSizeBytes; // maximum allowed usage buffer size in byte for each data node during query processing
70 71
extern int32_t  tsRetrieveBlockingModel;// retrieve threads will be blocked

S
Shengliang Guan 已提交
72
extern int8_t   tsKeepOriginalColumnName;
H
Haojun Liao 已提交
73

S
Shengliang Guan 已提交
74 75
// client
extern int32_t tsMaxSQLStringLen;
76
extern int32_t tsMaxWildCardsLen;
77
extern int32_t tsMaxRegexStringLen;
S
Shengliang Guan 已提交
78
extern int8_t  tsTscEnableRecordSql;
S
Shengliang Guan 已提交
79 80 81 82 83
extern int32_t tsMaxNumOfOrderedResults;
extern int32_t tsMinSlidingTime;
extern int32_t tsMinIntervalTime;
extern int32_t tsMaxStreamComputDelay;
extern int32_t tsStreamCompStartDelay;
84
extern int32_t tsRetryStreamCompDelay;
S
Shengliang Guan 已提交
85 86 87
extern float   tsStreamComputDelayRatio;  // the delayed computing ration of the whole time window
extern int32_t tsProjectExecInterval;
extern int64_t tsMaxRetentWindow;
H
hzcheng 已提交
88

S
Shengliang Guan 已提交
89
// db parameters in client
S
slguan 已提交
90
extern int32_t tsCacheBlockSize;
H
hjxilinx 已提交
91
extern int32_t tsBlocksPerVnode;
92
extern int32_t tsMinTablePerVnode;
H
hjxilinx 已提交
93
extern int32_t tsMaxTablePerVnode;
94
extern int32_t tsTableIncStepPerVnode;
95
extern int32_t tsMaxVgroupsPerDb;
S
slguan 已提交
96 97
extern int16_t tsDaysPerFile;
extern int32_t tsDaysToKeep;
S
slguan 已提交
98 99
extern int32_t tsMinRowsInFileBlock;
extern int32_t tsMaxRowsInFileBlock;
S
slguan 已提交
100 101
extern int16_t tsCommitTime;  // seconds
extern int32_t tsTimePrecision;
S
TD-1207  
Shengliang Guan 已提交
102 103
extern int8_t  tsCompression;
extern int8_t  tsWAL;
陶建辉(Jeff)'s avatar
陶建辉(Jeff) 已提交
104
extern int32_t tsFsyncPeriod;
S
slguan 已提交
105
extern int32_t tsReplications;
S
Shengliang Guan 已提交
106
extern int16_t tsPartitons;
107
extern int32_t tsQuorum;
S
Shengliang Guan 已提交
108
extern int8_t  tsUpdate;
S
Shengliang Guan 已提交
109
extern int8_t  tsCacheLastRow;
S
slguan 已提交
110

Y
yihaoDeng 已提交
111 112 113
//tsdb 
extern bool tsdbForceKeepFile;

S
Shengliang Guan 已提交
114
// balance
S
Shengliang Guan 已提交
115 116
extern int8_t  tsEnableBalance;
extern int8_t  tsAlternativeRole;
S
slguan 已提交
117
extern int32_t tsBalanceInterval;
S
slguan 已提交
118
extern int32_t tsOfflineThreshold;
119
extern int32_t tsMnodeEqualVnodeNum;
S
Shengliang Guan 已提交
120 121 122
extern int8_t  tsEnableFlowCtrl;
extern int8_t  tsEnableSlaveQuery;
extern int8_t  tsEnableAdjustMaster;
S
slguan 已提交
123

S
Shengliang Guan 已提交
124
// restful
S
Shengliang Guan 已提交
125
extern int8_t   tsEnableHttpModule;
S
Shengliang Guan 已提交
126
extern int32_t  tsRestRowLimit;
L
lihui 已提交
127
extern uint16_t tsHttpPort;
S
slguan 已提交
128 129 130
extern int32_t  tsHttpCacheSessions;
extern int32_t  tsHttpSessionExpire;
extern int32_t  tsHttpMaxThreads;
S
Shengliang Guan 已提交
131 132 133
extern int8_t   tsHttpEnableCompress;
extern int8_t   tsHttpEnableRecordSql;
extern int8_t   tsTelegrafUseFieldNum;
134
extern int8_t   tsHttpDbNameMandatory;
S
slguan 已提交
135

S
Shengliang Guan 已提交
136
// mqtt
S
Shengliang Guan 已提交
137 138 139 140 141 142 143
extern int8_t tsEnableMqttModule;
extern char   tsMqttHostName[];
extern char   tsMqttPort[];
extern char   tsMqttUser[];
extern char   tsMqttPass[];
extern char   tsMqttClientId[];
extern char   tsMqttTopic[];
S
Shengliang Guan 已提交
144 145

// monitor
S
Shengliang Guan 已提交
146
extern int8_t  tsEnableMonitorModule;
S
Shengliang Guan 已提交
147 148 149 150
extern char    tsMonitorDbName[];
extern char    tsInternalPass[];
extern int32_t tsMonitorInterval;

151
// stream
S
Shengliang Guan 已提交
152
extern int8_t tsEnableStream;
153

S
Shengliang Guan 已提交
154
// internal
155
extern int8_t  tsCompactMnodeWal;
S
Shengliang Guan 已提交
156 157
extern int8_t  tsPrintAuth;
extern int8_t  tscEmbedded;
S
Shengliang Guan 已提交
158 159 160 161
extern char    configDir[];
extern char    tsVnodeDir[];
extern char    tsDnodeDir[];
extern char    tsMnodeDir[];
162 163
extern char    tsMnodeBakDir[];
extern char    tsMnodeTmpDir[];
S
Shengliang Guan 已提交
164 165 166
extern char    tsDataDir[];
extern char    tsLogDir[];
extern char    tsScriptDir[];
167
extern int64_t tsTickPerDay[3];
168
extern int32_t tsTopicBianryLen;
S
Shengliang Guan 已提交
169 170 171 172 173 174 175 176 177 178 179

// system info
extern char    tsOsName[];
extern int64_t tsPageSize;
extern int64_t tsOpenMax;
extern int64_t tsStreamMax;
extern int32_t tsNumOfCores;
extern float   tsTotalLogDirGB;
extern float   tsTotalTmpDirGB;
extern float   tsTotalDataDirGB;
extern float   tsAvailLogDirGB;
H
Haojun Liao 已提交
180
extern float   tsAvailTmpDirectorySpace;
S
Shengliang Guan 已提交
181
extern float   tsAvailDataDirGB;
182
extern float   tsUsedDataDirGB;
S
Shengliang Guan 已提交
183
extern float   tsMinimalLogDirGB;
H
Haojun Liao 已提交
184
extern float   tsReservedTmpDirectorySpace;
S
Shengliang Guan 已提交
185 186
extern float   tsMinimalDataDirGB;
extern int32_t tsTotalMemoryMB;
187
extern uint32_t tsVersion;
S
slguan 已提交
188

S
Shengliang Guan 已提交
189 190 191 192 193 194
// build info
extern char version[];
extern char compatible_version[];
extern char gitinfo[];
extern char gitinfoOfInternal[];
extern char buildinfo[];
S
slguan 已提交
195

S
Shengliang Guan 已提交
196
// log
S
Shengliang Guan 已提交
197
extern int8_t  tsAsyncLog;
S
slguan 已提交
198
extern int32_t tsNumOfLogLines;
199
extern int32_t tsLogKeepDays;
200 201
extern int32_t dDebugFlag;
extern int32_t vDebugFlag;
guanshengliang's avatar
guanshengliang 已提交
202
extern int32_t mDebugFlag;
H
Haojun Liao 已提交
203
extern uint32_t cDebugFlag;
guanshengliang's avatar
guanshengliang 已提交
204
extern int32_t jniDebugFlag;
S
slguan 已提交
205 206 207
extern int32_t tmrDebugFlag;
extern int32_t sdbDebugFlag;
extern int32_t httpDebugFlag;
208
extern int32_t mqttDebugFlag;
S
Shengliang Guan 已提交
209
extern int32_t monDebugFlag;
S
slguan 已提交
210 211
extern int32_t uDebugFlag;
extern int32_t rpcDebugFlag;
guanshengliang's avatar
guanshengliang 已提交
212
extern int32_t odbcDebugFlag;
213
extern uint32_t qDebugFlag;
S
Shengliang Guan 已提交
214
extern int32_t wDebugFlag;
S
TD-1520  
Shengliang Guan 已提交
215
extern int32_t cqDebugFlag;
216
extern int32_t debugFlag;
H
hzcheng 已提交
217

T
tickduan 已提交
218
#ifdef TD_TSZ
219
// lossy
T
tickduan 已提交
220 221 222
extern char lossyColumns[];
extern double fPrecision;
extern double dPrecision;
T
tickduan 已提交
223
extern uint32_t maxRange;
T
tickduan 已提交
224
extern uint32_t curRange;
T
tickduan 已提交
225
extern char Compressor[];
226
#endif
227
// long query
228
extern int8_t tsDeadLockKillQuery;
T
tickduan 已提交
229

230 231 232
// schemaless
extern char tsSmlDefaultJSONStrType[];

S
TD-1767  
Shengliang Guan 已提交
233 234 235 236 237 238 239 240
typedef struct {
  char dir[TSDB_FILENAME_LEN];
  int  level;
  int  primary;
} SDiskCfg;
extern int32_t  tsDiskCfgNum;
extern SDiskCfg tsDiskCfg[];

H
hjxilinx 已提交
241 242
#define NEEDTO_COMPRESSS_MSG(size) (tsCompressMsgSize != -1 && (size) > tsCompressMsgSize)

H
Hongze Cheng 已提交
243 244 245 246 247 248 249 250 251
void    taosInitGlobalCfg();
int32_t taosCheckGlobalCfg();
void    taosSetAllDebugFlag();
bool    taosCfgDynamicOptions(char *msg);
int     taosGetFqdnPortFromEp(const char *ep, char *fqdn, uint16_t *port);
bool    taosCheckBalanceCfgOptions(const char *option, int32_t *vnodeId, int32_t *dnodeId);
void    taosAddDataDir(int index, char *v1, int level, int primary);
void    taosReadDataDirCfg(char *v1, char *v2, char *v3);
void    taosPrintDataDirCfg();
S
TD-1767  
Shengliang Guan 已提交
252

H
hzcheng 已提交
253 254 255 256
#ifdef __cplusplus
}
#endif

S
slguan 已提交
257
#endif