tdef.h

/*
 * 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/>.
 */

#ifndef _TD_UTIL_DEF_H_
#define _TD_UTIL_DEF_H_

#include "cus_name.h"
#include "os.h"

#ifdef __cplusplus
extern "C" {
#endif

#define TSDB__packed

#if defined(TD_ASTRA_32)
#define PACK_PUSH_MIN _Pragma("pack(push, 4)")
#elif defined(WINDOWS)
#define PACK_PUSH_MIN __pragma(pack(push, 1))
#else
#define PACK_PUSH_MIN _Pragma("pack(push, 1)")
#endif

#if defined(WINDOWS)
#define PACK_POP __pragma(pack(pop))
#else
#define PACK_POP _Pragma("pack(pop)")
#endif

#define TSKEY             int64_t
#define TSKEY_MIN         INT64_MIN
#define TSKEY_MAX         INT64_MAX
#define TSKEY_INITIAL_VAL TSKEY_MIN

#define TD_VER_MAX UINT64_MAX  // TODO: use the real max version from query handle

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

#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 *)
#define M256_BYTES      32
#define TSDB_KEYSIZE    sizeof(TSKEY)
#define TSDB_NCHAR_SIZE sizeof(TdUcs4)

#define DECIMAL64_BYTES  8
#define DECIMAL128_BYTES 16

// NULL definition
#define TSDB_DATA_BOOL_NULL     0x02
#define TSDB_DATA_TINYINT_NULL  0x80
#define TSDB_DATA_SMALLINT_NULL 0x8000

#ifndef TSDB_DATA_INT_NULL
#define TSDB_DATA_INT_NULL 0x80000000LL
#endif

#ifndef TSDB_DATA_BIGINT_NULL
#define TSDB_DATA_BIGINT_NULL 0x8000000000000000LL
#endif

#define TSDB_DATA_TIMESTAMP_NULL TSDB_DATA_BIGINT_NULL

#ifndef TSDB_DATA_FLOAT_NULL
#define TSDB_DATA_FLOAT_NULL 0x7FF00000
#endif

#ifndef TSDB_DATA_DOUBLE_NULL
#define TSDB_DATA_DOUBLE_NULL 0x7FFFFF0000000000LL
#endif

#define TSDB_DATA_NCHAR_NULL    0xFFFFFFFF
#define TSDB_DATA_BINARY_NULL   0xFF
#define TSDB_DATA_GEOMETRY_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"
#ifdef _TD_POWER_
#define TSDB_DEFAULT_PASS "powerdb"
#elif (_TD_TQ_ == true)
#define TSDB_DEFAULT_PASS "tqueue"
#elif (_TD_PRO_ == true)
#define TSDB_DEFAULT_PASS "prodb"
#else
#define TSDB_DEFAULT_PASS "taosdata"
#endif

#define TSDB_TRUE  1
#define TSDB_FALSE 0
#define TSDB_OK    0
#define TSDB_ERR   -1

#define TS_PATH_DELIMITER "."
#define TS_ESCAPE_CHAR    '`'

#define TSDB_TIME_PRECISION_MILLI   0
#define TSDB_TIME_PRECISION_MICRO   1
#define TSDB_TIME_PRECISION_NANO    2
#define TSDB_TIME_PRECISION_HOURS   3
#define TSDB_TIME_PRECISION_MINUTES 4
#define TSDB_TIME_PRECISION_SECONDS 5

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

#define TSDB_TIME_PRECISION_SEC_DIGITS   10
#define TSDB_TIME_PRECISION_MILLI_DIGITS 13
#define TSDB_TIME_PRECISION_MICRO_DIGITS 16
#define TSDB_TIME_PRECISION_NANO_DIGITS  19

#define TSDB_INDEX_TYPE_SMA      "SMA"
#define TSDB_INDEX_TYPE_FULLTEXT "FULLTEXT"
#define TSDB_INDEX_TYPE_NORMAL   "NORMAL"

#define TSDB_INS_USER_STABLES_DBNAME_COLID 2

static const int64_t TICK_PER_SECOND[] = {
    1000LL,        // MILLISECOND
    1000000LL,     // MICROSECOND
    1000000000LL,  // NANOSECOND
    0LL,           // HOUR
    0LL,           // MINUTE
    1LL            // SECOND
};

#define TSDB_TICK_PER_SECOND(precision)               \
  ((int64_t)((precision) == TSDB_TIME_PRECISION_MILLI \
                 ? 1000LL                             \
                 : ((precision) == TSDB_TIME_PRECISION_MICRO ? 1000000LL : 1000000000LL)))

#define T_MEMBER_SIZE(type, member) sizeof(((type *)0)->member)
#define T_APPEND_MEMBER(dst, ptr, type, member)                                           \
  do {                                                                                    \
    (void)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)

typedef enum EOperatorType {
  // binary arithmetic operator
  OP_TYPE_ADD = 1,
  OP_TYPE_SUB,
  OP_TYPE_MULTI,
  OP_TYPE_DIV,
  OP_TYPE_REM,
  // unary arithmetic operator
  OP_TYPE_MINUS = 20,

  // bitwise operator
  OP_TYPE_BIT_AND = 30,
  OP_TYPE_BIT_OR,

  // binary comparison operator
  OP_TYPE_GREATER_THAN = 40,  // MUST KEEP IT FIRST AT COMPARE SECTION
  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,
  
  // unary comparison operator
  OP_TYPE_IS_NULL = 100,
  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,
  OP_TYPE_EXISTS,
  OP_TYPE_NOT_EXISTS,
  OP_TYPE_COMPARE_MAX_VALUE = 149,  // MUST KEEP IT LAST AT COMPARE SECTION

  // json operator
  OP_TYPE_JSON_GET_VALUE = 150,
  OP_TYPE_JSON_CONTAINS,

  // internal operator
  OP_TYPE_ASSIGN = 200
} EOperatorType;

static const EOperatorType OPERATOR_ARRAY[] = {
    OP_TYPE_ADD, OP_TYPE_SUB, OP_TYPE_MULTI, OP_TYPE_DIV, OP_TYPE_REM,

    OP_TYPE_MINUS,

    OP_TYPE_BIT_AND, OP_TYPE_BIT_OR,

    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,

    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, OP_TYPE_EXISTS, OP_TYPE_NOT_EXISTS,
    // OP_TYPE_COMPARE_MAX_VALUE,

    OP_TYPE_JSON_GET_VALUE, OP_TYPE_JSON_CONTAINS,

    OP_TYPE_ASSIGN};

#define OP_TYPE_CALC_MAX OP_TYPE_BIT_OR

typedef enum ELogicConditionType {
  LOGIC_COND_TYPE_AND = 1,
  LOGIC_COND_TYPE_OR,
  LOGIC_COND_TYPE_NOT,
} ELogicConditionType;

typedef enum EQuantifyType {
  QU_TYPE_NULL = 0,
  QU_TYPE_ANY,
  QU_TYPE_ALL
} EQuantifyType;

#define ENCRYPTED_LEN(len)  (len / 16) * 16 + (len % 16 ? 1 : 0) * 16
#define ENCRYPT_KEY_LEN     16
#define ENCRYPT_KEY_LEN_MIN 8

#define ENCRYPT_KEY_EXPIRE_STRATEGY_LEN 16

#define TSDB_INT32_ID_LEN 11

#define TSDB_NAME_DELIMITER_LEN 1
#define TSDB_NAME_QUOTE         2

#define TSDB_UNI_LEN  24
#define TSDB_USER_LEN TSDB_UNI_LEN
#define TSDB_ROLE_LEN 64

#define TSDB_POINTER_PRINT_BYTES 18  // 0x1122334455667788
// ACCOUNT is a 32 bit positive integer
// this is the length of its string representation, including the terminator zero
#define TSDB_ACCT_ID_LEN   11
#define TSDB_NODE_ID_LEN   11
#define TSDB_VGROUP_ID_LEN 11

#define TSDB_MAX_COLUMNS             32767
#define TSDB_MAX_COLUMNS_NON_VIRTUAL 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
#define TSDB_TOKEN_LEN                64                                 // it is a null-terminated string
#define TSDB_TOKEN_EXPIRY_LEEWAY      30                                 // in seconds
#define TSDB_TOKEN_PROVIDER_LEN       64                                 // it is a null-terminated string
#define TSDB_TOKEN_EXTRA_INFO_LEN     1024                               // it is a null-terminated string
#define TSDB_CGROUP_LEN               193                                // it is a null-terminated string
#define TSDB_CLIENT_ID_LEN            256                                // it is a null-terminated string
#define TSDB_CONSUMER_ID_LEN          32                                 // it is a null-terminated string
#define TSDB_OFFSET_LEN               64                                 // it is a null-terminated string
#define TSDB_USER_CGROUP_LEN          (TSDB_USER_LEN + TSDB_CGROUP_LEN)  // it is a null-terminated string
#define TSDB_STREAM_NAME_LEN          193                                // it is a null-terminated string
#define TSDB_STREAM_NOTIFY_URL_LEN    128                                // it includes the terminating '\0'
#define TSDB_STREAM_NOTIFY_STAT_LEN   350                                // it includes the terminating '\0'
#define TSDB_OBJ_NAME_LEN             193                                // it is a null-terminated string
#define TSDB_OBJ_FNAME_LEN            (TSDB_ACCT_ID_LEN + TSDB_OBJ_NAME_LEN + TSDB_NAME_DELIMITER_LEN)
#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_PRIV_MAX_KEY_LEN         (TSDB_OBJ_FNAME_LEN + TSDB_TABLE_NAME_LEN + TSDB_NAME_DELIMITER_LEN + 10)
#define TSDB_PRIV_MAX_INPUT_ARGS      256
#define TSDB_PRIVILEGE_COLS_LEN       12 * 1024
#define TSDB_PRIVILEDGE_CONDITION_LEN 48 * 1024
#define TSDB_PRIVILEDGE_HOST_LEN      48 * 1024

#define TSDB_FUNC_NAME_LEN       65
#define TSDB_FUNC_COMMENT_LEN    1024 * 1024
#define TSDB_FUNC_CODE_LEN       10 * 1024 * 1024
#define TSDB_FUNC_BUF_SIZE       4096 * 64
#define TSDB_FUNC_TYPE_SCALAR    1
#define TSDB_FUNC_TYPE_AGGREGATE 2
#define TSDB_FUNC_SCRIPT_BIN_LIB 0
#define TSDB_FUNC_SCRIPT_PYTHON  1
#define TSDB_FUNC_MAX_RETRIEVE   1024

#define TSDB_INDEX_NAME_LEN    65  // 64 + 1 '\0'
#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)
#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_ACCT_ID_LEN + TSDB_TOPIC_NAME_LEN + TSDB_NAME_DELIMITER_LEN)
#define TSDB_STREAM_FNAME_LEN  (TSDB_DB_FNAME_LEN + TSDB_STREAM_NAME_LEN + TSDB_NAME_DELIMITER_LEN)
#define TSDB_SUBSCRIBE_KEY_LEN (TSDB_CGROUP_LEN + TSDB_TOPIC_FNAME_LEN + 2)
#define TSDB_PARTITION_KEY_LEN (TSDB_SUBSCRIBE_KEY_LEN + 20)
#define TSDB_COL_NAME_LEN      65
#define TSDB_COL_NAME_EXLEN    8
#define TSDB_COL_FNAME_LEN     (TSDB_TABLE_NAME_LEN + TSDB_COL_NAME_LEN + TSDB_NAME_DELIMITER_LEN)
#define TSDB_COL_FNAME_EX_LEN \
  (TSDB_DB_NAME_LEN + TSDB_NAME_DELIMITER_LEN + TSDB_TABLE_NAME_LEN + TSDB_NAME_DELIMITER_LEN + TSDB_COL_NAME_LEN)
#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
// TSDB_MAX_ALLOWED_SQL_LEN is deprecated, use tsMaxSQLLength instead (defined in tglobal.h)
#define TSDB_ENCRYPT_ALGR_NAME_LEN      64
#define TSDB_ENCRYPT_ALGR_DESC_LEN      128
#define TSDB_ENCRYPT_ALGR_TYPE_LEN      64
#define TSDB_ENCRYPT_ALGR_SM4_NAME      "SM4-CBC:SM4"
#define TSDB_MNODE_BUILTIN_DATA_VERSION 1

#define TSDB_VIEW_NAME_LEN  193
#define TSDB_VIEW_FNAME_LEN (TSDB_DB_FNAME_LEN + TSDB_VIEW_NAME_LEN + TSDB_NAME_DELIMITER_LEN)

#define TSDB_APP_NAME_LEN   TSDB_UNI_LEN
#define TSDB_TB_COMMENT_LEN 1025

#define TSDB_INSTANCE_ID_LEN   256
#define TSDB_INSTANCE_TYPE_LEN 64
#define TSDB_INSTANCE_DESC_LEN 512

#define TSDB_QUERY_ID_LEN   26
#define TSDB_TRANS_OPER_LEN 16

#define TSDB_MAX_BYTES_PER_ROW         65531  // 49151:65531
#define TSDB_MAX_BYTES_PER_ROW_VIRTUAL 524283
#define TSDB_MAX_TAGS_LEN              16384
#define TSDB_MAX_TAGS                  128

#define TSDB_MAX_COL_TAG_NUM  (TSDB_MAX_COLUMNS + TSDB_MAX_TAGS)
#define TSDB_MAX_JSON_TAG_LEN 16384
#define TSDB_MAX_JSON_KEY_LEN 256

#define TSDB_AUTH_LEN                           16
#define TSDB_PASSWORD_MIN_LEN                   8
#define TSDB_PASSWORD_MAX_LEN                   255
#define TSDB_PASSWORD_LEN                       32  // this is the length after encryption
#define TSDB_PASSWORD_SALT_LEN                  31  // length of salt used in password encryption, excluding the terminator '\0'
#define TSDB_USER_PASSWORD_LEN                  129
#define TSDB_USER_PASSWORD_LONGLEN              256
#define TSDB_TOTP_SECRET_LEN                    32
#define TSDB_USER_TOTPSEED_MIN_LEN              8    // minimum length for TOTP seed, excluding the terminator '\0'
#define TSDB_USER_TOTPSEED_MAX_LEN              255  // maximum length for TOTP seed, excluding the terminator '\0'
#define TSDB_USER_SESSION_PER_USER_DEFAULT      32 
#define TSDB_USER_CONNECT_TIME_DEFAULT          (480 * 60)  // 480 minutes
#define TSDB_USER_CONNECT_IDLE_TIME_DEFAULT     (30 * 60)   // 30 minutes
#define TSDB_USER_CALL_PER_SESSION_DEFAULT      128
#define TSDB_USER_VNODE_PER_CALL_DEFAULT        -1
#define TSDB_USER_FAILED_LOGIN_ATTEMPTS_DEFAULT 3
#define TSDB_USER_PASSWORD_LOCK_TIME_DEFAULT    (1440 * 60)        // 1440 minutes
#define TSDB_USER_PASSWORD_LIFE_TIME_DEFAULT    (90 * 1440 * 60)   // 90 days
#define TSDB_USER_PASSWORD_LIFE_TIME_MIN        (1 * 1440 * 60)    // 1 day
#define TSDB_USER_PASSWORD_GRACE_TIME_DEFAULT   (7 * 1440 * 60)    // 7 days
#define TSDB_USER_PASSWORD_REUSE_TIME_DEFAULT   (30 * 1440 * 60)   // 30 days
#define TSDB_USER_PASSWORD_REUSE_TIME_MAX       (365 * 1440 * 60)  // 365 days
#define TSDB_USER_PASSWORD_REUSE_MAX_DEFAULT    5
#define TSDB_USER_PASSWORD_REUSE_MAX_MAX        100
#define TSDB_USER_INACTIVE_ACCOUNT_TIME_DEFAULT (90 * 1440 * 60)  // 90 days
#define TSDB_USER_ALLOW_TOKEN_NUM_DEFAULT       3

#define TSDB_PRODUCT_LEN    32
#define TSDB_VERSION_LEN    32
#define TSDB_LABEL_LEN      16
#define TSDB_JOB_STATUS_LEN 32

#define TSDB_CLUSTER_ID_LEN       40
#define TSDB_MACHINE_ID_LEN       24
#define TSDB_FQDN_LEN             TD_FQDN_LEN
#define TSDB_EP_LEN               (TSDB_FQDN_LEN + 6)
#define TSDB_IPv4ADDR_LEN         16
#define TSDB_FILENAME_LEN         128
#define TSDB_SHOW_SQL_LEN         2048
#define TSDB_INS_STREAM_SQL_LEN   (48 * 1024)
#define TSDB_SHOW_SCHEMA_JSON_LEN TSDB_MAX_COLUMNS * 256
#define TSDB_SLOW_QUERY_SQL_LEN   512
#define TSDB_SHOW_SUBQUERY_LEN    1000
#define TSDB_LOG_VAR_LEN          32

#define TSDB_ANALYTIC_ANODE_URL_LEN   128
#define TSDB_ANALYTIC_ALGO_NAME_LEN   64
#define TSDB_ANALYTIC_ALGO_TYPE_LEN   24
#define TSDB_ANALYTIC_ALGO_KEY_LEN    (TSDB_ANALYTIC_ALGO_NAME_LEN + 9)
#define TSDB_ANALYTIC_ALGO_URL_LEN    (TSDB_ANALYTIC_ANODE_URL_LEN + TSDB_ANALYTIC_ALGO_TYPE_LEN + 1)
#define TSDB_ANALYTIC_ALGO_OPTION_LEN (512)

#define TSDB_MOUNT_NAME_LEN           TSDB_DB_FNAME_LEN
#define TSDB_MOUNT_PATH_LEN           TSDB_FILENAME_LEN
#define TSDB_MOUNT_FPATH_LEN          (TSDB_MOUNT_PATH_LEN + 32)
#define TSDB_BNODE_OPT_PROTO_STR_MQTT "mqtt"
#define TSDB_BNODE_OPT_PROTO_MQTT     1
#define TSDB_BNODE_OPT_PROTO_STR_LEN  sizeof(TSDB_BNODE_OPT_PROTO_STR_MQTT)
#define TSDB_BNODE_OPT_PROTO_DEFAULT  TSDB_BNODE_OPT_PROTO_MQTT
#define TSDB_BNODE_OPT_PROTO_DFT_STR  TSDB_BNODE_OPT_PROTO_STR_MQTT

#define TSDB_XNODE_OPT_PROTO            1
#define TSDB_XNODE_URL_LEN              256
#define TSDB_XNODE_STATUS_LEN           16
#define TSDB_XNODE_TASK_NAME_LEN        64
#define TSDB_XNODE_TASK_PARSER_LEN      48*1024
#define TSDB_XNODE_TASK_TRIGGER_LEN     128
#define TSDB_XNODE_RESOURCE_ID_LEN      8
#define TSDB_XNODE_RESOURCE_NAME_LEN    64
#define TSDB_XNODE_TASK_SOURCE_LEN      4096
#define TSDB_XNODE_TASK_SINK_LEN        2048
#define TSDB_XNODE_TASK_REASON_LEN      1024
#define TSDB_XNODE_TASK_OPTIONS_MAX_NUM 64
#define TSDB_XNODE_TASK_JOB_CONFIG_LEN  48*1024
#define TSDB_XNODE_TASK_LABELS_LEN      4096
#define TSDB_XNODE_AGENT_NAME_LEN       TSDB_XNODE_TASK_NAME_LEN
#define TSDB_XNODE_AGENT_STATUS_LEN     TSDB_XNODE_STATUS_LEN
#define TSDB_XNODE_AGENT_TOKEN_LEN      512

#define TSDB_MAX_EP_NUM 10

#define TSDB_ARB_GROUP_MEMBER_NUM 2
#define TSDB_ARB_TOKEN_SIZE       32

#define TSDB_TRANS_STAGE_LEN   12
#define TSDB_TRANS_TYPE_LEN    16
#define TSDB_TRANS_ERROR_LEN   512
#define TSDB_TRANS_OBJTYPE_LEN 40
#define TSDB_TRANS_RESULT_LEN  100
#define TSDB_TRANS_TARGET_LEN  300
#define TSDB_TRANS_DETAIL_LEN  100

#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_RESERVE_VALUE_LEN 256

#define TSDB_CLUSTER_VALUE_LEN 1000
#define TSDB_GRANT_LOG_COL_LEN 15600

#define TSDB_ACTIVE_KEY_LEN      109
#define TSDB_CONN_ACTIVE_KEY_LEN 255

#define TSDB_DEFAULT_PKT_SIZE       65480  // same as RPC_MAX_UDP_SIZE
#define TSDB_SNAP_DATA_PAYLOAD_SIZE (1 * 1024 * 1024)
#define TSDB_SNAP_MAX_ROWS_PER_DATA (64 * 1024)

#define TSDB_PAYLOAD_SIZE         TSDB_DEFAULT_PKT_SIZE
#define TSDB_DEFAULT_PAYLOAD_SIZE 5120  // default payload size, greater than PATH_MAX value
#define TSDB_MIN_VNODES           16
#define TSDB_MAX_VNODES           512

#define TSDB_DNODE_ROLE_ANY   0
#define TSDB_DNODE_ROLE_MGMT  1
#define TSDB_DNODE_ROLE_VNODE 2

#define TSDB_MAX_REPLICA               5
#define TSDB_MAX_LEARNER_REPLICA       10
#define TSDB_SYNC_RESTORE_lEN          20
#define TSDB_SYNC_APPLY_COMMIT_LEN     100
#define TSDB_SYNC_LOG_BUFFER_SIZE      4096
#define TSDB_SYNC_LOG_BUFFER_RETENTION 256
#define TSDB_SYNC_LOG_BUFFER_THRESHOLD (1024 * 1024 * 5)
#define TSDB_SYNC_NEGOTIATION_WIN      512

#define TSDB_SYNC_SNAP_BUFFER_SIZE 1024

#define TSDB_TBNAME_COLUMN_INDEX     (-1)
#define TSDB_MULTI_TABLEMETA_MAX_NUM 100000  // maximum batch size allowed to load table meta

#define TSDB_MIN_VNODES_PER_DB          1
#define TSDB_MAX_VNODES_PER_DB          1024
#define TSDB_DEFAULT_VN_PER_DB          2
#define TSDB_MIN_BUFFER_PER_VNODE       3      // unit MB
#define TSDB_MAX_BUFFER_PER_VNODE       16384  // unit MB
#define TSDB_DEFAULT_BUFFER_PER_VNODE   256
#define TSDB_MIN_PAGES_PER_VNODE        64
#define TSDB_MAX_PAGES_PER_VNODE        (INT32_MAX - 1)
#define TSDB_DEFAULT_PAGES_PER_VNODE    256
#define TSDB_MIN_PAGESIZE_PER_VNODE     1  // unit KB
#define TSDB_MAX_PAGESIZE_PER_VNODE     16384
#define TSDB_DEFAULT_TSDB_PAGESIZE      4
#define TSDB_MIN_TSDB_PAGESIZE          1  // unit KB
#define TSDB_MAX_TSDB_PAGESIZE          16384
#define TSDB_DEFAULT_PAGESIZE_PER_VNODE 4
#define TSDB_MIN_DAYS_PER_FILE          60  // unit minute
#define TSDB_MAX_DAYS_PER_FILE          (3650 * 1440)
#define TSDB_DEFAULT_DAYS_PER_FILE      (10 * 1440)
#define TSDB_MIN_DURATION_PER_FILE      60  // unit minute
#define TSDB_MAX_DURATION_PER_FILE      (90 * 1440)
#define TSDB_DEFAULT_DURATION_PER_FILE  (10 * 1440)
#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_MAX_KEEP_NS                (365 * 292 * 1440)  // data in db to be reserved.
#define TSDB_DEFAULT_KEEP               (3650 * 1440)       // ten years
#define TSDB_MIN_KEEP_TIME_OFFSET       0
#define TSDB_MAX_KEEP_TIME_OFFSET       23
#define TSDB_DEFAULT_KEEP_TIME_OFFSET   0
#define TSDB_MIN_MINROWS_FBLOCK         10
#define TSDB_MAX_MINROWS_FBLOCK         1000000
#define TSDB_DEFAULT_MINROWS_FBLOCK     100
#define TSDB_MIN_MAXROWS_FBLOCK         200
#define TSDB_MAX_MAXROWS_FBLOCK         10000000
#define TSDB_DEFAULT_MAXROWS_FBLOCK     4096
#define TSDB_MIN_FSYNC_PERIOD           0
#define TSDB_MAX_FSYNC_PERIOD           180000  // millisecond
#define TSDB_DEFAULT_FSYNC_PERIOD       3000    // three second
#define TSDB_MIN_WAL_LEVEL              0
#define TSDB_MAX_WAL_LEVEL              2
#define TSDB_DEFAULT_WAL_LEVEL          1
#define TSDB_MIN_PRECISION              TSDB_TIME_PRECISION_MILLI
#define TSDB_MAX_PRECISION              TSDB_TIME_PRECISION_NANO
#define TSDB_DEFAULT_PRECISION          TSDB_TIME_PRECISION_MILLI
#define TSDB_MIN_COMP_LEVEL             0
#define TSDB_MAX_COMP_LEVEL             2
#define TSDB_DEFAULT_COMP_LEVEL         2
#define TSDB_MIN_DB_REPLICA             1
#define TSDB_MAX_DB_REPLICA             3
#define TSDB_DEFAULT_DB_REPLICA         1
#define TSDB_DB_STRICT_STR_LEN          sizeof(TSDB_DB_STRICT_OFF_STR)
#define TSDB_DB_STRICT_OFF_STR          "off"
#define TSDB_DB_STRICT_ON_STR           "on"
#define TSDB_DB_STRICT_OFF              0
#define TSDB_DB_STRICT_ON               1
#define TSDB_DEFAULT_DB_STRICT          TSDB_DB_STRICT_ON
#define TSDB_CACHE_MODEL_STR_LEN        sizeof(TSDB_CACHE_MODEL_LAST_VALUE_STR)
#define TSDB_CACHE_MODEL_NONE_STR       "none"
#define TSDB_CACHE_MODEL_LAST_ROW_STR   "last_row"
#define TSDB_CACHE_MODEL_LAST_VALUE_STR "last_value"
#define TSDB_CACHE_MODEL_BOTH_STR       "both"
#define TSDB_CACHE_MODEL_NONE           0
#define TSDB_CACHE_MODEL_LAST_ROW       1
#define TSDB_CACHE_MODEL_LAST_VALUE     2
#define TSDB_CACHE_MODEL_BOTH           3
#define TSDB_DNODE_LIST_LEN             256
#define TSDB_ENCRYPT_ALGO_STR_LEN       16
#define TSDB_ENCRYPT_ALGO_NONE_STR      "none"
#define TSDB_ENCRYPT_ALGO_SM4_STR       "sm4"
#define TSDB_ENCRYPT_ALGO_NONE          0
#define TSDB_ENCRYPT_ALGO_SM4           1
#define TSDB_DEFAULT_ENCRYPT_ALGO       TSDB_ENCRYPT_ALGO_NONE
#define TSDB_MIN_ENCRYPT_ALGO           TSDB_ENCRYPT_ALGO_NONE
#define TSDB_MAX_ENCRYPT_ALGO           TSDB_ENCRYPT_ALGO_SM4
#define TSDB_DEFAULT_CACHE_MODEL        TSDB_CACHE_MODEL_NONE
#define TSDB_MIN_DB_CACHE_SIZE          1  // MB
#define TSDB_MAX_DB_CACHE_SIZE          65536
#define TSDB_DEFAULT_CACHE_SIZE         1
#define TSDB_DEFAULT_MECACHE_SIZE       (1024 * 128)
#define TSDB_MIN_MECACHE_SIZE           (1024 * 4)
#define TSDB_MAX_MECACHE_SIZE           (4ll * 1024 * 1024 * 1024)
#define TSDB_DB_STREAM_MODE_OFF         0
#define TSDB_DB_STREAM_MODE_ON          1
#define TSDB_DEFAULT_DB_STREAM_MODE     0
#define TSDB_DB_SINGLE_STABLE_ON        1
#define TSDB_DB_SINGLE_STABLE_OFF       0
#define TSDB_DEFAULT_DB_SINGLE_STABLE   TSDB_DB_SINGLE_STABLE_OFF
#define TSDB_DB_SCHEMALESS_ON           1
#define TSDB_DB_SCHEMALESS_OFF          0
#define TSDB_DEFAULT_DB_SCHEMALESS      TSDB_DB_SCHEMALESS_OFF
#define TSDB_MIN_STT_TRIGGER            1
// #ifdef TD_ENTERPRISE
#define TSDB_MAX_STT_TRIGGER     16
#define TSDB_DEFAULT_SST_TRIGGER 2
// #else
// #define TSDB_MAX_STT_TRIGGER     1
// #define TSDB_DEFAULT_SST_TRIGGER 1
// #endif
#define TSDB_STT_TRIGGER_ARRAY_SIZE 16  // maximum of TSDB_MAX_STT_TRIGGER of TD_ENTERPRISE and TD_COMMUNITY
#define TSDB_MIN_HASH_PREFIX        (2 - TSDB_TABLE_NAME_LEN)
#define TSDB_MAX_HASH_PREFIX        (TSDB_TABLE_NAME_LEN - 2)
#define TSDB_DEFAULT_HASH_PREFIX    0
#define TSDB_MIN_HASH_SUFFIX        (2 - TSDB_TABLE_NAME_LEN)
#define TSDB_MAX_HASH_SUFFIX        (TSDB_TABLE_NAME_LEN - 2)
#define TSDB_DEFAULT_HASH_SUFFIX    0

#if !defined(TD_ENTERPRISE) || defined(ASSERT_NOT_CORE) || defined(GRANTS_CFG)
#define TSDB_MIN_SS_CHUNK_SIZE     (128 * 1024)
#define TSDB_MAX_SS_CHUNK_SIZE     (1024 * 1024)
#define TSDB_DEFAULT_SS_CHUNK_SIZE (128 * 1024)
#else
#define TSDB_MIN_SS_CHUNK_SIZE     (4 * 1024)
#define TSDB_MAX_SS_CHUNK_SIZE     (1024 * 1024)
#define TSDB_DEFAULT_SS_CHUNK_SIZE (4 * 1024)
#endif
#define TSDB_MIN_SS_KEEP_LOCAL     (1 * 1440)  // unit minute
#define TSDB_MAX_SS_KEEP_LOCAL     (365000 * 1440)
#define TSDB_DEFAULT_SS_KEEP_LOCAL (365 * 1440)
#define TSDB_MIN_SS_COMPACT        0
#define TSDB_MAX_SS_COMPACT        1
#define TSDB_DEFAULT_SS_COMPACT    1

#define TSDB_DB_MIN_WAL_RETENTION_PERIOD -1
#define TSDB_REP_DEF_DB_WAL_RET_PERIOD   3600
#define TSDB_REPS_DEF_DB_WAL_RET_PERIOD  3600
#define TSDB_DB_MIN_WAL_RETENTION_SIZE   -1
#define TSDB_REP_DEF_DB_WAL_RET_SIZE     0
#define TSDB_REPS_DEF_DB_WAL_RET_SIZE    0
#define TSDB_DB_MIN_WAL_ROLL_PERIOD      0
#define TSDB_REP_DEF_DB_WAL_ROLL_PERIOD  0
#define TSDB_REPS_DEF_DB_WAL_ROLL_PERIOD 0
#define TSDB_DB_MIN_WAL_SEGMENT_SIZE     0
#define TSDB_DEFAULT_DB_WAL_SEGMENT_SIZE 0

#define TSDB_DEFAULT_DB_WITH_ARBITRATOR 0
#define TSDB_MIN_DB_WITH_ARBITRATOR     0
#define TSDB_MAX_DB_WITH_ARBITRATOR     1
#define TSDB_MIN_DB_IS_AUDIT            0
#define TSDB_MAX_DB_IS_AUDIT            1
#define TSDB_DEFAULT_DB_ALLOW_DROP      1
#define TSDB_MIN_DB_ALLOW_DROP          0
#define TSDB_MAX_DB_ALLOW_DROP          1

#define TSDB_MIN_ROLLUP_MAX_DELAY       1  // unit millisecond
#define TSDB_MAX_ROLLUP_MAX_DELAY       (15 * 60 * 1000)
#define TSDB_MIN_ROLLUP_WATERMARK       0  // unit millisecond
#define TSDB_MAX_ROLLUP_WATERMARK       (15 * 60 * 1000)
#define TSDB_DEFAULT_ROLLUP_WATERMARK   5000
#define TSDB_MIN_ROLLUP_DELETE_MARK     0  // unit millisecond
#define TSDB_MAX_ROLLUP_DELETE_MARK     INT64_MAX
#define TSDB_DEFAULT_ROLLUP_DELETE_MARK 900000  // 900s
#define TSDB_MIN_TABLE_TTL              0
#define TSDB_DEFAULT_TABLE_TTL          0

#define TSDB_DEFAULT_COMPACT_INTERVAL    0
#define TSDB_MIN_COMPACT_INTERVAL        10             // unit minute
#define TSDB_MAX_COMPACT_INTERVAL        TSDB_MAX_KEEP  // unit minute
#define TSDB_DEFAULT_COMPACT_START_TIME  0
#define TSDB_DEFAULT_COMPACT_END_TIME    0
#define TSDB_MIN_COMPACT_TIME_OFFSET     0
#define TSDB_MAX_COMPACT_TIME_OFFSET     23
#define TSDB_DEFAULT_COMPACT_TIME_OFFSET 0

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

#define TSDB_DEFAULT_EXPLAIN_VERBOSE false

#define TSDB_EXPLAIN_RESULT_ROW_SIZE    (16 * 1024)
#define TSDB_EXPLAIN_RESULT_COLUMN_NAME "QUERY_PLAN"

#define TSDB_MAX_FIELD_LEN     65519               // 16384:65519
#define TSDB_MAX_BINARY_LEN    TSDB_MAX_FIELD_LEN  // 16384-8:65519
#define TSDB_MAX_NCHAR_LEN     TSDB_MAX_FIELD_LEN  // 16384-8:65519
#define TSDB_MAX_GEOMETRY_LEN  TSDB_MAX_FIELD_LEN  // 16384-8:65519
#define TSDB_MAX_VARBINARY_LEN TSDB_MAX_FIELD_LEN  // 16384-8:65519

#define TSDB_MAX_BLOB_LEN (4 << 20)

#define TSDB_MAX_SUBROLE   32
#define TSDB_MAX_PRIV_OBJS 512
#define TSDB_MAX_USERS     2000
#define TSDB_MAX_ROLES     200

#define TSDB_SHOW_VALIDATE_VIRTUAL_TABLE_ERROR 512

#define PRIMARYKEY_TIMESTAMP_COL_ID    1
#define COL_REACH_END(colId, maxColId) ((colId) > (maxColId))

#ifdef WINDOWS
#define TSDB_MAX_RPC_THREADS 4  // windows pipe only support 4 connections.
#else
#define TSDB_MAX_RPC_THREADS 100
#endif

#define TSDB_QUERY_TYPE_NON_TYPE 0x00u  // none type

#define TSDB_META_COMPACT_RATIO 0  // disable tsdb meta compact by default

/*
 * 1. ordinary sub query for select * from super_table
 * 2. all sqlobj generated by createSubqueryObj with this flag
 */
#define TSDB_QUERY_TYPE_INSERT      0x100u  // insert type
#define TSDB_QUERY_TYPE_FILE_INSERT 0x400u  // insert data from file
#define TSDB_QUERY_TYPE_STMT_INSERT 0x800u  // stmt insert type

#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_NONE 0
#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_MSG_SIZE (1024 * 1024 * 10)

#define TSDB_BLOB_MEMORY_LIMIT (1024 * 1024 * 1024 * 1)  // 1GB

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

#define TFS_MAX_TIERS              3
#define TFS_MAX_DISKS_PER_TIER     128
#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
#define TFS_MIN_DISK_FREE_SIZE     50 * 1024 * 1024                    // 50MB
#define TFS_MIN_DISK_FREE_SIZE_MAX (2ULL * 1024 * 1024 * 1024 * 1024)  // 2TB

#define SYNC_SNAPSHOT_SEQ_END          0x7FFFFFFF

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 };
enum {
  ENCRYPT_KEY_STAT_UNKNOWN = 0,
  ENCRYPT_KEY_STAT_UNSET,
  ENCRYPT_KEY_STAT_SET,
  ENCRYPT_KEY_STAT_LOADED,
  ENCRYPT_KEY_STAT_NOT_EXIST
};

