tglobal.h 6.0 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/>.
 */

16 17
#ifndef _TD_COMMON_GLOBAL_H_
#define _TD_COMMON_GLOBAL_H_
H
Hongze Cheng 已提交
18

S
Shengliang Guan 已提交
19
#include "tarray.h"
20
#include "tconfig.h"
21
#include "tdef.h"
S
Shengliang Guan 已提交
22

H
hzcheng 已提交
23 24 25 26
#ifdef __cplusplus
extern "C" {
#endif

D
dapan1121 已提交
27 28 29 30 31 32
#define SLOW_LOG_TYPE_QUERY  0x1
#define SLOW_LOG_TYPE_INSERT 0x2
#define SLOW_LOG_TYPE_OTHERS 0x4
#define SLOW_LOG_TYPE_ALL    0xFFFFFFFF


S
Shengliang Guan 已提交
33
// cluster
S
Shengliang Guan 已提交
34 35 36 37 38 39 40
extern char     tsFirst[];
extern char     tsSecond[];
extern char     tsLocalFqdn[];
extern char     tsLocalEp[];
extern uint16_t tsServerPort;
extern int32_t  tsVersion;
extern int32_t  tsStatusInterval;
41
extern int32_t  tsNumOfSupportVnodes;
S
Shengliang Guan 已提交
42

S
Shengliang Guan 已提交
43
// common
S
Shengliang Guan 已提交
44 45 46 47 48 49 50
extern int32_t tsMaxShellConns;
extern int32_t tsShellActivityTimer;
extern int32_t tsCompressMsgSize;
extern int32_t tsCompressColData;
extern int32_t tsMaxNumOfDistinctResults;
extern int32_t tsCompatibleModel;
extern bool    tsPrintAuth;
51
extern int64_t tsTickPerMin[3];
52
extern int32_t tsCountAlwaysReturnValue;
H
Haojun Liao 已提交
53 54
extern float   tsSelectivityRatio;
extern int32_t tsTagFilterResCacheSize;
55

S
Shengliang Guan 已提交
56 57
// queue & threads
extern int32_t tsNumOfRpcThreads;
dengyihao's avatar
dengyihao 已提交
58
extern int32_t tsNumOfRpcSessions;
dengyihao's avatar
dengyihao 已提交
59
extern int32_t tsTimeToGetAvailableConn;
S
Shengliang Guan 已提交
60 61
extern int32_t tsNumOfCommitThreads;
extern int32_t tsNumOfTaskQueueThreads;
S
Shengliang Guan 已提交
62
extern int32_t tsNumOfMnodeQueryThreads;
D
dapan1121 已提交
63
extern int32_t tsNumOfMnodeFetchThreads;
S
Shengliang Guan 已提交
64 65
extern int32_t tsNumOfMnodeReadThreads;
extern int32_t tsNumOfVnodeQueryThreads;
66
extern float   tsRatioOfVnodeStreamThreads;
S
Shengliang Guan 已提交
67
extern int32_t tsNumOfVnodeFetchThreads;
C
Cary Xu 已提交
68
extern int32_t tsNumOfVnodeRsmaThreads;
S
Shengliang Guan 已提交
69 70
extern int32_t tsNumOfQnodeQueryThreads;
extern int32_t tsNumOfQnodeFetchThreads;
L
Liu Jicong 已提交
71 72
extern int32_t tsNumOfSnodeStreamThreads;
extern int32_t tsNumOfSnodeWriteThreads;
73
extern int64_t tsRpcQueueMemoryAllowed;
S
Shengliang Guan 已提交
74

75 76 77 78 79
// sync raft
extern int32_t tsElectInterval;
extern int32_t tsHeartbeatInterval;
extern int32_t tsHeartbeatTimeout;

80 81 82
// vnode
extern int64_t tsVndCommitMaxIntervalMs;

83 84
// mnode
extern int64_t tsMndSdbWriteDelta;
85
extern int64_t tsMndLogRetention;
86

S
monitor  
Shengliang Guan 已提交
87 88 89 90 91
// monitor
extern bool     tsEnableMonitor;
extern int32_t  tsMonitorInterval;
extern char     tsMonitorFqdn[];
extern uint16_t tsMonitorPort;
S
monitor  
Shengliang Guan 已提交
92
extern int32_t  tsMonitorMaxLogs;
S
Shengliang Guan 已提交
93
extern bool     tsMonitorComp;
S
monitor  
Shengliang Guan 已提交
94

S
Shengliang Guan 已提交
95 96 97 98 99
// telem
extern bool     tsEnableTelem;
extern int32_t  tsTelemInterval;
extern char     tsTelemServer[];
extern uint16_t tsTelemPort;
D
dapan1121 已提交
100
extern bool     tsEnableCrashReport;
dengyihao's avatar
dengyihao 已提交
101 102 103
extern char    *tsTelemUri;
extern char    *tsClientCrashReportUri;
extern char    *tsSvrCrashReportUri;
S
Shengliang Guan 已提交
104

S
Shengliang Guan 已提交
105 106
// query buffer management
extern int32_t tsQueryBufferSize;  // maximum allowed usage buffer size in MB for each data node during query processing
107 108
extern int64_t tsQueryBufferSizeBytes;    // maximum allowed usage buffer size in byte for each data node
extern int32_t tsCacheLazyLoadThreshold;  // cost threshold for last/last_row loading cache as much as possible
H
Haojun Liao 已提交
109

X
Xiaoyu Wang 已提交
110 111
// query client
extern int32_t tsQueryPolicy;
D
dapan1121 已提交
112
extern int32_t tsQueryRspPolicy;
113
extern int64_t tsQueryMaxConcurrentTables;
X
Xiaoyu Wang 已提交
114
extern int32_t tsQuerySmaOptimize;
115
extern int32_t tsQueryRsmaTolerance;
116
extern bool    tsQueryPlannerTrace;
117 118
extern int32_t tsQueryNodeChunkSize;
extern bool    tsQueryUseNodeAllocator;
119
extern bool    tsKeepColumnName;
120
extern bool    tsEnableQueryHb;
121
extern bool    tsEnableScience;
122 123 124 125
extern int32_t tsRedirectPeriod;
extern int32_t tsRedirectFactor;
extern int32_t tsRedirectMaxPeriod;
extern int32_t tsMaxRetryWaitTime;
126
extern bool    tsUseAdapter;
D
dapan1121 已提交
127
extern int32_t tsMetaCacheMaxSize;
D
dapan1121 已提交
128 129
extern int32_t tsSlowLogThreshold;
extern int32_t tsSlowLogScope;
X
Xiaoyu Wang 已提交
130

S
Shengliang Guan 已提交
131 132 133
// client
extern int32_t tsMinSlidingTime;
extern int32_t tsMinIntervalTime;
134
extern int32_t tsMaxMemUsedByInsert;
H
hzcheng 已提交
135

S
Shengliang Guan 已提交
136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153
// build info
extern char version[];
extern char compatible_version[];
extern char gitinfo[];
extern char buildinfo[];

// lossy
extern char     tsLossyColumns[];
extern double   tsFPrecision;
extern double   tsDPrecision;
extern uint32_t tsMaxRange;
extern uint32_t tsCurRange;
extern char     tsCompressor[];

// tfs
extern int32_t  tsDiskCfgNum;
extern SDiskCfg tsDiskCfg[];

S
slzhou 已提交
154
// udf
155
extern bool tsStartUdfd;
S
slzhou 已提交
156
extern char tsUdfdResFuncs[];
157
extern char tsUdfdLdLibPath[];
S
slzhou 已提交
158

159
// schemaless
160 161 162 163
extern char tsSmlChildTableName[];
extern char tsSmlTagName[];
// extern bool    tsSmlDataFormat;
// extern int32_t tsSmlBatchSize;
164

165
// wal
166
extern int64_t tsWalFsyncDataSizeLimit;
167

168 169 170
// internal
extern int32_t tsTransPullupInterval;
extern int32_t tsMqRebalanceInterval;
171
extern int32_t tsStreamCheckpointTickInterval;
wmmhello's avatar
wmmhello 已提交
172
extern int32_t tsTtlUnit;
wmmhello's avatar
wmmhello 已提交
173
extern int32_t tsTtlPushInterval;
C
Cary Xu 已提交
174
extern int32_t tsGrantHBInterval;
175
extern int32_t tsUptimeInterval;
176

dengyihao's avatar
dengyihao 已提交
177 178 179
extern int32_t tsRpcRetryLimit;
extern int32_t tsRpcRetryInterval;

5
54liuyao 已提交
180 181
extern bool    tsDisableStream;
extern int64_t tsStreamBufferSize;
5
54liuyao 已提交
182
extern int64_t tsCheckpointInterval;
5
54liuyao 已提交
183

184
// #define NEEDTO_COMPRESSS_MSG(size) (tsCompressMsgSize != -1 && (size) > tsCompressMsgSize)
H
hjxilinx 已提交
185

186 187 188 189
int32_t taosCreateLog(const char *logname, int32_t logFileNum, const char *cfgDir, const char **envCmd,
                      const char *envFile, char *apolloUrl, SArray *pArgs, bool tsc);
int32_t taosInitCfg(const char *cfgDir, const char **envCmd, const char *envFile, char *apolloUrl, SArray *pArgs,
                    bool tsc);
S
Shengliang Guan 已提交
190 191
void    taosCleanupCfg();
void    taosCfgDynamicOptions(const char *option, const char *value);
S
TD-1767  
Shengliang Guan 已提交
192

S
Shengliang Guan 已提交
193
struct SConfig *taosGetCfg();
194

wafwerar's avatar
wafwerar 已提交
195 196
void    taosSetAllDebugFlag(int32_t flag, bool rewrite);
void    taosSetDebugFlag(int32_t *pFlagPtr, const char *flagName, int32_t flagVal, bool rewrite);
D
dapan1121 已提交
197
int32_t taosApplyLocalCfg(SConfig *pCfg, char *name);
198
void    taosLocalCfgForbiddenToChange(char *name, bool *forbidden);
S
Shengliang Guan 已提交
199

H
hzcheng 已提交
200 201 202 203
#ifdef __cplusplus
}
#endif

204
#endif /*_TD_COMMON_GLOBAL_H_*/