tdef.h 16.4 KB
Newer Older
S
Shengliang Guan 已提交
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
Shengliang Guan 已提交
16 17
#ifndef _TD_UTIL_DEF_H_
#define _TD_UTIL_DEF_H_
S
Shengliang Guan 已提交
18

S
Shengliang Guan 已提交
19 20
#include "os.h"

S
Shengliang Guan 已提交
21 22 23 24 25 26
#ifdef __cplusplus
extern "C" {
#endif

#define TSDB__packed

S
Shengliang Guan 已提交
27 28 29
#define TSKEY             int64_t
#define TSKEY_MIN         INT64_MIN
#define TSKEY_MAX         (INT64_MAX - 1)
H
Hongze Cheng 已提交
30
#define TSKEY_INITIAL_VAL TSKEY_MIN
S
Shengliang Guan 已提交
31 32 33 34

// Bytes for each type.
extern const int32_t TYPE_BYTES[15];

35
// TODO: replace and remove code below
S
Shengliang Guan 已提交
36 37 38 39 40 41 42 43
#define CHAR_BYTES      sizeof(char)
#define SHORT_BYTES     sizeof(int16_t)
#define INT_BYTES       sizeof(int32_t)
#define LONG_BYTES      sizeof(int64_t)
#define FLOAT_BYTES     sizeof(float)
#define DOUBLE_BYTES    sizeof(double)
#define POINTER_BYTES   sizeof(void *)  // 8 by default  assert(sizeof(ptrdiff_t) == sizseof(void*)
#define TSDB_KEYSIZE    sizeof(TSKEY)
wafwerar's avatar
wafwerar 已提交
44
#define TSDB_NCHAR_SIZE sizeof(TdUcs4)
S
Shengliang Guan 已提交
45 46

// NULL definition
S
Shengliang Guan 已提交
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68
#define TSDB_DATA_BOOL_NULL      0x02
#define TSDB_DATA_TINYINT_NULL   0x80
#define TSDB_DATA_SMALLINT_NULL  0x8000
#define TSDB_DATA_INT_NULL       0x80000000L
#define TSDB_DATA_BIGINT_NULL    0x8000000000000000L
#define TSDB_DATA_TIMESTAMP_NULL TSDB_DATA_BIGINT_NULL

#define TSDB_DATA_FLOAT_NULL  0x7FF00000           // it is an NAN
#define TSDB_DATA_DOUBLE_NULL 0x7FFFFF0000000000L  // an NAN
#define TSDB_DATA_NCHAR_NULL  0xFFFFFFFF
#define TSDB_DATA_BINARY_NULL 0xFF

#define TSDB_DATA_UTINYINT_NULL  0xFF
#define TSDB_DATA_USMALLINT_NULL 0xFFFF
#define TSDB_DATA_UINT_NULL      0xFFFFFFFF
#define TSDB_DATA_UBIGINT_NULL   0xFFFFFFFFFFFFFFFFL

#define TSDB_DATA_NULL_STR   "NULL"
#define TSDB_DATA_NULL_STR_L "null"

#define TSDB_NETTEST_USER "nettestinternal"
#define TSDB_DEFAULT_USER "root"
S
Shengliang Guan 已提交
69
#ifdef _TD_POWER_
S
Shengliang Guan 已提交
70
#define TSDB_DEFAULT_PASS "powerdb"
S
Shengliang Guan 已提交
71
#elif (_TD_TQ_ == true)
S
Shengliang Guan 已提交
72
#define TSDB_DEFAULT_PASS "tqueue"
S
Shengliang Guan 已提交
73
#elif (_TD_PRO_ == true)
S
Shengliang Guan 已提交
74
#define TSDB_DEFAULT_PASS "prodb"
S
Shengliang Guan 已提交
75
#else
S
Shengliang Guan 已提交
76
#define TSDB_DEFAULT_PASS "taosdata"
S
Shengliang Guan 已提交
77 78
#endif

S
Shengliang Guan 已提交
79
#define SHELL_MAX_PASSWORD_LEN 20
S
Shengliang Guan 已提交
80

S
Shengliang Guan 已提交
81 82 83
#define TSDB_TRUE  1
#define TSDB_FALSE 0
#define TSDB_OK    0
S
Shengliang Guan 已提交
84 85 86
#define TSDB_ERR   -1

#define TS_PATH_DELIMITER "."
87
#define TS_ESCAPE_CHAR    '`'
S
Shengliang Guan 已提交
88

S
Shengliang Guan 已提交
89 90 91
#define TSDB_TIME_PRECISION_MILLI 0
#define TSDB_TIME_PRECISION_MICRO 1
#define TSDB_TIME_PRECISION_NANO  2
S
Shengliang Guan 已提交
92 93 94 95 96

#define TSDB_TIME_PRECISION_MILLI_STR "ms"
#define TSDB_TIME_PRECISION_MICRO_STR "us"
#define TSDB_TIME_PRECISION_NANO_STR  "ns"

D
dapan1121 已提交
97
#define TSDB_INFORMATION_SCHEMA_DB            "information_schema"
98
#define TSDB_PERFORMANCE_SCHEMA_DB            "performance_schema"
D
dapan1121 已提交
99 100 101 102
#define TSDB_INS_TABLE_DNODES                 "dnodes"
#define TSDB_INS_TABLE_MNODES                 "mnodes"
#define TSDB_INS_TABLE_MODULES                "modules"
#define TSDB_INS_TABLE_QNODES                 "qnodes"
103 104
#define TSDB_INS_TABLE_BNODES                 "bnodes"
#define TSDB_INS_TABLE_CLUSTER                "cluster"
X
Xiaoyu Wang 已提交
105
#define TSDB_INS_TABLE_USER_DATABASES         "user_databases"
D
dapan1121 已提交
106 107 108 109 110 111 112 113
#define TSDB_INS_TABLE_USER_FUNCTIONS         "user_functions"
#define TSDB_INS_TABLE_USER_INDEXES           "user_indexes"
#define TSDB_INS_TABLE_USER_STABLES           "user_stables"
#define TSDB_INS_TABLE_USER_STREAMS           "user_streams"
#define TSDB_INS_TABLE_USER_TABLES            "user_tables"
#define TSDB_INS_TABLE_USER_TABLE_DISTRIBUTED "user_table_distributed"
#define TSDB_INS_TABLE_USER_USERS             "user_users"
#define TSDB_INS_TABLE_VGROUPS                "vgroups"
114 115
#define TSDB_INS_TABLE_BNODES                 "bnodes"
#define TSDB_INS_TABLE_SNODES                 "snodes"
D
dapan1121 已提交
116

D
dapan1121 已提交
117 118 119
#define TSDB_INDEX_TYPE_SMA      "SMA"
#define TSDB_INDEX_TYPE_FULLTEXT "FULLTEXT"

D
dapan1121 已提交
120 121
#define TSDB_INS_USER_STABLES_DBNAME_COLID    2

S
Shengliang Guan 已提交
122 123 124
#define TSDB_TICK_PER_SECOND(precision)                      \
  ((int64_t)((precision) == TSDB_TIME_PRECISION_MILLI ? 1e3L \
                                                      : ((precision) == TSDB_TIME_PRECISION_MICRO ? 1e6L : 1e9L)))
S
Shengliang Guan 已提交
125 126

#define T_MEMBER_SIZE(type, member) sizeof(((type *)0)->member)
S
Shengliang Guan 已提交
127 128 129 130 131 132 133 134 135 136
#define T_APPEND_MEMBER(dst, ptr, type, member)                                     \
  do {                                                                              \
    memcpy((void *)(dst), (void *)(&((ptr)->member)), T_MEMBER_SIZE(type, member)); \
    dst = (void *)((char *)(dst) + T_MEMBER_SIZE(type, member));                    \
  } while (0)
#define T_READ_MEMBER(src, type, target)          \
  do {                                            \
    (target) = *(type *)(src);                    \
    (src) = (void *)((char *)src + sizeof(type)); \
  } while (0)
L
Liu Jicong 已提交
137

D
dapan1121 已提交
138
typedef enum EOperatorType {
X
Xiaoyu Wang 已提交
139
  // binary arithmetic operator
D
dapan1121 已提交
140 141 142 143 144
  OP_TYPE_ADD = 1,
  OP_TYPE_SUB,
  OP_TYPE_MULTI,
  OP_TYPE_DIV,
  OP_TYPE_MOD,
X
Xiaoyu Wang 已提交
145 146
  // unary arithmetic operator
  OP_TYPE_MINUS,
D
dapan1121 已提交
147 148 149 150 151

  // bit operator
  OP_TYPE_BIT_AND,
  OP_TYPE_BIT_OR,

X
Xiaoyu Wang 已提交
152
  // binary comparison operator
D
dapan1121 已提交
153 154 155 156 157 158 159 160 161 162 163 164
  OP_TYPE_GREATER_THAN,
  OP_TYPE_GREATER_EQUAL,
  OP_TYPE_LOWER_THAN,
  OP_TYPE_LOWER_EQUAL,
  OP_TYPE_EQUAL,
  OP_TYPE_NOT_EQUAL,
  OP_TYPE_IN,
  OP_TYPE_NOT_IN,
  OP_TYPE_LIKE,
  OP_TYPE_NOT_LIKE,
  OP_TYPE_MATCH,
  OP_TYPE_NMATCH,
X
Xiaoyu Wang 已提交
165
  // unary comparison operator
D
dapan1121 已提交
166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184
  OP_TYPE_IS_NULL,
  OP_TYPE_IS_NOT_NULL,
  OP_TYPE_IS_TRUE,
  OP_TYPE_IS_FALSE,
  OP_TYPE_IS_UNKNOWN,
  OP_TYPE_IS_NOT_TRUE,
  OP_TYPE_IS_NOT_FALSE,
  OP_TYPE_IS_NOT_UNKNOWN,

  // json operator
  OP_TYPE_JSON_GET_VALUE,
  OP_TYPE_JSON_CONTAINS
} EOperatorType;

typedef enum ELogicConditionType {
  LOGIC_COND_TYPE_AND,
  LOGIC_COND_TYPE_OR,
  LOGIC_COND_TYPE_NOT,
} ELogicConditionType;
S
Shengliang Guan 已提交
185

S
Shengliang Guan 已提交
186 187 188 189
#define FUNCTION_CEIL  4500
#define FUNCTION_FLOOR 4501
#define FUNCTION_ABS   4502
#define FUNCTION_ROUND 4503
L
Liu Jicong 已提交
190

S
Shengliang Guan 已提交
191 192 193 194
#define FUNCTION_LENGTH 4800
#define FUNCTION_CONCAT 4801
#define FUNCTION_LTRIM  4802
#define FUNCTION_RTRIM  4803
L
Liu Jicong 已提交
195

S
Shengliang Guan 已提交
196
#define TSDB_NAME_DELIMITER_LEN 1
L
Liu Jicong 已提交
197

S
Shengliang Guan 已提交
198 199
#define TSDB_UNI_LEN  24
#define TSDB_USER_LEN TSDB_UNI_LEN
S
Shengliang Guan 已提交
200 201 202

// ACCOUNT is a 32 bit positive integer
// this is the length of its string representation, including the terminator zero
S
Shengliang Guan 已提交
203 204 205 206 207 208 209 210
#define TSDB_ACCT_ID_LEN 11

#define TSDB_MAX_COLUMNS 4096
#define TSDB_MIN_COLUMNS 2  // PRIMARY COLUMN(timestamp) + other columns

#define TSDB_NODE_NAME_LEN  64
#define TSDB_TABLE_NAME_LEN 193  // it is a null-terminated string
#define TSDB_TOPIC_NAME_LEN 193  // it is a null-terminated string
L
Liu Jicong 已提交
211
#define TSDB_CGROUP_LEN     193  // it is a null-terminated string
S
Shengliang Guan 已提交
212 213 214 215 216 217 218 219 220 221 222
#define TSDB_DB_NAME_LEN    65
#define TSDB_DB_FNAME_LEN   (TSDB_ACCT_ID_LEN + TSDB_DB_NAME_LEN + TSDB_NAME_DELIMITER_LEN)

#define TSDB_FUNC_NAME_LEN       65
#define TSDB_FUNC_COMMENT_LEN    4096
#define TSDB_FUNC_CODE_LEN       (65535 - 512)
#define TSDB_FUNC_BUF_SIZE       512
#define TSDB_FUNC_TYPE_SCALAR    1
#define TSDB_FUNC_TYPE_AGGREGATE 2
#define TSDB_FUNC_MAX_RETRIEVE   1024

C
Cary Xu 已提交
223
#define TSDB_INDEX_NAME_LEN      65  // 64 + 1 '\0'
D
dapan1121 已提交
224 225 226
#define TSDB_INDEX_TYPE_LEN      10
#define TSDB_INDEX_EXTS_LEN      256
#define TSDB_INDEX_FNAME_LEN     (TSDB_DB_FNAME_LEN + TSDB_INDEX_NAME_LEN + TSDB_NAME_DELIMITER_LEN)
S
Shengliang Guan 已提交
227 228 229
#define TSDB_TYPE_STR_MAX_LEN    32
#define TSDB_TABLE_FNAME_LEN     (TSDB_DB_FNAME_LEN + TSDB_TABLE_NAME_LEN + TSDB_NAME_DELIMITER_LEN)
#define TSDB_TOPIC_FNAME_LEN     TSDB_TABLE_FNAME_LEN
L
Liu Jicong 已提交
230
#define TSDB_STREAM_FNAME_LEN    TSDB_TABLE_FNAME_LEN
L
Liu Jicong 已提交
231 232
#define TSDB_SUBSCRIBE_KEY_LEN   (TSDB_CGROUP_LEN + TSDB_TOPIC_FNAME_LEN + 2)
#define TSDB_PARTITION_KEY_LEN   (TSDB_SUBSCRIBE_KEY_LEN + 20)
S
Shengliang Guan 已提交
233 234 235 236 237 238 239 240
#define TSDB_COL_NAME_LEN        65
#define TSDB_MAX_SAVED_SQL_LEN   TSDB_MAX_COLUMNS * 64
#define TSDB_MAX_SQL_LEN         TSDB_PAYLOAD_SIZE
#define TSDB_MAX_SQL_SHOW_LEN    1024
#define TSDB_MAX_ALLOWED_SQL_LEN (1 * 1024 * 1024u)  // sql length should be less than 1mb

#define TSDB_APP_NAME_LEN    TSDB_UNI_LEN
#define TSDB_STB_COMMENT_LEN 1024
D
dapan1121 已提交
241

S
Shengliang Guan 已提交
242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289
/**
 *  In some scenarios uint16_t (0~65535) is used to store the row len.
 *  - Firstly, we use 65531(65535 - 4), as the SDataRow/SKVRow contains 4 bits header.
 *  - Secondly, if all cols are VarDataT type except primary key, we need 4 bits to store the offset, thus
 *    the final value is 65531-(4096-1)*4 = 49151.
 */
#define TSDB_MAX_BYTES_PER_ROW  49151
#define TSDB_MAX_TAGS_LEN       16384
#define TSDB_MAX_TAGS           128
#define TSDB_MAX_TAG_CONDITIONS 1024

#define TSDB_AUTH_LEN          16
#define TSDB_PASSWORD_LEN      32
#define TSDB_USET_PASSWORD_LEN 129
#define TSDB_VERSION_LEN       12
#define TSDB_LABEL_LEN         8

#define TSDB_CLUSTER_ID_LEN     40
#define TSDB_FQDN_LEN           128
#define TSDB_EP_LEN             (TSDB_FQDN_LEN + 6)
#define TSDB_IPv4ADDR_LEN       16
#define TSDB_FILENAME_LEN       128
#define TSDB_SHOW_SQL_LEN       512
#define TSDB_SHOW_SUBQUERY_LEN  1000
#define TSDB_SLOW_QUERY_SQL_LEN 512

#define TSDB_TRANS_STAGE_LEN 12
#define TSDB_TRANS_TYPE_LEN  16
#define TSDB_TRANS_ERROR_LEN 64

#define TSDB_STEP_NAME_LEN 32
#define TSDB_STEP_DESC_LEN 128

#define TSDB_ERROR_MSG_LEN    1024
#define TSDB_DNODE_CONFIG_LEN 128
#define TSDB_DNODE_VALUE_LEN  256

#define TSDB_MQTT_HOSTNAME_LEN  64
#define TSDB_MQTT_PORT_LEN      8
#define TSDB_MQTT_USER_LEN      24
#define TSDB_MQTT_PASS_LEN      24
#define TSDB_MQTT_TOPIC_LEN     64
#define TSDB_MQTT_CLIENT_ID_LEN 32

#define TSDB_DB_TYPE_DEFAULT 0
#define TSDB_DB_TYPE_TOPIC   1

#define TSDB_DEFAULT_PKT_SIZE 65480  // same as RPC_MAX_UDP_SIZE
S
Shengliang Guan 已提交
290 291

#define TSDB_PAYLOAD_SIZE         TSDB_DEFAULT_PKT_SIZE
S
Shengliang Guan 已提交
292 293
#define TSDB_DEFAULT_PAYLOAD_SIZE 5120  // default payload size, greater than PATH_MAX value
#define TSDB_EXTRA_PAYLOAD_SIZE   128   // extra bytes for auth
S
Shengliang Guan 已提交
294
#define TSDB_CQ_SQL_SIZE          1024
295
#define TSDB_MIN_VNODES           16
S
Shengliang Guan 已提交
296
#define TSDB_MAX_VNODES           512
297 298
#define TSDB_MIN_VNODES_PER_DB    1
#define TSDB_MAX_VNODES_PER_DB    4096
S
Shengliang Guan 已提交
299
#define TSDB_DEFAULT_VN_PER_DB    2
L
Liu Jicong 已提交
300

S
Shengliang Guan 已提交
301 302 303
#define TSDB_DNODE_ROLE_ANY   0
#define TSDB_DNODE_ROLE_MGMT  1
#define TSDB_DNODE_ROLE_VNODE 2
S
Shengliang Guan 已提交
304

S
Shengliang Guan 已提交
305
#define TSDB_MAX_REPLICA 5
S
Shengliang Guan 已提交
306

S
Shengliang Guan 已提交
307 308 309
#define TSDB_TBNAME_COLUMN_INDEX (-1)
#define TSDB_UD_COLUMN_INDEX     (-1000)
#define TSDB_RES_COL_ID          (-5000)
S
Shengliang Guan 已提交
310

S
Shengliang Guan 已提交
311
#define TSDB_MULTI_TABLEMETA_MAX_NUM 100000  // maximum batch size allowed to load table meta
S
Shengliang Guan 已提交
312

S
Shengliang Guan 已提交
313 314 315
#define TSDB_MIN_CACHE_BLOCK_SIZE     1
#define TSDB_MAX_CACHE_BLOCK_SIZE     128  // 128MB for each vnode
#define TSDB_DEFAULT_CACHE_BLOCK_SIZE 16
S
Shengliang Guan 已提交
316

S
Shengliang Guan 已提交
317 318 319
#define TSDB_MIN_TOTAL_BLOCKS     3
#define TSDB_MAX_TOTAL_BLOCKS     10000
#define TSDB_DEFAULT_TOTAL_BLOCKS 6
S
Shengliang Guan 已提交
320

X
Xiaoyu Wang 已提交
321
#define TSDB_MIN_DAYS_PER_FILE     60    // unit minute
X
Xiaoyu Wang 已提交
322 323
#define TSDB_MAX_DAYS_PER_FILE     (3650 * 1440)
#define TSDB_DEFAULT_DAYS_PER_FILE (10 * 1440)
S
Shengliang Guan 已提交
324

X
Xiaoyu Wang 已提交
325 326 327
#define TSDB_MIN_KEEP     (1 * 1440)       // data in db to be reserved. unit minute
#define TSDB_MAX_KEEP     (365000 * 1440) // data in db to be reserved.
#define TSDB_DEFAULT_KEEP (3650 * 1440)    // ten years
S
Shengliang Guan 已提交
328

S
Shengliang Guan 已提交
329 330 331
#define TSDB_MIN_MIN_ROW_FBLOCK     10
#define TSDB_MAX_MIN_ROW_FBLOCK     1000
#define TSDB_DEFAULT_MIN_ROW_FBLOCK 100
S
Shengliang Guan 已提交
332

S
Shengliang Guan 已提交
333 334 335
#define TSDB_MIN_MAX_ROW_FBLOCK     200
#define TSDB_MAX_MAX_ROW_FBLOCK     10000
#define TSDB_DEFAULT_MAX_ROW_FBLOCK 4096
S
Shengliang Guan 已提交
336

S
Shengliang Guan 已提交
337 338 339
#define TSDB_MIN_COMMIT_TIME     30
#define TSDB_MAX_COMMIT_TIME     40960
#define TSDB_DEFAULT_COMMIT_TIME 3600
S
Shengliang Guan 已提交
340

S
Shengliang Guan 已提交
341 342 343
#define TSDB_MIN_FSYNC_PERIOD     0
#define TSDB_MAX_FSYNC_PERIOD     180000  // millisecond
#define TSDB_DEFAULT_FSYNC_PERIOD 3000    // three second
S
Shengliang Guan 已提交
344

X
Xiaoyu Wang 已提交
345
#define TSDB_MIN_WAL_LEVEL     1
S
Shengliang Guan 已提交
346 347
#define TSDB_MAX_WAL_LEVEL     2
#define TSDB_DEFAULT_WAL_LEVEL 1
S
Shengliang Guan 已提交
348

S
Shengliang Guan 已提交
349 350 351
#define TSDB_MIN_PRECISION     TSDB_TIME_PRECISION_MILLI
#define TSDB_MAX_PRECISION     TSDB_TIME_PRECISION_NANO
#define TSDB_DEFAULT_PRECISION TSDB_TIME_PRECISION_MILLI
S
Shengliang Guan 已提交
352

S
Shengliang Guan 已提交
353 354 355
#define TSDB_MIN_COMP_LEVEL     0
#define TSDB_MAX_COMP_LEVEL     2
#define TSDB_DEFAULT_COMP_LEVEL 2
S
Shengliang Guan 已提交
356

S
Shengliang Guan 已提交
357 358 359
#define TSDB_MIN_DB_REPLICA_OPTION     1
#define TSDB_MAX_DB_REPLICA_OPTION     3
#define TSDB_DEFAULT_DB_REPLICA_OPTION 1
S
Shengliang Guan 已提交
360

S
Shengliang Guan 已提交
361 362 363
#define TSDB_MIN_DB_QUORUM_OPTION     1
#define TSDB_MAX_DB_QUORUM_OPTION     2
#define TSDB_DEFAULT_DB_QUORUM_OPTION 1
S
Shengliang Guan 已提交
364

L
Liu Jicong 已提交
365 366
#define TSDB_MIN_DB_TTL_OPTION     1
#define TSDB_DEFAULT_DB_TTL_OPTION 0
367

L
Liu Jicong 已提交
368 369 370
#define TSDB_MIN_DB_SINGLE_STABLE_OPTION     0
#define TSDB_MAX_DB_SINGLE_STABLE_OPTION     1
#define TSDB_DEFAULT_DB_SINGLE_STABLE_OPTION 0
371

L
Liu Jicong 已提交
372 373 374
#define TSDB_MIN_DB_STREAM_MODE_OPTION     0
#define TSDB_MAX_DB_STREAM_MODE_OPTION     1
#define TSDB_DEFAULT_DB_STREAM_MODE_OPTION 0
375

L
Liu Jicong 已提交
376 377
#define TSDB_MAX_JOIN_TABLE_NUM 10
#define TSDB_MAX_UNION_CLAUSE   5
S
Shengliang Guan 已提交
378

S
Shengliang Guan 已提交
379 380 381
#define TSDB_MIN_DB_UPDATE            0
#define TSDB_MAX_DB_UPDATE            2
#define TSDB_DEFAULT_DB_UPDATE_OPTION 0
S
Shengliang Guan 已提交
382

S
Shengliang Guan 已提交
383 384 385
#define TSDB_MIN_DB_CACHE_LAST_ROW  0
#define TSDB_MAX_DB_CACHE_LAST_ROW  3
#define TSDB_DEFAULT_CACHE_LAST_ROW 0
S
Shengliang Guan 已提交
386

387 388 389 390
#define TSDB_MIN_DB_STREAM_MODE     0
#define TSDB_MAX_DB_STREAM_MODE     1
#define TSDB_DEFAULT_DB_STREAM_MODE 0

X
Xiaoyu Wang 已提交
391 392 393 394 395 396 397 398
#define TSDB_MIN_DB_FILE_FACTOR     0
#define TSDB_MAX_DB_FILE_FACTOR     1
#define TSDB_DEFAULT_DB_FILE_FACTOR 0.1

#define TSDB_MIN_DB_DELAY     1
#define TSDB_MAX_DB_DELAY     10
#define TSDB_DEFAULT_DB_DELAY 2

399 400 401 402 403 404 405
#define TSDB_DEFAULT_EXPLAIN_VERBOSE false

#define TSDB_MIN_EXPLAIN_RATIO       0
#define TSDB_MAX_EXPLAIN_RATIO       1
#define TSDB_DEFAULT_EXPLAIN_RATIO   0.001

#define TSDB_EXPLAIN_RESULT_ROW_SIZE 1024
D
dapan1121 已提交
406
#define TSDB_EXPLAIN_RESULT_COLUMN_NAME "QUERY PLAN"
407

S
Shengliang Guan 已提交
408 409
#define TSDB_MAX_JOIN_TABLE_NUM 10
#define TSDB_MAX_UNION_CLAUSE   5
S
Shengliang Guan 已提交
410

S
Shengliang Guan 已提交
411 412 413 414 415
#define TSDB_MAX_FIELD_LEN             16384
#define TSDB_MAX_BINARY_LEN            (TSDB_MAX_FIELD_LEN - TSDB_KEYSIZE)  // keep 16384
#define TSDB_MAX_NCHAR_LEN             (TSDB_MAX_FIELD_LEN - TSDB_KEYSIZE)  // keep 16384
#define PRIMARYKEY_TIMESTAMP_COL_ID    1
#define COL_REACH_END(colId, maxColId) ((colId) > (maxColId))
S
Shengliang Guan 已提交
416

S
Shengliang Guan 已提交
417
#define TSDB_MAX_RPC_THREADS 5
S
Shengliang Guan 已提交
418

S
Shengliang Guan 已提交
419 420
#define TSDB_QUERY_TYPE_NON_TYPE      0x00u  // none type
#define TSDB_QUERY_TYPE_FREE_RESOURCE 0x01u  // free qhandle at vnode
S
Shengliang Guan 已提交
421

S
Shengliang Guan 已提交
422
#define TSDB_META_COMPACT_RATIO 0  // disable tsdb meta compact by default
S
Shengliang Guan 已提交
423

S
Shengliang Guan 已提交
424 425 426 427
/*
 * 1. ordinary sub query for select * from super_table
 * 2. all sqlobj generated by createSubqueryObj with this flag
 */
S
Shengliang Guan 已提交
428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466
#define TSDB_QUERY_TYPE_SUBQUERY        0x02u
#define TSDB_QUERY_TYPE_STABLE_SUBQUERY 0x04u  // two-stage subquery for super table

#define TSDB_QUERY_TYPE_TABLE_QUERY      0x08u  // query ordinary table; below only apply to client side
#define TSDB_QUERY_TYPE_STABLE_QUERY     0x10u  // query on super table
#define TSDB_QUERY_TYPE_JOIN_QUERY       0x20u  // join query
#define TSDB_QUERY_TYPE_PROJECTION_QUERY 0x40u  // select *,columns... query
#define TSDB_QUERY_TYPE_JOIN_SEC_STAGE   0x80u  // join sub query at the second stage

#define TSDB_QUERY_TYPE_TAG_FILTER_QUERY 0x400u
#define TSDB_QUERY_TYPE_INSERT           0x100u  // insert type
#define TSDB_QUERY_TYPE_MULTITABLE_QUERY 0x200u
#define TSDB_QUERY_TYPE_FILE_INSERT      0x400u   // insert data from file
#define TSDB_QUERY_TYPE_STMT_INSERT      0x800u   // stmt insert type
#define TSDB_QUERY_TYPE_NEST_SUBQUERY    0x1000u  // nested sub query

#define TSDB_QUERY_HAS_TYPE(x, _type)   (((x) & (_type)) != 0)
#define TSDB_QUERY_SET_TYPE(x, _type)   ((x) |= (_type))
#define TSDB_QUERY_CLEAR_TYPE(x, _type) ((x) &= (~_type))
#define TSDB_QUERY_RESET_TYPE(x)        ((x) = TSDB_QUERY_TYPE_NON_TYPE)

#define TSDB_ORDER_ASC  1
#define TSDB_ORDER_DESC 2

#define TSDB_DEFAULT_CLUSTER_HASH_SIZE  1
#define TSDB_DEFAULT_MNODES_HASH_SIZE   5
#define TSDB_DEFAULT_DNODES_HASH_SIZE   10
#define TSDB_DEFAULT_ACCOUNTS_HASH_SIZE 10
#define TSDB_DEFAULT_USERS_HASH_SIZE    20
#define TSDB_DEFAULT_DBS_HASH_SIZE      100
#define TSDB_DEFAULT_VGROUPS_HASH_SIZE  100
#define TSDB_DEFAULT_STABLES_HASH_SIZE  100
#define TSDB_DEFAULT_CTABLES_HASH_SIZE  20000

#define TSDB_MAX_WAL_SIZE (1024 * 1024 * 3)

#define TSDB_ARB_DUMMY_TIME 4765104000000  // 2121-01-01 00:00:00.000, :P

#define TFS_MAX_TIERS          3
S
Shengliang Guan 已提交
467
#define TFS_MAX_DISKS_PER_TIER 16
S
Shengliang Guan 已提交
468 469 470 471 472
#define TFS_MAX_DISKS          (TFS_MAX_TIERS * TFS_MAX_DISKS_PER_TIER)
#define TFS_MIN_LEVEL          0
#define TFS_MAX_LEVEL          (TFS_MAX_TIERS - 1)
#define TFS_PRIMARY_LEVEL      0
#define TFS_PRIMARY_ID         0
S
Shengliang Guan 已提交
473
#define TFS_MIN_DISK_FREE_SIZE 50 * 1024 * 1024
S
Shengliang Guan 已提交
474

475 476
enum { TRANS_STAT_INIT = 0, TRANS_STAT_EXECUTING, TRANS_STAT_EXECUTED, TRANS_STAT_ROLLBACKING, TRANS_STAT_ROLLBACKED };
enum { TRANS_OPER_INIT = 0, TRANS_OPER_EXECUTE, TRANS_OPER_ROLLBACK };
S
Shengliang Guan 已提交
477

S
tcfg  
Shengliang Guan 已提交
478
typedef struct {
S
Shengliang Guan 已提交
479 480 481
  char    dir[TSDB_FILENAME_LEN];
  int32_t level;
  int32_t primary;
S
tcfg  
Shengliang Guan 已提交
482 483
} SDiskCfg;

L
Liu Jicong 已提交
484 485
#define TMQ_SEPARATOR ':'

L
Liu Jicong 已提交
486 487 488 489 490
enum {
  SND_WORKER_TYPE__SHARED = 1,
  SND_WORKER_TYPE__UNIQUE,
};

S
Shengliang Guan 已提交
491 492 493
#define MNODE_HANDLE -1
#define QNODE_HANDLE 1
#define DEFAULT_HANDLE 0
S
Shengliang Guan 已提交
494

D
dapan1121 已提交
495 496 497
#define MAX_NUM_STR_SIZE 40


S
Shengliang Guan 已提交
498 499 500 501 502
#ifdef __cplusplus
}
#endif

#endif