typedef struct {
  char    dir[TSDB_FILENAME_LEN];
  int32_t level;
  int64_t diskId;
  int32_t primary;
  int8_t  disable;  // disable create new file
} SDiskCfg;

typedef struct {
  char name[TSDB_LOG_VAR_LEN];
} SLogVar;

typedef struct SEncryptData {
  char encryptAlgrName[TSDB_ENCRYPT_ALGR_NAME_LEN];
  char encryptKey[ENCRYPT_KEY_LEN + 1];
} SEncryptData;

#define TMQ_SEPARATOR      ":"
#define TMQ_SEPARATOR_CHAR ':'

enum {
  SND_WORKER_TYPE__SHARED = 1,
  SND_WORKER_TYPE__UNIQUE,
};

enum { RAND_ERR_MEMORY = 1, RAND_ERR_FILE = 2, RAND_ERR_NETWORK = 4 };

/**
 * RB: return before
 * RA: return after
 * NR: not return, skip and go on following steps
 */
#define TSDB_BYPASS_RB_RPC_SEND_SUBMIT 0x01u
#define TSDB_BYPASS_RA_RPC_RECV_SUBMIT 0x02u
#define TSDB_BYPASS_RB_TSDB_WRITE_MEM  0x04u
#define TSDB_BYPASS_RB_TSDB_COMMIT     0x08u

#define DEFAULT_HANDLE 0
#define MNODE_HANDLE   1
#define QNODE_HANDLE   -1
#define SNODE_HANDLE   -2
#define VNODE_HANDLE   -3
#define CLIENT_HANDLE  -5

#define TSDB_CONFIG_OPTION_LEN   32
#define TSDB_CONFIG_VALUE_LEN    64
#define TSDB_CONFIG_SCOPE_LEN    8
#define TSDB_CONFIG_NUMBER       16
#define TSDB_CONFIG_PATH_LEN     4096
#define TSDB_CONFIG_INFO_LEN     64
#define TSDB_CONFIG_CATEGORY_LEN 8

#define QUERY_ID_SIZE      20
#define QUERY_OBJ_ID_SIZE  18
#define SUBQUERY_INFO_SIZE 6
#define QUERY_SAVE_SIZE    20

#define MAX_NUM_STR_SIZE 40

#define MAX_META_MSG_IN_BATCH   1048576
#define MAX_META_BATCH_RSP_SIZE (1 * 1048576 * 1024)

// sort page size by default
#define DEFAULT_PAGESIZE 4096

#define VNODE_TIMEOUT_SEC 60
#define MNODE_TIMEOUT_SEC 60

#define MONITOR_TABLENAME_LEN   200
#define MONITOR_TAG_NAME_LEN    100
#define MONITOR_TAG_VALUE_LEN   300
#define MONITOR_METRIC_NAME_LEN 100

#define AUDIT_OPERATION_LEN 20
#define CONNECTOR_INFO_LEN  256

typedef enum {
  AUDIT_LEVEL_NONE = 0,
  AUDIT_LEVEL_SYSTEM = 1,
  AUDIT_LEVEL_CLUSTER = 2,
  AUDIT_LEVEL_DATABASE = 3,
  AUDIT_LEVEL_CHILDTABLE = 4,
  AUDIT_LEVEL_DATA = 5,
} EAuditLevel;

typedef enum {
  ANALY_ALGO_TYPE_ANOMALY_DETECT = 0,
  ANALY_ALGO_TYPE_FORECAST = 1,
  ANALY_ALGO_TYPE_IMPUTATION = 2,
  ANALY_ALGO_TYPE_CORREL = 3,
  ANALY_ALGO_TYPE_CLASSIFI = 4,
  ANALY_ALGO_TYPE_MOTIF = 5,
  ANALY_ALGO_TYPE_END = 10,
} EAnalyAlgoType;

typedef enum {
  TSDB_VERSION_UNKNOWN = 0,
  TSDB_VERSION_OSS,
  TSDB_VERSION_ENTERPRISE,
  TSDB_VERSION_CLOUD,
  TSDB_VERSION_END,
} EVersionType;

#define MIN_RESERVE_MEM_SIZE 1024  // MB

// Decimal
#define TSDB_DECIMAL64_MAX_PRECISION 18
#define TSDB_DECIMAL64_MAX_SCALE     TSDB_DECIMAL64_MAX_PRECISION

#define TSDB_DECIMAL128_MAX_PRECISION 38
#define TSDB_DECIMAL128_MAX_SCALE     TSDB_DECIMAL128_MAX_PRECISION

#define TSDB_DECIMAL_MIN_PRECISION 1
#define TSDB_DECIMAL_MAX_PRECISION TSDB_DECIMAL128_MAX_PRECISION
#define TSDB_DECIMAL_MIN_SCALE     0
#define TSDB_DECIMAL_MAX_SCALE     TSDB_DECIMAL_MAX_PRECISION
#define GET_DEICMAL_MAX_PRECISION(type) \
  (type) == TSDB_DATA_TYPE_DECIMAL64 ? TSDB_DECIMAL64_MAX_PRECISION : TSDB_DECIMAL_MAX_SCALE

typedef uint64_t DecimalWord;
#define DECIMAL_WORD_NUM(TYPE) (sizeof(TYPE) / sizeof(DecimalWord))

#define COMPILE_TIME_ASSERT(pred) \
  switch (0) {                    \
    case 0:                       \
    case pred:;                   \
  }

#ifdef __cplusplus
}
#endif

#endif