tmsg.h 99.1 KB
Newer Older
D
dapan1121 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
/*
 * 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_COMMON_TAOS_MSG_H_
#define _TD_COMMON_TAOS_MSG_H_

#include "taosdef.h"
#include "taoserror.h"
H
more  
Hongze Cheng 已提交
21
#include "tarray.h"
H
more  
Hongze Cheng 已提交
22
#include "tcoding.h"
S
Shengliang Guan 已提交
23
#include "tencode.h"
L
Liu Jicong 已提交
24
#include "thash.h"
H
Hongze Cheng 已提交
25
#include "tlist.h"
D
dapan1121 已提交
26
#include "tname.h"
L
Liu Jicong 已提交
27
#include "trow.h"
L
Liu Jicong 已提交
28
#include "tuuid.h"
D
dapan1121 已提交
29

S
Shengliang Guan 已提交
30 31 32 33
#ifdef __cplusplus
extern "C" {
#endif

H
Hongze Cheng 已提交
34
/* ------------------------ MESSAGE DEFINITIONS ------------------------ */
H
Hongze Cheng 已提交
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52
#define TD_MSG_NUMBER_
#undef TD_MSG_DICT_
#undef TD_MSG_INFO_
#undef TD_MSG_SEG_CODE_
#include "tmsgdef.h"

#undef TD_MSG_NUMBER_
#undef TD_MSG_DICT_
#undef TD_MSG_INFO_
#define TD_MSG_SEG_CODE_
#include "tmsgdef.h"

#undef TD_MSG_NUMBER_
#undef TD_MSG_DICT_
#undef TD_MSG_INFO_
#undef TD_MSG_SEG_CODE_
#include "tmsgdef.h"

S
Shengliang Guan 已提交
53 54
extern char*   tMsgInfo[];
extern int32_t tMsgDict[];
H
Hongze Cheng 已提交
55 56

#define TMSG_SEG_CODE(TYPE) (((TYPE)&0xff00) >> 8)
L
Liu Jicong 已提交
57
#define TMSG_SEG_SEQ(TYPE)  ((TYPE)&0xff)
S
Shengliang Guan 已提交
58 59
#define TMSG_INFO(TYPE)                                                                                                \
  ((TYPE) < TDMT_DND_MAX_MSG || (TYPE) < TDMT_MND_MAX_MSG || (TYPE) < TDMT_VND_MAX_MSG || (TYPE) < TDMT_SCH_MAX_MSG || \
L
Liu Jicong 已提交
60
   (TYPE) < TDMT_STREAM_MAX_MSG || (TYPE) < TDMT_MON_MAX_MSG || (TYPE) < TDMT_SYNC_MAX_MSG) ||                         \
dengyihao's avatar
dengyihao 已提交
61
          (TYPE) < TDMT_VND_STREAM_MSG || (TYPE) < TDMT_VND_TMQ_MSG || (TYPE) < TDMT_VND_TMQ_MAX_MSG                   \
S
Shengliang Guan 已提交
62
      ? tMsgInfo[tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE)]                                                   \
dengyihao's avatar
dengyihao 已提交
63
      : 0
L
Liu Jicong 已提交
64

dengyihao's avatar
dengyihao 已提交
65
#define TMSG_INDEX(TYPE) (tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE))
D
dapan1121 已提交
66

H
Hongze Cheng 已提交
67 68
typedef uint16_t tmsg_t;

dengyihao's avatar
dengyihao 已提交
69 70 71 72 73 74 75 76 77
static inline bool tmsgIsValid(tmsg_t type) {
  if (type < TDMT_DND_MAX_MSG || type < TDMT_MND_MAX_MSG || type < TDMT_VND_MAX_MSG || type < TDMT_SCH_MAX_MSG ||
      type < TDMT_STREAM_MAX_MSG || type < TDMT_MON_MAX_MSG || type < TDMT_SYNC_MAX_MSG || type < TDMT_VND_STREAM_MSG ||
      type < TDMT_VND_TMQ_MSG || type < TDMT_VND_TMQ_MAX_MSG) {
    return true;
  } else {
    return false;
  }
}
78 79
static inline bool vnodeIsMsgBlock(tmsg_t type) {
  return (type == TDMT_VND_CREATE_TABLE) || (type == TDMT_VND_ALTER_TABLE) || (type == TDMT_VND_DROP_TABLE) ||
80
         (type == TDMT_VND_UPDATE_TAG_VAL) || (type == TDMT_VND_ALTER_CONFIRM) || (type == TDMT_VND_COMMIT);
81
}
82 83 84 85 86

static inline bool syncUtilUserCommit(tmsg_t msgType) {
  return msgType != TDMT_SYNC_NOOP && msgType != TDMT_SYNC_LEADER_TRANSFER;
}

H
Hongze Cheng 已提交
87
/* ------------------------ OTHER DEFINITIONS ------------------------ */
D
dapan1121 已提交
88
// IE type
L
Liu Jicong 已提交
89 90 91 92
#define TSDB_IE_TYPE_SEC         1
#define TSDB_IE_TYPE_META        2
#define TSDB_IE_TYPE_MGMT_IP     3
#define TSDB_IE_TYPE_DNODE_CFG   4
D
dapan1121 已提交
93
#define TSDB_IE_TYPE_NEW_VERSION 5
L
Liu Jicong 已提交
94
#define TSDB_IE_TYPE_DNODE_EXT   6
D
dapan1121 已提交
95 96
#define TSDB_IE_TYPE_DNODE_STATE 7

97 98 99 100 101 102
enum {
  CONN_TYPE__QUERY = 1,
  CONN_TYPE__TMQ,
  CONN_TYPE__UDFD,
  CONN_TYPE__MAX,
};
L
Liu Jicong 已提交
103

D
dapan1121 已提交
104
enum {
D
dapan 已提交
105 106
  HEARTBEAT_KEY_USER_AUTHINFO = 1,
  HEARTBEAT_KEY_DBINFO,
D
dapan1121 已提交
107
  HEARTBEAT_KEY_STBINFO,
108
  HEARTBEAT_KEY_TMQ,
K
kailixu 已提交
109
  HEARTBEAT_KEY_USER_PASSINFO,
D
dapan1121 已提交
110 111
};

S
Shengliang Guan 已提交
112 113
typedef enum _mgmt_table {
  TSDB_MGMT_TABLE_START,
D
dapan1121 已提交
114 115
  TSDB_MGMT_TABLE_DNODE,
  TSDB_MGMT_TABLE_MNODE,
116
  TSDB_MGMT_TABLE_MODULE,
S
Shengliang Guan 已提交
117 118
  TSDB_MGMT_TABLE_QNODE,
  TSDB_MGMT_TABLE_SNODE,
S
Shengliang Guan 已提交
119
  TSDB_MGMT_TABLE_BNODE,  // no longer used
120 121 122 123
  TSDB_MGMT_TABLE_CLUSTER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_FUNC,
  TSDB_MGMT_TABLE_INDEX,
S
Shengliang Guan 已提交
124
  TSDB_MGMT_TABLE_STB,
D
dapan1121 已提交
125
  TSDB_MGMT_TABLE_STREAMS,
126
  TSDB_MGMT_TABLE_TABLE,
127
  TSDB_MGMT_TABLE_TAG,
128
  TSDB_MGMT_TABLE_COL,
129
  TSDB_MGMT_TABLE_USER,
D
dapan1121 已提交
130
  TSDB_MGMT_TABLE_GRANTS,
131 132 133
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_TOPICS,
  TSDB_MGMT_TABLE_CONSUMERS,
L
Liu Jicong 已提交
134
  TSDB_MGMT_TABLE_SUBSCRIPTIONS,
135 136 137 138 139
  TSDB_MGMT_TABLE_TRANS,
  TSDB_MGMT_TABLE_SMAS,
  TSDB_MGMT_TABLE_CONFIGS,
  TSDB_MGMT_TABLE_CONNS,
  TSDB_MGMT_TABLE_QUERIES,
D
dapan1121 已提交
140
  TSDB_MGMT_TABLE_VNODES,
D
dapan1121 已提交
141
  TSDB_MGMT_TABLE_APPS,
142
  TSDB_MGMT_TABLE_STREAM_TASKS,
S
Shengliang Guan 已提交
143
  TSDB_MGMT_TABLE_PRIVILEGES,
D
dapan1121 已提交
144
  TSDB_MGMT_TABLE_MAX,
S
Shengliang Guan 已提交
145
} EShowType;
D
dapan1121 已提交
146

147 148 149 150
#define TSDB_ALTER_TABLE_ADD_TAG             1
#define TSDB_ALTER_TABLE_DROP_TAG            2
#define TSDB_ALTER_TABLE_UPDATE_TAG_NAME     3
#define TSDB_ALTER_TABLE_UPDATE_TAG_VAL      4
L
Liu Jicong 已提交
151 152
#define TSDB_ALTER_TABLE_ADD_COLUMN          5
#define TSDB_ALTER_TABLE_DROP_COLUMN         6
S
Shengliang Guan 已提交
153
#define TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES 7
L
Liu Jicong 已提交
154
#define TSDB_ALTER_TABLE_UPDATE_TAG_BYTES    8
155 156
#define TSDB_ALTER_TABLE_UPDATE_OPTIONS      9
#define TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME  10
dengyihao's avatar
dengyihao 已提交
157 158
#define TSDB_ALTER_TABLE_ADD_TAG_INDEX       11
#define TSDB_ALTER_TABLE_DROP_TAG_INDEX      12
D
dapan1121 已提交
159

D
dapan1121 已提交
160 161 162 163 164 165 166 167
#define TSDB_FILL_NONE        0
#define TSDB_FILL_NULL        1
#define TSDB_FILL_NULL_F      2
#define TSDB_FILL_SET_VALUE   3
#define TSDB_FILL_SET_VALUE_F 4
#define TSDB_FILL_LINEAR      5
#define TSDB_FILL_PREV        6
#define TSDB_FILL_NEXT        7
L
Liu Jicong 已提交
168

169 170 171 172 173 174 175 176 177 178 179 180
#define TSDB_ALTER_USER_PASSWD                 0x1
#define TSDB_ALTER_USER_SUPERUSER              0x2
#define TSDB_ALTER_USER_ADD_READ_DB            0x3
#define TSDB_ALTER_USER_REMOVE_READ_DB         0x4
#define TSDB_ALTER_USER_ADD_WRITE_DB           0x5
#define TSDB_ALTER_USER_REMOVE_WRITE_DB        0x6
#define TSDB_ALTER_USER_ADD_ALL_DB             0x7
#define TSDB_ALTER_USER_REMOVE_ALL_DB          0x8
#define TSDB_ALTER_USER_ENABLE                 0x9
#define TSDB_ALTER_USER_SYSINFO                0xA
#define TSDB_ALTER_USER_ADD_SUBSCRIBE_TOPIC    0xB
#define TSDB_ALTER_USER_REMOVE_SUBSCRIBE_TOPIC 0xC
C
table  
cademfly 已提交
181 182 183 184
#define TSDB_ALTER_USER_ADD_READ_TABLE         0xD
#define TSDB_ALTER_USER_REMOVE_READ_TABLE      0xE
#define TSDB_ALTER_USER_ADD_WRITE_TABLE        0xF
#define TSDB_ALTER_USER_REMOVE_WRITE_TABLE     0x10
X
Xiaoyu Wang 已提交
185 186
#define TSDB_ALTER_USER_ADD_ALL_TABLE          0x11
#define TSDB_ALTER_USER_REMOVE_ALL_TABLE       0x12
S
Shengliang Guan 已提交
187

D
dapan1121 已提交
188 189
#define TSDB_ALTER_USER_PRIVILEGES 0x2

H
Hongze Cheng 已提交
190
#define TSDB_KILL_MSG_LEN 30
D
dapan1121 已提交
191

D
dapan1121 已提交
192 193
#define TSDB_TABLE_NUM_UNIT 100000

L
Liu Jicong 已提交
194
#define TSDB_VN_READ_ACCCESS  ((char)0x1)
H
Hongze Cheng 已提交
195
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
L
Liu Jicong 已提交
196
#define TSDB_VN_ALL_ACCCESS   (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
D
dapan1121 已提交
197

H
Hongze Cheng 已提交
198
#define TSDB_COL_NORMAL 0x0u  // the normal column of the table
L
Liu Jicong 已提交
199 200 201 202
#define TSDB_COL_TAG    0x1u  // the tag column type
#define TSDB_COL_UDC    0x2u  // the user specified normal string column, it is a dummy column
#define TSDB_COL_TMP    0x4u  // internal column generated by the previous operators
#define TSDB_COL_NULL   0x8u  // the column filter NULL or not
D
dapan1121 已提交
203

L
Liu Jicong 已提交
204
#define TSDB_COL_IS_TAG(f)        (((f & (~(TSDB_COL_NULL))) & TSDB_COL_TAG) != 0)
H
Hongze Cheng 已提交
205
#define TSDB_COL_IS_NORMAL_COL(f) ((f & (~(TSDB_COL_NULL))) == TSDB_COL_NORMAL)
L
Liu Jicong 已提交
206 207
#define TSDB_COL_IS_UD_COL(f)     ((f & (~(TSDB_COL_NULL))) == TSDB_COL_UDC)
#define TSDB_COL_REQ_NULL(f)      (((f)&TSDB_COL_NULL) != 0)
S
Shengliang Guan 已提交
208

L
Liu Jicong 已提交
209 210
#define TD_SUPER_TABLE  TSDB_SUPER_TABLE
#define TD_CHILD_TABLE  TSDB_CHILD_TABLE
S
Shengliang Guan 已提交
211 212
#define TD_NORMAL_TABLE TSDB_NORMAL_TABLE

213 214 215
#define TD_REQ_FROM_APP  0
#define TD_REQ_FROM_TAOX 1

S
Shengliang Guan 已提交
216
typedef struct {
S
Shengliang Guan 已提交
217
  int32_t vgId;
D
dapan1121 已提交
218 219
  char*   dbFName;
  char*   tbName;
D
dapan1121 已提交
220
} SBuildTableInput;
D
dapan1121 已提交
221

S
Shengliang Guan 已提交
222
typedef struct {
D
dapan1121 已提交
223
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
224
  int64_t dbId;
225
  int32_t vgVersion;
L
Liu Jicong 已提交
226
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
D
dapan1121 已提交
227
  int64_t stateTs;
D
dapan1121 已提交
228 229
} SBuildUseDBInput;

S
Shengliang Guan 已提交
230 231 232
typedef struct SField {
  char    name[TSDB_COL_NAME_LEN];
  uint8_t type;
233
  int8_t  flags;
234
  int32_t bytes;
S
Shengliang Guan 已提交
235 236
} SField;

S
Shengliang Guan 已提交
237
typedef struct SRetention {
C
Cary Xu 已提交
238 239
  int64_t freq;
  int64_t keep;
S
sma  
Shengliang Guan 已提交
240 241
  int8_t  freqUnit;
  int8_t  keepUnit;
S
Shengliang Guan 已提交
242 243
} SRetention;

C
Cary Xu 已提交
244 245
#define RETENTION_VALID(r) (((r)->freq > 0) && ((r)->keep > 0))

D
dapan1121 已提交
246 247 248
#pragma pack(push, 1)

// null-terminated string instead of char array to avoid too many memory consumption in case of more than 1M tableMeta
H
Haojun Liao 已提交
249
typedef struct SEp {
D
dapan1121 已提交
250
  char     fqdn[TSDB_FQDN_LEN];
D
dapan1121 已提交
251
  uint16_t port;
H
Haojun Liao 已提交
252
} SEp;
D
dapan1121 已提交
253

S
Shengliang Guan 已提交
254
typedef struct {
D
dapan1121 已提交
255
  int32_t contLen;
L
Liu Jicong 已提交
256
  int32_t vgId;
D
dapan1121 已提交
257 258 259 260
} SMsgHead;

// Submit message for one table
typedef struct SSubmitBlk {
261
  int64_t uid;        // table unique id
L
Liu Jicong 已提交
262
  int64_t suid;       // stable id
263 264 265
  int32_t sversion;   // data schema version
  int32_t dataLen;    // data part length, not including the SSubmitBlk head
  int32_t schemaLen;  // schema length, if length is 0, no schema exists
266
  int32_t numOfRows;  // total number of rows in current submit block
267
  char    data[];
D
dapan1121 已提交
268 269 270
} SSubmitBlk;

// Submit message for this TSDB
S
Shengliang Guan 已提交
271
typedef struct {
S
Shengliang Guan 已提交
272
  SMsgHead header;
H
Hongze Cheng 已提交
273
  int64_t  version;
S
Shengliang Guan 已提交
274 275 276
  int32_t  length;
  int32_t  numOfBlocks;
  char     blocks[];
S
Shengliang Guan 已提交
277
} SSubmitReq;
D
dapan1121 已提交
278

H
Hongze Cheng 已提交
279 280 281
typedef struct {
  int32_t totalLen;
  int32_t len;
282
  STSRow* row;
H
Hongze Cheng 已提交
283 284 285
} SSubmitBlkIter;

typedef struct {
C
Cary Xu 已提交
286 287 288
  int32_t totalLen;
  int32_t len;
  // head of SSubmitBlk
C
Cary Xu 已提交
289 290 291 292 293
  int64_t uid;        // table unique id
  int64_t suid;       // stable id
  int32_t sversion;   // data schema version
  int32_t dataLen;    // data part length, not including the SSubmitBlk head
  int32_t schemaLen;  // schema length, if length is 0, no schema exists
294
  int32_t numOfRows;  // total number of rows in current submit block
C
Cary Xu 已提交
295
  // head of SSubmitBlk
C
Cary Xu 已提交
296
  int32_t     numOfBlocks;
C
Cary Xu 已提交
297
  const void* pMsg;
H
Hongze Cheng 已提交
298
} SSubmitMsgIter;
C
Cary Xu 已提交
299

L
Liu Jicong 已提交
300
int32_t tInitSubmitMsgIter(const SSubmitReq* pMsg, SSubmitMsgIter* pIter);
S
Shengliang Guan 已提交
301
int32_t tGetSubmitMsgNext(SSubmitMsgIter* pIter, SSubmitBlk** pPBlock);
C
Cary Xu 已提交
302
int32_t tInitSubmitBlkIter(SSubmitMsgIter* pMsgIter, SSubmitBlk* pBlock, SSubmitBlkIter* pIter);
C
Cary Xu 已提交
303
STSRow* tGetSubmitBlkNext(SSubmitBlkIter* pIter);
L
Liu Jicong 已提交
304
// for debug
H
Hongze Cheng 已提交
305
int32_t tPrintFixedSchemaSubmitReq(SSubmitReq* pReq, STSchema* pSchema);
H
Hongze Cheng 已提交
306

307 308 309 310 311 312 313 314
struct SSchema {
  int8_t   type;
  int8_t   flags;
  col_id_t colId;
  int32_t  bytes;
  char     name[TSDB_COL_NAME_LEN];
};

dengyihao's avatar
dengyihao 已提交
315 316 317 318 319 320 321
struct SSchema2 {
  int8_t   type;
  int8_t   flags;
  col_id_t colId;
  int32_t  bytes;
  char     name[TSDB_COL_NAME_LEN];
  char     alias[TSDB_COL_NAME_LEN];
dengyihao's avatar
dengyihao 已提交
322
};
dengyihao's avatar
dengyihao 已提交
323

324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341
typedef struct {
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     stbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
  int64_t  dbId;
  int32_t  numOfTags;
  int32_t  numOfColumns;
  int8_t   precision;
  int8_t   tableType;
  int32_t  sversion;
  int32_t  tversion;
  uint64_t suid;
  uint64_t tuid;
  int32_t  vgId;
  int8_t   sysInfo;
  SSchema* pSchemas;
} STableMetaRsp;

D
dapan1121 已提交
342
typedef struct {
L
Liu Jicong 已提交
343 344 345 346 347 348 349
  int32_t        code;
  int64_t        uid;
  char*          tblFName;
  int32_t        numOfRows;
  int32_t        affectedRows;
  int64_t        sver;
  STableMetaRsp* pMeta;
H
Hongze Cheng 已提交
350
} SSubmitBlkRsp;
D
dapan1121 已提交
351 352

typedef struct {
H
Hongze Cheng 已提交
353 354 355 356 357 358 359
  int32_t numOfRows;
  int32_t affectedRows;
  int32_t nBlocks;
  union {
    SArray*        pArray;
    SSubmitBlkRsp* pBlocks;
  };
S
Shengliang Guan 已提交
360
} SSubmitRsp;
D
dapan1121 已提交
361

H
Hongze Cheng 已提交
362 363
int32_t tEncodeSSubmitRsp(SEncoder* pEncoder, const SSubmitRsp* pRsp);
int32_t tDecodeSSubmitRsp(SDecoder* pDecoder, SSubmitRsp* pRsp);
L
Liu Jicong 已提交
364
void    tFreeSSubmitBlkRsp(void* param);
H
Hongze Cheng 已提交
365
void    tFreeSSubmitRsp(SSubmitRsp* pRsp);
366

367 368 369 370 371
#define COL_SMA_ON     ((int8_t)0x1)
#define COL_IDX_ON     ((int8_t)0x2)
#define COL_SET_NULL   ((int8_t)0x10)
#define COL_SET_VAL    ((int8_t)0x20)
#define COL_IS_SYSINFO ((int8_t)0x40)
D
dapan1121 已提交
372

wmmhello's avatar
wmmhello 已提交
373
#define COL_IS_SET(FLG)  (((FLG) & (COL_SET_VAL | COL_SET_NULL)) != 0)
H
Hongze Cheng 已提交
374
#define COL_CLR_SET(FLG) ((FLG) &= (~(COL_SET_VAL | COL_SET_NULL)))
H
Hongze Cheng 已提交
375

376
#define IS_BSMA_ON(s)  (((s)->flags & 0x01) == COL_SMA_ON)
dengyihao's avatar
dengyihao 已提交
377
#define IS_IDX_ON(s)   (((s)->flags & 0x02) == COL_IDX_ON)
378
#define IS_SET_NULL(s) (((s)->flags & COL_SET_NULL) == COL_SET_NULL)
C
Cary Xu 已提交
379

dengyihao's avatar
dengyihao 已提交
380 381 382 383 384 385 386 387 388
#define SSCHMEA_SET_IDX_ON(s) \
  do {                        \
    (s)->flags |= COL_IDX_ON; \
  } while (0)

#define SSCHMEA_SET_IDX_OFF(s)   \
  do {                           \
    (s)->flags &= (~COL_IDX_ON); \
  } while (0)
C
Cary Xu 已提交
389

dengyihao's avatar
dengyihao 已提交
390
#define SSCHMEA_TYPE(s)  ((s)->type)
C
Cary Xu 已提交
391
#define SSCHMEA_FLAGS(s) ((s)->flags)
C
Cary Xu 已提交
392 393
#define SSCHMEA_COLID(s) ((s)->colId)
#define SSCHMEA_BYTES(s) ((s)->bytes)
dengyihao's avatar
dengyihao 已提交
394
#define SSCHMEA_NAME(s)  ((s)->name)
C
Cary Xu 已提交
395

H
Hongze Cheng 已提交
396 397
typedef struct {
  int32_t  nCols;
398
  int32_t  version;
H
Hongze Cheng 已提交
399 400 401
  SSchema* pSchema;
} SSchemaWrapper;

L
Liu Jicong 已提交
402
static FORCE_INLINE SSchemaWrapper* tCloneSSchemaWrapper(const SSchemaWrapper* pSchemaWrapper) {
M
Minglei Jin 已提交
403 404
  if (pSchemaWrapper->pSchema == NULL) return NULL;

L
Liu Jicong 已提交
405 406 407
  SSchemaWrapper* pSW = (SSchemaWrapper*)taosMemoryMalloc(sizeof(SSchemaWrapper));
  if (pSW == NULL) return pSW;
  pSW->nCols = pSchemaWrapper->nCols;
408
  pSW->version = pSchemaWrapper->version;
L
Liu Jicong 已提交
409 410 411 412 413
  pSW->pSchema = (SSchema*)taosMemoryCalloc(pSW->nCols, sizeof(SSchema));
  if (pSW->pSchema == NULL) {
    taosMemoryFree(pSW);
    return NULL;
  }
M
Minglei Jin 已提交
414

L
Liu Jicong 已提交
415 416 417 418
  memcpy(pSW->pSchema, pSchemaWrapper->pSchema, pSW->nCols * sizeof(SSchema));
  return pSW;
}

419
static FORCE_INLINE void tDeleteSchemaWrapper(SSchemaWrapper* pSchemaWrapper) {
420 421 422 423
  if (pSchemaWrapper) {
    taosMemoryFree(pSchemaWrapper->pSchema);
    taosMemoryFree(pSchemaWrapper);
  }
L
Liu Jicong 已提交
424 425
}

wmmhello's avatar
wmmhello 已提交
426
static FORCE_INLINE void tDeleteSSchemaWrapperForHash(void* pSchemaWrapper) {
wmmhello's avatar
wmmhello 已提交
427 428 429
  if (pSchemaWrapper != NULL && *(SSchemaWrapper**)pSchemaWrapper != NULL) {
    taosMemoryFree((*(SSchemaWrapper**)pSchemaWrapper)->pSchema);
    taosMemoryFree(*(SSchemaWrapper**)pSchemaWrapper);
wmmhello's avatar
wmmhello 已提交
430 431 432
  }
}

L
Liu Jicong 已提交
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 467 468 469 470 471 472
static FORCE_INLINE int32_t taosEncodeSSchema(void** buf, const SSchema* pSchema) {
  int32_t tlen = 0;
  tlen += taosEncodeFixedI8(buf, pSchema->type);
  tlen += taosEncodeFixedI8(buf, pSchema->flags);
  tlen += taosEncodeFixedI32(buf, pSchema->bytes);
  tlen += taosEncodeFixedI16(buf, pSchema->colId);
  tlen += taosEncodeString(buf, pSchema->name);
  return tlen;
}

static FORCE_INLINE void* taosDecodeSSchema(const void* buf, SSchema* pSchema) {
  buf = taosDecodeFixedI8(buf, &pSchema->type);
  buf = taosDecodeFixedI8(buf, &pSchema->flags);
  buf = taosDecodeFixedI32(buf, &pSchema->bytes);
  buf = taosDecodeFixedI16(buf, &pSchema->colId);
  buf = taosDecodeStringTo(buf, pSchema->name);
  return (void*)buf;
}

static FORCE_INLINE int32_t tEncodeSSchema(SEncoder* pEncoder, const SSchema* pSchema) {
  if (tEncodeI8(pEncoder, pSchema->type) < 0) return -1;
  if (tEncodeI8(pEncoder, pSchema->flags) < 0) return -1;
  if (tEncodeI32v(pEncoder, pSchema->bytes) < 0) return -1;
  if (tEncodeI16v(pEncoder, pSchema->colId) < 0) return -1;
  if (tEncodeCStr(pEncoder, pSchema->name) < 0) return -1;
  return 0;
}

static FORCE_INLINE int32_t tDecodeSSchema(SDecoder* pDecoder, SSchema* pSchema) {
  if (tDecodeI8(pDecoder, &pSchema->type) < 0) return -1;
  if (tDecodeI8(pDecoder, &pSchema->flags) < 0) return -1;
  if (tDecodeI32v(pDecoder, &pSchema->bytes) < 0) return -1;
  if (tDecodeI16v(pDecoder, &pSchema->colId) < 0) return -1;
  if (tDecodeCStrTo(pDecoder, pSchema->name) < 0) return -1;
  return 0;
}

static FORCE_INLINE int32_t taosEncodeSSchemaWrapper(void** buf, const SSchemaWrapper* pSW) {
  int32_t tlen = 0;
  tlen += taosEncodeVariantI32(buf, pSW->nCols);
473
  tlen += taosEncodeVariantI32(buf, pSW->version);
L
Liu Jicong 已提交
474 475 476 477 478 479 480 481
  for (int32_t i = 0; i < pSW->nCols; i++) {
    tlen += taosEncodeSSchema(buf, &pSW->pSchema[i]);
  }
  return tlen;
}

static FORCE_INLINE void* taosDecodeSSchemaWrapper(const void* buf, SSchemaWrapper* pSW) {
  buf = taosDecodeVariantI32(buf, &pSW->nCols);
482
  buf = taosDecodeVariantI32(buf, &pSW->version);
483 484 485 486 487
  if (pSW->nCols > 0) {
    pSW->pSchema = (SSchema*)taosMemoryCalloc(pSW->nCols, sizeof(SSchema));
    if (pSW->pSchema == NULL) {
      return NULL;
    }
L
Liu Jicong 已提交
488

489 490 491 492 493
    for (int32_t i = 0; i < pSW->nCols; i++) {
      buf = taosDecodeSSchema(buf, &pSW->pSchema[i]);
    }
  } else {
    pSW->pSchema = NULL;
L
Liu Jicong 已提交
494 495 496 497 498 499
  }
  return (void*)buf;
}

static FORCE_INLINE int32_t tEncodeSSchemaWrapper(SEncoder* pEncoder, const SSchemaWrapper* pSW) {
  if (tEncodeI32v(pEncoder, pSW->nCols) < 0) return -1;
500
  if (tEncodeI32v(pEncoder, pSW->version) < 0) return -1;
L
Liu Jicong 已提交
501 502 503 504 505 506 507 508 509
  for (int32_t i = 0; i < pSW->nCols; i++) {
    if (tEncodeSSchema(pEncoder, &pSW->pSchema[i]) < 0) return -1;
  }

  return 0;
}

static FORCE_INLINE int32_t tDecodeSSchemaWrapper(SDecoder* pDecoder, SSchemaWrapper* pSW) {
  if (tDecodeI32v(pDecoder, &pSW->nCols) < 0) return -1;
510
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
L
Liu Jicong 已提交
511 512 513 514 515 516 517 518 519 520

  pSW->pSchema = (SSchema*)taosMemoryCalloc(pSW->nCols, sizeof(SSchema));
  if (pSW->pSchema == NULL) return -1;
  for (int32_t i = 0; i < pSW->nCols; i++) {
    if (tDecodeSSchema(pDecoder, &pSW->pSchema[i]) < 0) return -1;
  }

  return 0;
}

C
Cary Xu 已提交
521 522
static FORCE_INLINE int32_t tDecodeSSchemaWrapperEx(SDecoder* pDecoder, SSchemaWrapper* pSW) {
  if (tDecodeI32v(pDecoder, &pSW->nCols) < 0) return -1;
523
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
C
Cary Xu 已提交
524 525 526 527 528 529 530 531 532 533

  pSW->pSchema = (SSchema*)tDecoderMalloc(pDecoder, pSW->nCols * sizeof(SSchema));
  if (pSW->pSchema == NULL) return -1;
  for (int32_t i = 0; i < pSW->nCols; i++) {
    if (tDecodeSSchema(pDecoder, &pSW->pSchema[i]) < 0) return -1;
  }

  return 0;
}

D
dapan1121 已提交
534
typedef struct {
535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558
  char     name[TSDB_TABLE_FNAME_LEN];
  int8_t   igExists;
  int8_t   source;  // 1-taosX or 0-taosClient
  int8_t   reserved[6];
  tb_uid_t suid;
  int64_t  delay1;
  int64_t  delay2;
  int64_t  watermark1;
  int64_t  watermark2;
  int32_t  ttl;
  int32_t  colVer;
  int32_t  tagVer;
  int32_t  numOfColumns;
  int32_t  numOfTags;
  int32_t  numOfFuncs;
  int32_t  commentLen;
  int32_t  ast1Len;
  int32_t  ast2Len;
  SArray*  pColumns;  // array of SField
  SArray*  pTags;     // array of SField
  SArray*  pFuncs;
  char*    pComment;
  char*    pAst1;
  char*    pAst2;
559 560
  int64_t  deleteMark1;
  int64_t  deleteMark2;
S
Shengliang Guan 已提交
561
} SMCreateStbReq;
D
dapan1121 已提交
562

S
Shengliang Guan 已提交
563 564
int32_t tSerializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
int32_t tDeserializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
565
void    tFreeSMCreateStbReq(SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
566

567 568 569 570 571 572 573 574
typedef struct {
  STableMetaRsp* pMeta;
} SMCreateStbRsp;

int32_t tEncodeSMCreateStbRsp(SEncoder* pEncoder, const SMCreateStbRsp* pRsp);
int32_t tDecodeSMCreateStbRsp(SDecoder* pDecoder, SMCreateStbRsp* pRsp);
void    tFreeSMCreateStbRsp(SMCreateStbRsp* pRsp);

D
dapan1121 已提交
575
typedef struct {
576 577 578 579 580
  char     name[TSDB_TABLE_FNAME_LEN];
  int8_t   igNotExists;
  int8_t   source;  // 1-taosX or 0-taosClient
  int8_t   reserved[6];
  tb_uid_t suid;
S
Shengliang Guan 已提交
581
} SMDropStbReq;
S
Shengliang Guan 已提交
582

S
Shengliang Guan 已提交
583 584
int32_t tSerializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
int32_t tDeserializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
S
Shengliang Guan 已提交
585

S
Shengliang Guan 已提交
586 587 588
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
S
Shengliang Guan 已提交
589 590
  int32_t numOfFields;
  SArray* pFields;
X
Xiaoyu Wang 已提交
591 592 593
  int32_t ttl;
  int32_t commentLen;
  char*   comment;
S
Shengliang Guan 已提交
594
} SMAlterStbReq;
D
dapan1121 已提交
595

S
Shengliang Guan 已提交
596 597 598
int32_t tSerializeSMAlterStbReq(void* buf, int32_t bufLen, SMAlterStbReq* pReq);
int32_t tDeserializeSMAlterStbReq(void* buf, int32_t bufLen, SMAlterStbReq* pReq);
void    tFreeSMAltertbReq(SMAlterStbReq* pReq);
D
dapan1121 已提交
599 600

typedef struct SEpSet {
601 602 603
  int8_t inUse;
  int8_t numOfEps;
  SEp    eps[TSDB_MAX_REPLICA];
D
dapan1121 已提交
604 605
} SEpSet;

H
Hongze Cheng 已提交
606 607
int32_t tEncodeSEpSet(SEncoder* pEncoder, const SEpSet* pEp);
int32_t tDecodeSEpSet(SDecoder* pDecoder, SEpSet* pEp);
S
Shengliang Guan 已提交
608
int32_t taosEncodeSEpSet(void** buf, const SEpSet* pEp);
609
void*   taosDecodeSEpSet(const void* buf, SEpSet* pEp);
L
Liu Jicong 已提交
610

611 612
int32_t tSerializeSEpSet(void* buf, int32_t bufLen, const SEpSet* pEpset);
int32_t tDeserializeSEpSet(void* buf, int32_t buflen, SEpSet* pEpset);
dengyihao's avatar
dengyihao 已提交
613

D
dapan1121 已提交
614
typedef struct {
L
Liu Jicong 已提交
615
  int8_t  connType;
D
dapan1121 已提交
616
  int32_t pid;
S
Shengliang Guan 已提交
617 618
  char    app[TSDB_APP_NAME_LEN];
  char    db[TSDB_DB_NAME_LEN];
dengyihao's avatar
dengyihao 已提交
619 620
  char    user[TSDB_USER_LEN];
  char    passwd[TSDB_PASSWORD_LEN];
621
  int64_t startTime;
622
  char    sVer[TSDB_VERSION_LEN];
S
Shengliang Guan 已提交
623
} SConnectReq;
L
Liu Jicong 已提交
624

S
Shengliang Guan 已提交
625 626
int32_t tSerializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
int32_t tDeserializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
627

L
Liu Jicong 已提交
628
typedef struct {
629 630
  int32_t  acctId;
  int64_t  clusterId;
D
dapan1121 已提交
631
  uint32_t connId;
D
dapan 已提交
632
  int32_t  dnodeNum;
633
  int8_t   superUser;
634
  int8_t   sysInfo;
635 636
  int8_t   connType;
  SEpSet   epSet;
dengyihao's avatar
dengyihao 已提交
637
  int32_t  svrTimestamp;
638
  int32_t  passVer;
D
dapan1121 已提交
639 640
  char     sVer[TSDB_VERSION_LEN];
  char     sDetailVer[128];
L
Liu Jicong 已提交
641
} SConnectRsp;
L
Liu Jicong 已提交
642

S
Shengliang Guan 已提交
643 644 645
int32_t tSerializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);
int32_t tDeserializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);

L
Liu Jicong 已提交
646 647 648 649 650 651 652 653
typedef struct {
  char    user[TSDB_USER_LEN];
  char    pass[TSDB_PASSWORD_LEN];
  int32_t maxUsers;
  int32_t maxDbs;
  int32_t maxTimeSeries;
  int32_t maxStreams;
  int32_t accessState;  // Configured only by command
654
  int64_t maxStorage;
L
Liu Jicong 已提交
655
} SCreateAcctReq, SAlterAcctReq;
L
Liu Jicong 已提交
656

S
Shengliang Guan 已提交
657 658
int32_t tSerializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
int32_t tDeserializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
S
Shengliang Guan 已提交
659

L
Liu Jicong 已提交
660 661 662
typedef struct {
  char user[TSDB_USER_LEN];
} SDropUserReq, SDropAcctReq;
D
dapan1121 已提交
663

S
Shengliang Guan 已提交
664 665
int32_t tSerializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
int32_t tDeserializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
S
Shengliang Guan 已提交
666

D
dapan1121 已提交
667
typedef struct {
S
Shengliang Guan 已提交
668 669
  int8_t createType;
  int8_t superUser;  // denote if it is a super user or not
670 671
  int8_t sysInfo;
  int8_t enable;
S
Shengliang Guan 已提交
672
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
673
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
674 675
} SCreateUserReq;

S
Shengliang Guan 已提交
676 677
int32_t tSerializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
int32_t tDeserializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
S
Shengliang Guan 已提交
678 679

typedef struct {
X
Xiaoyu Wang 已提交
680 681 682 683 684 685 686 687 688 689
  int8_t  alterType;
  int8_t  superUser;
  int8_t  sysInfo;
  int8_t  enable;
  char    user[TSDB_USER_LEN];
  char    pass[TSDB_USET_PASSWORD_LEN];
  char    objname[TSDB_DB_FNAME_LEN];  // db or topic
  char    tabName[TSDB_TABLE_NAME_LEN];
  char*   tagCond;
  int32_t tagCondLen;
S
Shengliang Guan 已提交
690 691
} SAlterUserReq;

S
Shengliang Guan 已提交
692 693
int32_t tSerializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
int32_t tDeserializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
X
Xiaoyu Wang 已提交
694
void    tFreeSAlterUserReq(SAlterUserReq* pReq);
D
dapan1121 已提交
695

S
Shengliang Guan 已提交
696 697 698 699
typedef struct {
  char user[TSDB_USER_LEN];
} SGetUserAuthReq;

S
Shengliang Guan 已提交
700 701
int32_t tSerializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
int32_t tDeserializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
S
Shengliang Guan 已提交
702 703 704

typedef struct {
  char      user[TSDB_USER_LEN];
D
dapan 已提交
705
  int32_t   version;
S
Shengliang Guan 已提交
706
  int8_t    superAuth;
707 708 709
  int8_t    sysInfo;
  int8_t    enable;
  int8_t    reserve;
D
dapan 已提交
710
  SHashObj* createdDbs;
S
Shengliang Guan 已提交
711 712
  SHashObj* readDbs;
  SHashObj* writeDbs;
C
table  
cademfly 已提交
713 714
  SHashObj* readTbs;
  SHashObj* writeTbs;
X
Xiaoyu Wang 已提交
715
  SHashObj* useDbs;
S
Shengliang Guan 已提交
716 717
} SGetUserAuthRsp;

S
Shengliang Guan 已提交
718 719
int32_t tSerializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
int32_t tDeserializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
720
void    tFreeSGetUserAuthRsp(SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
721

K
kailixu 已提交
722
typedef struct SUserPassVersion {
K
kailixu 已提交
723 724
  char    user[TSDB_USER_LEN];
  int32_t version;
K
kailixu 已提交
725 726 727 728
} SUserPassVersion;

typedef SGetUserAuthReq SGetUserPassReq;
typedef SUserPassVersion SGetUserPassRsp;
K
kailixu 已提交
729

D
dapan1121 已提交
730
/*
L
Liu Jicong 已提交
731
 * for client side struct, only column id, type, bytes are necessary
D
dapan1121 已提交
732 733
 * But for data in vnode side, we need all the following information.
 */
S
Shengliang Guan 已提交
734
typedef struct {
H
Haojun Liao 已提交
735
  union {
736 737
    col_id_t colId;
    int16_t  slotId;
H
Haojun Liao 已提交
738 739
  };

L
Liu Jicong 已提交
740 741
  uint8_t precision;
  uint8_t scale;
H
Haojun Liao 已提交
742 743
  int32_t bytes;
  int8_t  type;
D
dapan1121 已提交
744 745 746 747 748 749 750 751
} SColumnInfo;

typedef struct STimeWindow {
  TSKEY skey;
  TSKEY ekey;
} STimeWindow;

typedef struct {
S
Shengliang Guan 已提交
752 753 754 755
  int32_t tsOffset;       // offset value in current msg body, NOTE: ts list is compressed
  int32_t tsLen;          // total length of ts comp block
  int32_t tsNumOfBlocks;  // ts comp block numbers
  int32_t tsOrder;        // ts comp block order
D
dapan1121 已提交
756 757
} STsBufInfo;

S
Shengliang Guan 已提交
758
typedef struct {
S
Shengliang Guan 已提交
759
  int32_t tz;  // query client timezone
D
dapan1121 已提交
760 761
  char    intervalUnit;
  char    slidingUnit;
762
  char    offsetUnit;
H
Haojun Liao 已提交
763
  int8_t  precision;
D
dapan1121 已提交
764 765 766 767 768 769
  int64_t interval;
  int64_t sliding;
  int64_t offset;
} SInterval;

typedef struct {
S
Shengliang Guan 已提交
770
  int32_t code;
D
dapan1121 已提交
771 772 773
  char    tbFName[TSDB_TABLE_FNAME_LEN];
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
774
  int64_t affectedRows;
D
dapan1121 已提交
775 776
} SQueryTableRsp;

L
Liu Jicong 已提交
777
int32_t tSerializeSQueryTableRsp(void* buf, int32_t bufLen, SQueryTableRsp* pRsp);
D
dapan1121 已提交
778

L
Liu Jicong 已提交
779
int32_t tDeserializeSQueryTableRsp(void* buf, int32_t bufLen, SQueryTableRsp* pRsp);
D
dapan1121 已提交
780

D
dapan1121 已提交
781 782 783 784 785 786
typedef struct {
  SMsgHead header;
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
} STableCfgReq;

D
dapan1121 已提交
787 788 789 790 791 792 793 794 795 796 797 798
typedef struct {
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     stbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
  int32_t  numOfTags;
  int32_t  numOfColumns;
  int8_t   tableType;
  int64_t  delay1;
  int64_t  delay2;
  int64_t  watermark1;
  int64_t  watermark2;
  int32_t  ttl;
D
dapan1121 已提交
799 800 801
  SArray*  pFuncs;
  int32_t  commentLen;
  char*    pComment;
D
dapan1121 已提交
802
  SSchema* pSchemas;
D
dapan1121 已提交
803 804
  int32_t  tagsLen;
  char*    pTags;
D
dapan1121 已提交
805 806
} STableCfg;

D
dapan1121 已提交
807 808
typedef STableCfg STableCfgRsp;

L
Liu Jicong 已提交
809 810
int32_t tSerializeSTableCfgReq(void* buf, int32_t bufLen, STableCfgReq* pReq);
int32_t tDeserializeSTableCfgReq(void* buf, int32_t bufLen, STableCfgReq* pReq);
D
dapan1121 已提交
811

L
Liu Jicong 已提交
812 813 814
int32_t tSerializeSTableCfgRsp(void* buf, int32_t bufLen, STableCfgRsp* pRsp);
int32_t tDeserializeSTableCfgRsp(void* buf, int32_t bufLen, STableCfgRsp* pRsp);
void    tFreeSTableCfgRsp(STableCfgRsp* pRsp);
D
dapan1121 已提交
815

D
dapan1121 已提交
816
typedef struct {
817
  char    db[TSDB_DB_FNAME_LEN];
818
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
819 820 821 822
  int32_t numOfStables;  // single_stable
  int32_t buffer;        // MB
  int32_t pageSize;
  int32_t pages;
823
  int32_t cacheLastSize;
S
Shengliang Guan 已提交
824 825 826 827
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
S
Shengliang Guan 已提交
828 829
  int32_t minRows;
  int32_t maxRows;
830
  int32_t walFsyncPeriod;
S
Shengliang Guan 已提交
831
  int8_t  walLevel;
S
Shengliang Guan 已提交
832 833 834
  int8_t  precision;  // time resolution
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
835
  int8_t  strict;
836
  int8_t  cacheLast;
X
Xiaoyu Wang 已提交
837
  int8_t  schemaless;
S
Shengliang Guan 已提交
838
  int8_t  ignoreExist;
S
Shengliang Guan 已提交
839 840
  int32_t numOfRetensions;
  SArray* pRetensions;  // SRetention
X
Xiaoyu Wang 已提交
841
  int32_t walRetentionPeriod;
842
  int64_t walRetentionSize;
X
Xiaoyu Wang 已提交
843
  int32_t walRollPeriod;
844
  int64_t walSegmentSize;
845
  int32_t sstTrigger;
846 847
  int16_t hashPrefix;
  int16_t hashSuffix;
848
  int32_t tsdbPageSize;
S
Shengliang Guan 已提交
849
} SCreateDbReq;
S
Shengliang Guan 已提交
850

S
Shengliang Guan 已提交
851 852
int32_t tSerializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
int32_t tDeserializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
S
Shengliang Guan 已提交
853
void    tFreeSCreateDbReq(SCreateDbReq* pReq);
S
Shengliang Guan 已提交
854

S
Shengliang Guan 已提交
855
typedef struct {
856
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
857 858 859
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
860
  int32_t cacheLastSize;
S
Shengliang Guan 已提交
861
  int32_t daysPerFile;
S
Shengliang Guan 已提交
862 863 864
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
865
  int32_t walFsyncPeriod;
S
Shengliang Guan 已提交
866
  int8_t  walLevel;
S
Shengliang Guan 已提交
867
  int8_t  strict;
868
  int8_t  cacheLast;
X
Xiaoyu Wang 已提交
869
  int8_t  replications;
870
  int32_t sstTrigger;
871
  int32_t minRows;
872 873
  int32_t walRetentionPeriod;
  int32_t walRetentionSize;
S
Shengliang Guan 已提交
874
} SAlterDbReq;
S
Shengliang Guan 已提交
875

S
Shengliang Guan 已提交
876 877 878
int32_t tSerializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);
int32_t tDeserializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);

S
Shengliang Guan 已提交
879
typedef struct {
S
Shengliang Guan 已提交
880
  char   db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
881
  int8_t ignoreNotExists;
S
Shengliang Guan 已提交
882
} SDropDbReq;
S
Shengliang Guan 已提交
883

S
Shengliang Guan 已提交
884 885 886
int32_t tSerializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);
int32_t tDeserializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);

S
Shengliang Guan 已提交
887
typedef struct {
L
Liu Jicong 已提交
888 889
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
S
Shengliang Guan 已提交
890 891
} SDropDbRsp;

S
Shengliang Guan 已提交
892 893 894
int32_t tSerializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);
int32_t tDeserializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);

S
Shengliang Guan 已提交
895 896
typedef struct {
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
897
  int64_t dbId;
898
  int32_t vgVersion;
L
Liu Jicong 已提交
899
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
900
  int64_t stateTs;     // ms
S
Shengliang Guan 已提交
901
} SUseDbReq;
S
Shengliang Guan 已提交
902

S
Shengliang Guan 已提交
903 904
int32_t tSerializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
int32_t tDeserializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
S
Shengliang Guan 已提交
905 906

typedef struct {
L
Liu Jicong 已提交
907 908 909 910
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
  int32_t vgVersion;
  int32_t vgNum;
911 912
  int16_t hashPrefix;
  int16_t hashSuffix;
L
Liu Jicong 已提交
913 914
  int8_t  hashMethod;
  SArray* pVgroupInfos;  // Array of SVgroupInfo
915
  int32_t errCode;
916
  int64_t stateTs;  // ms
S
Shengliang Guan 已提交
917 918
} SUseDbRsp;

L
Liu Jicong 已提交
919
int32_t tSerializeSUseDbRsp(void* buf, int32_t bufLen, const SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
920
int32_t tDeserializeSUseDbRsp(void* buf, int32_t bufLen, SUseDbRsp* pRsp);
H
Hongze Cheng 已提交
921 922
int32_t tSerializeSUseDbRspImp(SEncoder* pEncoder, const SUseDbRsp* pRsp);
int32_t tDeserializeSUseDbRspImp(SDecoder* pDecoder, SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
923 924
void    tFreeSUsedbRsp(SUseDbRsp* pRsp);

D
dapan1121 已提交
925
typedef struct {
dengyihao's avatar
dengyihao 已提交
926
  char db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
927 928 929 930 931
} SDbCfgReq;

int32_t tSerializeSDbCfgReq(void* buf, int32_t bufLen, SDbCfgReq* pReq);
int32_t tDeserializeSDbCfgReq(void* buf, int32_t bufLen, SDbCfgReq* pReq);

X
Xiaoyu Wang 已提交
932
typedef struct {
933 934
  char    db[TSDB_DB_FNAME_LEN];
  int32_t maxSpeed;
X
Xiaoyu Wang 已提交
935 936 937 938 939
} STrimDbReq;

int32_t tSerializeSTrimDbReq(void* buf, int32_t bufLen, STrimDbReq* pReq);
int32_t tDeserializeSTrimDbReq(void* buf, int32_t bufLen, STrimDbReq* pReq);

S
Shengliang Guan 已提交
940
typedef struct {
941
  int32_t timestamp;
S
Shengliang Guan 已提交
942 943 944 945 946 947 948 949 950 951 952 953
} SVTrimDbReq;

int32_t tSerializeSVTrimDbReq(void* buf, int32_t bufLen, SVTrimDbReq* pReq);
int32_t tDeserializeSVTrimDbReq(void* buf, int32_t bufLen, SVTrimDbReq* pReq);

typedef struct {
  int32_t timestamp;
} SVDropTtlTableReq;

int32_t tSerializeSVDropTtlTableReq(void* buf, int32_t bufLen, SVDropTtlTableReq* pReq);
int32_t tDeserializeSVDropTtlTableReq(void* buf, int32_t bufLen, SVDropTtlTableReq* pReq);

D
dapan1121 已提交
954 955
typedef struct {
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
956 957
  int32_t numOfStables;
  int32_t buffer;
958
  int32_t cacheSize;
S
Shengliang Guan 已提交
959 960
  int32_t pageSize;
  int32_t pages;
D
dapan1121 已提交
961 962 963 964 965 966
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t minRows;
  int32_t maxRows;
967
  int32_t walFsyncPeriod;
968 969
  int16_t hashPrefix;
  int16_t hashSuffix;
D
dapan1121 已提交
970 971 972 973
  int8_t  walLevel;
  int8_t  precision;
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
974
  int8_t  strict;
975
  int8_t  cacheLast;
976 977 978 979 980
  int32_t tsdbPageSize;
  int32_t walRetentionPeriod;
  int32_t walRollPeriod;
  int64_t walRetentionSize;
  int64_t walSegmentSize;
981 982
  int32_t numOfRetensions;
  SArray* pRetensions;
wmmhello's avatar
wmmhello 已提交
983
  int8_t  schemaless;
984
  int16_t sstTrigger;
D
dapan1121 已提交
985 986 987 988 989
} SDbCfgRsp;

int32_t tSerializeSDbCfgRsp(void* buf, int32_t bufLen, const SDbCfgRsp* pRsp);
int32_t tDeserializeSDbCfgRsp(void* buf, int32_t bufLen, SDbCfgRsp* pRsp);

D
dapan1121 已提交
990 991 992 993 994 995 996
typedef struct {
  int32_t rowNum;
} SQnodeListReq;

int32_t tSerializeSQnodeListReq(void* buf, int32_t bufLen, SQnodeListReq* pReq);
int32_t tDeserializeSQnodeListReq(void* buf, int32_t bufLen, SQnodeListReq* pReq);

D
dapan1121 已提交
997 998 999 1000 1001 1002 1003
typedef struct {
  int32_t rowNum;
} SDnodeListReq;

int32_t tSerializeSDnodeListReq(void* buf, int32_t bufLen, SDnodeListReq* pReq);
int32_t tDeserializeSDnodeListReq(void* buf, int32_t bufLen, SDnodeListReq* pReq);

D
dapan1121 已提交
1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017
typedef struct {
  int32_t useless;  // useless
} SServerVerReq;

int32_t tSerializeSServerVerReq(void* buf, int32_t bufLen, SServerVerReq* pReq);
int32_t tDeserializeSServerVerReq(void* buf, int32_t bufLen, SServerVerReq* pReq);

typedef struct {
  char ver[TSDB_VERSION_LEN];
} SServerVerRsp;

int32_t tSerializeSServerVerRsp(void* buf, int32_t bufLen, SServerVerRsp* pRsp);
int32_t tDeserializeSServerVerRsp(void* buf, int32_t bufLen, SServerVerRsp* pRsp);

D
dapan1121 已提交
1018 1019 1020 1021 1022
typedef struct SQueryNodeAddr {
  int32_t nodeId;  // vgId or qnodeId
  SEpSet  epSet;
} SQueryNodeAddr;

D
dapan1121 已提交
1023
typedef struct {
D
dapan1121 已提交
1024 1025 1026 1027
  SQueryNodeAddr addr;
  uint64_t       load;
} SQueryNodeLoad;

D
dapan1121 已提交
1028
typedef struct {
D
dapan1121 已提交
1029
  SArray* qnodeList;  // SArray<SQueryNodeLoad>
D
dapan1121 已提交
1030 1031 1032 1033 1034 1035
} SQnodeListRsp;

int32_t tSerializeSQnodeListRsp(void* buf, int32_t bufLen, SQnodeListRsp* pRsp);
int32_t tDeserializeSQnodeListRsp(void* buf, int32_t bufLen, SQnodeListRsp* pRsp);
void    tFreeSQnodeListRsp(SQnodeListRsp* pRsp);

D
dapan1121 已提交
1036 1037 1038 1039 1040 1041 1042 1043
typedef struct {
  SArray* dnodeList;  // SArray<SEpSet>
} SDnodeListRsp;

int32_t tSerializeSDnodeListRsp(void* buf, int32_t bufLen, SDnodeListRsp* pRsp);
int32_t tDeserializeSDnodeListRsp(void* buf, int32_t bufLen, SDnodeListRsp* pRsp);
void    tFreeSDnodeListRsp(SDnodeListRsp* pRsp);

S
Shengliang Guan 已提交
1044 1045 1046 1047 1048 1049 1050
typedef struct {
  SArray* pArray;  // Array of SUseDbRsp
} SUseDbBatchRsp;

int32_t tSerializeSUseDbBatchRsp(void* buf, int32_t bufLen, SUseDbBatchRsp* pRsp);
int32_t tDeserializeSUseDbBatchRsp(void* buf, int32_t bufLen, SUseDbBatchRsp* pRsp);
void    tFreeSUseDbBatchRsp(SUseDbBatchRsp* pRsp);
S
Shengliang Guan 已提交
1051

D
dapan 已提交
1052 1053 1054 1055 1056 1057 1058 1059
typedef struct {
  SArray* pArray;  // Array of SGetUserAuthRsp
} SUserAuthBatchRsp;

int32_t tSerializeSUserAuthBatchRsp(void* buf, int32_t bufLen, SUserAuthBatchRsp* pRsp);
int32_t tDeserializeSUserAuthBatchRsp(void* buf, int32_t bufLen, SUserAuthBatchRsp* pRsp);
void    tFreeSUserAuthBatchRsp(SUserAuthBatchRsp* pRsp);

K
kailixu 已提交
1060 1061 1062 1063 1064 1065 1066 1067
typedef struct {
  SArray* pArray;  // Array of SGetUserPassRsp
} SUserPassBatchRsp;

int32_t tSerializeSUserPassBatchRsp(void* buf, int32_t bufLen, SUserPassBatchRsp* pRsp);
int32_t tDeserializeSUserPassBatchRsp(void* buf, int32_t bufLen, SUserPassBatchRsp* pRsp);
void    tFreeSUserPassBatchRsp(SUserPassBatchRsp* pRsp);

S
Shengliang Guan 已提交
1068
typedef struct {
1069 1070
  char        db[TSDB_DB_FNAME_LEN];
  STimeWindow timeRange;
S
Shengliang Guan 已提交
1071
} SCompactDbReq;
S
Shengliang Guan 已提交
1072

S
Shengliang Guan 已提交
1073 1074
int32_t tSerializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
int32_t tDeserializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
D
dapan1121 已提交
1075 1076

typedef struct {
S
Shengliang Guan 已提交
1077
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang 已提交
1078
  int8_t  igExists;
S
Shengliang Guan 已提交
1079 1080
  int8_t  funcType;
  int8_t  scriptType;
S
Shengliang Guan 已提交
1081
  int8_t  outputType;
S
Shengliang Guan 已提交
1082
  int32_t outputLen;
S
Shengliang Guan 已提交
1083
  int32_t bufSize;
1084
  int32_t codeLen;
S
Shengliang 已提交
1085
  int64_t signature;
1086 1087
  char*   pComment;
  char*   pCode;
1088
  int8_t  orReplace;
S
Shengliang Guan 已提交
1089
} SCreateFuncReq;
D
dapan1121 已提交
1090

S
Shengliang Guan 已提交
1091 1092
int32_t tSerializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
int32_t tDeserializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
1093
void    tFreeSCreateFuncReq(SCreateFuncReq* pReq);
S
Shengliang Guan 已提交
1094

D
dapan1121 已提交
1095
typedef struct {
S
Shengliang 已提交
1096 1097
  char   name[TSDB_FUNC_NAME_LEN];
  int8_t igNotExists;
S
Shengliang Guan 已提交
1098
} SDropFuncReq;
S
Shengliang Guan 已提交
1099

S
Shengliang Guan 已提交
1100 1101 1102
int32_t tSerializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);
int32_t tDeserializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);

S
Shengliang Guan 已提交
1103 1104
typedef struct {
  int32_t numOfFuncs;
D
dapan1121 已提交
1105
  bool    ignoreCodeComment;
S
Shengliang Guan 已提交
1106
  SArray* pFuncNames;
S
Shengliang Guan 已提交
1107
} SRetrieveFuncReq;
D
dapan1121 已提交
1108

S
Shengliang Guan 已提交
1109 1110
int32_t tSerializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
int32_t tDeserializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
1111
void    tFreeSRetrieveFuncReq(SRetrieveFuncReq* pReq);
S
Shengliang Guan 已提交
1112

D
dapan1121 已提交
1113 1114
typedef struct {
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang Guan 已提交
1115 1116 1117 1118
  int8_t  funcType;
  int8_t  scriptType;
  int8_t  outputType;
  int32_t outputLen;
D
dapan1121 已提交
1119
  int32_t bufSize;
S
Shengliang 已提交
1120
  int64_t signature;
S
Shengliang Guan 已提交
1121 1122
  int32_t commentSize;
  int32_t codeSize;
1123 1124
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
1125
} SFuncInfo;
D
dapan1121 已提交
1126

1127 1128 1129 1130 1131
typedef struct {
  int32_t funcVersion;
  int64_t funcCreatedTime;
} SFuncExtraInfo;

D
dapan1121 已提交
1132
typedef struct {
S
Shengliang Guan 已提交
1133
  int32_t numOfFuncs;
S
Shengliang Guan 已提交
1134
  SArray* pFuncInfos;
1135
  SArray* pFuncExtraInfos;
S
Shengliang Guan 已提交
1136
} SRetrieveFuncRsp;
D
dapan1121 已提交
1137

S
Shengliang Guan 已提交
1138 1139
int32_t tSerializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
int32_t tDeserializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
L
Liu Jicong 已提交
1140
void    tFreeSFuncInfo(SFuncInfo* pInfo);
1141
void    tFreeSRetrieveFuncRsp(SRetrieveFuncRsp* pRsp);
S
Shengliang Guan 已提交
1142

D
dapan1121 已提交
1143
typedef struct {
S
Shengliang Guan 已提交
1144
  int32_t statusInterval;
S
Shengliang Guan 已提交
1145
  int64_t checkTime;                  // 1970-01-01 00:00:00.000
S
Shengliang Guan 已提交
1146 1147 1148
  char    timezone[TD_TIMEZONE_LEN];  // tsTimezone
  char    locale[TD_LOCALE_LEN];      // tsLocale
  char    charset[TD_LOCALE_LEN];     // tsCharset
S
Shengliang Guan 已提交
1149
} SClusterCfg;
D
dapan1121 已提交
1150

1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162
typedef struct {
  int32_t openVnodes;
  int32_t totalVnodes;
  int32_t masterNum;
  int64_t numOfSelectReqs;
  int64_t numOfInsertReqs;
  int64_t numOfInsertSuccessReqs;
  int64_t numOfBatchInsertReqs;
  int64_t numOfBatchInsertSuccessReqs;
  int64_t errors;
} SVnodesStat;

S
Shengliang Guan 已提交
1163 1164
typedef struct {
  int32_t vgId;
1165 1166
  int8_t  syncState;
  int8_t  syncRestore;
1167
  int8_t  syncCanRead;
1168
  int64_t cacheUsage;
S
Shengliang Guan 已提交
1169 1170
  int64_t numOfTables;
  int64_t numOfTimeSeries;
S
Shengliang Guan 已提交
1171 1172 1173
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
S
Shengliang Guan 已提交
1174 1175 1176 1177 1178
  int64_t numOfSelectReqs;
  int64_t numOfInsertReqs;
  int64_t numOfInsertSuccessReqs;
  int64_t numOfBatchInsertReqs;
  int64_t numOfBatchInsertSuccessReqs;
D
dapan1121 已提交
1179
  int32_t numOfCachedTables;
S
Shengliang Guan 已提交
1180 1181
} SVnodeLoad;

S
Shengliang Guan 已提交
1182
typedef struct {
1183 1184
  int8_t syncState;
  int8_t syncRestore;
S
Shengliang Guan 已提交
1185 1186
} SMnodeLoad;

D
dapan1121 已提交
1187 1188 1189 1190 1191 1192 1193
typedef struct {
  int32_t dnodeId;
  int64_t numOfProcessedQuery;
  int64_t numOfProcessedCQuery;
  int64_t numOfProcessedFetch;
  int64_t numOfProcessedDrop;
  int64_t numOfProcessedHb;
D
dapan1121 已提交
1194
  int64_t numOfProcessedDelete;
D
dapan1121 已提交
1195 1196 1197 1198 1199 1200 1201
  int64_t cacheDataSize;
  int64_t numOfQueryInQueue;
  int64_t numOfFetchInQueue;
  int64_t timeInQueryQueue;
  int64_t timeInFetchQueue;
} SQnodeLoad;

S
Shengliang Guan 已提交
1202
typedef struct {
S
Shengliang Guan 已提交
1203 1204
  int32_t     sver;      // software version
  int64_t     dnodeVer;  // dnode table version in sdb
S
Shengliang Guan 已提交
1205
  int32_t     dnodeId;
1206
  int64_t     clusterId;
S
Shengliang Guan 已提交
1207 1208
  int64_t     rebootTime;
  int64_t     updateTime;
S
Shengliang Guan 已提交
1209
  float       numOfCores;
S
Shengliang Guan 已提交
1210
  int32_t     numOfSupportVnodes;
1211 1212
  int64_t     memTotal;
  int64_t     memAvail;
S
Shengliang Guan 已提交
1213
  char        dnodeEp[TSDB_EP_LEN];
1214
  SMnodeLoad  mload;
D
dapan1121 已提交
1215
  SQnodeLoad  qload;
S
Shengliang Guan 已提交
1216
  SClusterCfg clusterCfg;
S
Shengliang Guan 已提交
1217
  SArray*     pVloads;  // array of SVnodeLoad
1218
  int32_t     statusSeq;
S
Shengliang Guan 已提交
1219
} SStatusReq;
D
dapan1121 已提交
1220

S
Shengliang Guan 已提交
1221 1222
int32_t tSerializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
int32_t tDeserializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
S
Shengliang Guan 已提交
1223
void    tFreeSStatusReq(SStatusReq* pReq);
S
Shengliang Guan 已提交
1224

D
dapan1121 已提交
1225
typedef struct {
S
Shengliang Guan 已提交
1226
  int32_t dnodeId;
1227
  int64_t clusterId;
D
dapan1121 已提交
1228 1229 1230
} SDnodeCfg;

typedef struct {
1231 1232 1233
  int32_t id;
  int8_t  isMnode;
  SEp     ep;
D
dapan1121 已提交
1234 1235
} SDnodeEp;

K
kailixu 已提交
1236 1237
typedef struct {
  int32_t id;
K
kailixu 已提交
1238
  int8_t  isMnode;
K
kailixu 已提交
1239 1240 1241 1242 1243
  SEp     ep;
  char    active[TSDB_ACTIVE_KEY_LEN];
  char    connActive[TSDB_CONN_ACTIVE_KEY_LEN];
} SDnodeInfo;

D
dapan1121 已提交
1244
typedef struct {
S
Shengliang Guan 已提交
1245
  int64_t   dnodeVer;
S
Shengliang Guan 已提交
1246
  SDnodeCfg dnodeCfg;
S
Shengliang Guan 已提交
1247
  SArray*   pDnodeEps;  // Array of SDnodeEp
1248
  int32_t   statusSeq;
D
dapan1121 已提交
1249 1250
} SStatusRsp;

S
Shengliang Guan 已提交
1251 1252
int32_t tSerializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
int32_t tDeserializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
S
shm  
Shengliang Guan 已提交
1253
void    tFreeSStatusRsp(SStatusRsp* pRsp);
S
Shengliang Guan 已提交
1254 1255

typedef struct {
S
Shengliang Guan 已提交
1256 1257 1258 1259 1260
  int32_t reserved;
} SMTimerReq;

int32_t tSerializeSMTimerMsg(void* buf, int32_t bufLen, SMTimerReq* pReq);
int32_t tDeserializeSMTimerMsg(void* buf, int32_t bufLen, SMTimerReq* pReq);
S
Shengliang Guan 已提交
1261

1262 1263 1264 1265 1266 1267 1268
typedef struct {
  int64_t tick;
} SMStreamTickReq;

int32_t tSerializeSMStreamTickMsg(void* buf, int32_t bufLen, SMStreamTickReq* pReq);
int32_t tDeserializeSMStreamTickMsg(void* buf, int32_t bufLen, SMStreamTickReq* pReq);

D
dapan1121 已提交
1269
typedef struct {
S
Shengliang Guan 已提交
1270 1271 1272
  int32_t  id;
  uint16_t port;                 // node sync Port
  char     fqdn[TSDB_FQDN_LEN];  // node FQDN
S
Shengliang Guan 已提交
1273 1274 1275
} SReplica;

typedef struct {
S
Shengliang Guan 已提交
1276
  int32_t  vgId;
1277
  char     db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1278
  int64_t  dbUid;
1279
  int32_t  vgVersion;
L
Liu Jicong 已提交
1280
  int32_t  numOfStables;
S
Shengliang Guan 已提交
1281 1282 1283
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
1284
  int32_t  cacheLastSize;
S
Shengliang Guan 已提交
1285 1286 1287 1288
  int32_t  daysPerFile;
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
Shengliang Guan 已提交
1289 1290
  int32_t  minRows;
  int32_t  maxRows;
1291
  int32_t  walFsyncPeriod;
D
dapan1121 已提交
1292 1293
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1294
  int8_t   hashMethod;
S
Shengliang Guan 已提交
1295
  int8_t   walLevel;
S
Shengliang Guan 已提交
1296 1297
  int8_t   precision;
  int8_t   compression;
S
Shengliang Guan 已提交
1298
  int8_t   strict;
1299
  int8_t   cacheLast;
1300
  int8_t   isTsma;
S
Shengliang Guan 已提交
1301
  int8_t   replica;
S
Shengliang Guan 已提交
1302 1303
  int8_t   selfIndex;
  SReplica replicas[TSDB_MAX_REPLICA];
S
sma  
Shengliang Guan 已提交
1304 1305
  int32_t  numOfRetensions;
  SArray*  pRetensions;  // SRetention
1306
  void*    pTsma;
S
Shengliang Guan 已提交
1307
  int32_t  walRetentionPeriod;
L
Liu Jicong 已提交
1308
  int64_t  walRetentionSize;
S
Shengliang Guan 已提交
1309
  int32_t  walRollPeriod;
L
Liu Jicong 已提交
1310
  int64_t  walSegmentSize;
1311
  int16_t  sstTrigger;
1312 1313
  int16_t  hashPrefix;
  int16_t  hashSuffix;
1314
  int32_t  tsdbPageSize;
S
Shengliang Guan 已提交
1315
  int64_t  reserved[8];
C
cadem 已提交
1316 1317 1318
  int8_t   learnerReplica;
  int8_t   learnerSelfIndex;
  SReplica learnerReplicas[TSDB_MAX_LEARNER_REPLICA];
S
Shengliang Guan 已提交
1319
} SCreateVnodeReq;
D
dapan1121 已提交
1320

S
Shengliang Guan 已提交
1321 1322
int32_t tSerializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
int32_t tDeserializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
S
sma  
Shengliang Guan 已提交
1323
int32_t tFreeSCreateVnodeReq(SCreateVnodeReq* pReq);
S
Shengliang Guan 已提交
1324

S
Shengliang Guan 已提交
1325
typedef struct {
L
Liu Jicong 已提交
1326 1327 1328 1329
  int32_t vgId;
  int32_t dnodeId;
  int64_t dbUid;
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1330
  int64_t reserved[8];
S
Shengliang Guan 已提交
1331
} SDropVnodeReq;
S
Shengliang Guan 已提交
1332

S
Shengliang Guan 已提交
1333 1334
int32_t tSerializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
int32_t tDeserializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
S
Shengliang Guan 已提交
1335

S
Shengliang Guan 已提交
1336
typedef struct {
dengyihao's avatar
dengyihao 已提交
1337 1338 1339
  char    colName[TSDB_COL_NAME_LEN];
  char    stb[TSDB_TABLE_FNAME_LEN];
  int64_t stbUid;
S
Shengliang Guan 已提交
1340
  int64_t dbUid;
S
Shengliang Guan 已提交
1341
  int64_t reserved[8];
dengyihao's avatar
dengyihao 已提交
1342 1343 1344 1345 1346
} SDropIndexReq;

int32_t tSerializeSDropIdxReq(void* buf, int32_t bufLen, SDropIndexReq* pReq);
int32_t tDeserializeSDropIdxReq(void* buf, int32_t bufLen, SDropIndexReq* pReq);

S
Shengliang Guan 已提交
1347
typedef struct {
H
Hongze Cheng 已提交
1348 1349 1350 1351
  int64_t     dbUid;
  char        db[TSDB_DB_FNAME_LEN];
  int64_t     compactStartTime;
  STimeWindow tw;
S
Shengliang Guan 已提交
1352 1353 1354 1355 1356 1357
} SCompactVnodeReq;

int32_t tSerializeSCompactVnodeReq(void* buf, int32_t bufLen, SCompactVnodeReq* pReq);
int32_t tDeserializeSCompactVnodeReq(void* buf, int32_t bufLen, SCompactVnodeReq* pReq);

typedef struct {
L
Liu Jicong 已提交
1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371
  int32_t vgVersion;
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
  int32_t cacheLastSize;
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t walFsyncPeriod;
  int8_t  walLevel;
  int8_t  strict;
  int8_t  cacheLast;
  int64_t reserved[8];
H
refact  
Hongze Cheng 已提交
1372
  // 1st modification
1373 1374
  int16_t sttTrigger;
  int32_t minRows;
1375 1376 1377
  // 2nd modification
  int32_t walRetentionPeriod;
  int32_t walRetentionSize;
S
Shengliang Guan 已提交
1378 1379 1380 1381 1382 1383 1384 1385
} SAlterVnodeConfigReq;

int32_t tSerializeSAlterVnodeConfigReq(void* buf, int32_t bufLen, SAlterVnodeConfigReq* pReq);
int32_t tDeserializeSAlterVnodeConfigReq(void* buf, int32_t bufLen, SAlterVnodeConfigReq* pReq);

typedef struct {
  int32_t  vgId;
  int8_t   strict;
S
Shengliang Guan 已提交
1386
  int8_t   selfIndex;
1387
  int8_t   replica;
S
Shengliang Guan 已提交
1388
  SReplica replicas[TSDB_MAX_REPLICA];
S
Shengliang Guan 已提交
1389
  int64_t  reserved[8];
C
cadem 已提交
1390 1391 1392 1393
  int8_t   learnerSelfIndex;
  int8_t   learnerReplica;
  SReplica learnerReplicas[TSDB_MAX_LEARNER_REPLICA];
} SAlterVnodeReplicaReq, SAlterVnodeTypeReq;
S
Shengliang Guan 已提交
1394

S
Shengliang Guan 已提交
1395 1396
int32_t tSerializeSAlterVnodeReplicaReq(void* buf, int32_t bufLen, SAlterVnodeReplicaReq* pReq);
int32_t tDeserializeSAlterVnodeReplicaReq(void* buf, int32_t bufLen, SAlterVnodeReplicaReq* pReq);
S
Shengliang Guan 已提交
1397

1398
typedef struct {
X
Xiaoyu Wang 已提交
1399 1400
  int32_t vgId;
  int8_t  disable;
1401 1402 1403 1404 1405
} SDisableVnodeWriteReq;

int32_t tSerializeSDisableVnodeWriteReq(void* buf, int32_t bufLen, SDisableVnodeWriteReq* pReq);
int32_t tDeserializeSDisableVnodeWriteReq(void* buf, int32_t bufLen, SDisableVnodeWriteReq* pReq);

1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416
typedef struct {
  int32_t  srcVgId;
  int32_t  dstVgId;
  uint32_t hashBegin;
  uint32_t hashEnd;
  int64_t  reserved;
} SAlterVnodeHashRangeReq;

int32_t tSerializeSAlterVnodeHashRangeReq(void* buf, int32_t bufLen, SAlterVnodeHashRangeReq* pReq);
int32_t tDeserializeSAlterVnodeHashRangeReq(void* buf, int32_t bufLen, SAlterVnodeHashRangeReq* pReq);

D
dapan1121 已提交
1417
typedef struct {
D
dapan1121 已提交
1418
  SMsgHead header;
D
dapan1121 已提交
1419 1420
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
S
Shengliang Guan 已提交
1421
} STableInfoReq;
D
dapan1121 已提交
1422

S
Shengliang Guan 已提交
1423 1424 1425
int32_t tSerializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);
int32_t tDeserializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);

D
dapan1121 已提交
1426
typedef struct {
S
Shengliang Guan 已提交
1427
  int8_t  metaClone;  // create local clone of the cached table meta
D
dapan1121 已提交
1428 1429 1430 1431
  int32_t numOfVgroups;
  int32_t numOfTables;
  int32_t numOfUdfs;
  char    tableNames[];
S
Shengliang Guan 已提交
1432
} SMultiTableInfoReq;
D
dapan1121 已提交
1433

H
Haojun Liao 已提交
1434
// todo refactor
D
dapan1121 已提交
1435
typedef struct SVgroupInfo {
1436 1437 1438
  int32_t  vgId;
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1439
  SEpSet   epSet;
L
Liu Jicong 已提交
1440 1441 1442 1443
  union {
    int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
    int32_t taskId;      // used in stream
  };
D
dapan1121 已提交
1444 1445
} SVgroupInfo;

D
dapan1121 已提交
1446
typedef struct {
H
Haojun Liao 已提交
1447 1448
  int32_t     numOfVgroups;
  SVgroupInfo vgroups[];
S
Shengliang Guan 已提交
1449
} SVgroupsInfo;
D
dapan1121 已提交
1450

C
Cary Xu 已提交
1451
typedef struct {
D
dapan1121 已提交
1452 1453 1454
  STableMetaRsp* pMeta;
} SMAlterStbRsp;

C
Cary Xu 已提交
1455 1456 1457
int32_t tEncodeSMAlterStbRsp(SEncoder* pEncoder, const SMAlterStbRsp* pRsp);
int32_t tDecodeSMAlterStbRsp(SDecoder* pDecoder, SMAlterStbRsp* pRsp);
void    tFreeSMAlterStbRsp(SMAlterStbRsp* pRsp);
D
dapan1121 已提交
1458

S
Shengliang Guan 已提交
1459 1460
int32_t tSerializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
int32_t tDeserializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
1461
void    tFreeSTableMetaRsp(void* pRsp);
X
Xiaoyu Wang 已提交
1462
void    tFreeSTableIndexRsp(void* info);
S
Shengliang Guan 已提交
1463 1464

typedef struct {
X
Xiaoyu Wang 已提交
1465 1466
  SArray* pMetaRsp;   // Array of STableMetaRsp
  SArray* pIndexRsp;  // Array of STableIndexRsp;
D
dapan1121 已提交
1467
} SSTbHbRsp;
S
Shengliang Guan 已提交
1468

D
dapan1121 已提交
1469 1470 1471
int32_t tSerializeSSTbHbRsp(void* buf, int32_t bufLen, SSTbHbRsp* pRsp);
int32_t tDeserializeSSTbHbRsp(void* buf, int32_t bufLen, SSTbHbRsp* pRsp);
void    tFreeSSTbHbRsp(SSTbHbRsp* pRsp);
S
Shengliang Guan 已提交
1472

S
Shengliang Guan 已提交
1473
typedef struct {
S
Shengliang Guan 已提交
1474 1475 1476 1477 1478 1479 1480 1481
  int32_t numOfTables;
  int32_t numOfVgroup;
  int32_t numOfUdf;
  int32_t contLen;
  int8_t  compressed;  // denote if compressed or not
  int32_t rawLen;      // size before compress
  uint8_t metaClone;   // make meta clone after retrieve meta from mnode
  char    meta[];
D
dapan1121 已提交
1482 1483 1484 1485 1486
} SMultiTableMeta;

typedef struct {
  int32_t dataLen;
  char    name[TSDB_TABLE_FNAME_LEN];
H
Hongze Cheng 已提交
1487
  char*   data;
D
dapan1121 已提交
1488 1489
} STagData;

X
Xiaoyu Wang 已提交
1490 1491 1492 1493 1494 1495 1496
typedef struct {
  int32_t useless;  // useless
} SShowVariablesReq;

int32_t tSerializeSShowVariablesReq(void* buf, int32_t bufLen, SShowVariablesReq* pReq);
int32_t tDeserializeSShowVariablesReq(void* buf, int32_t bufLen, SShowVariablesReq* pReq);

D
dapan1121 已提交
1497
typedef struct {
1498 1499
  char name[TSDB_CONFIG_OPTION_LEN + 1];
  char value[TSDB_CONFIG_VALUE_LEN + 1];
D
dapan1121 已提交
1500 1501 1502
} SVariablesInfo;

typedef struct {
1503
  SArray* variables;  // SArray<SVariablesInfo>
D
dapan1121 已提交
1504 1505 1506 1507 1508 1509 1510
} SShowVariablesRsp;

int32_t tSerializeSShowVariablesRsp(void* buf, int32_t bufLen, SShowVariablesRsp* pReq);
int32_t tDeserializeSShowVariablesRsp(void* buf, int32_t bufLen, SShowVariablesRsp* pReq);

void tFreeSShowVariablesRsp(SShowVariablesRsp* pRsp);

D
dapan1121 已提交
1511 1512 1513 1514 1515 1516
/*
 * sql: show tables like '%a_%'
 * payload is the query condition, e.g., '%a_%'
 * payloadLen is the length of payload
 */
typedef struct {
L
Liu Jicong 已提交
1517
  int32_t type;
1518
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1519 1520
  int32_t payloadLen;
  char*   payload;
S
Shengliang Guan 已提交
1521
} SShowReq;
D
dapan1121 已提交
1522

S
Shengliang Guan 已提交
1523 1524 1525 1526
int32_t tSerializeSShowReq(void* buf, int32_t bufLen, SShowReq* pReq);
int32_t tDeserializeSShowReq(void* buf, int32_t bufLen, SShowReq* pReq);
void    tFreeSShowReq(SShowReq* pReq);

S
Shengliang Guan 已提交
1527
typedef struct {
1528
  int64_t       showId;
S
Shengliang Guan 已提交
1529
  STableMetaRsp tableMeta;
S
Shengliang Guan 已提交
1530
} SShowRsp, SVShowTablesRsp;
D
dapan1121 已提交
1531

S
Shengliang Guan 已提交
1532 1533 1534
int32_t tSerializeSShowRsp(void* buf, int32_t bufLen, SShowRsp* pRsp);
int32_t tDeserializeSShowRsp(void* buf, int32_t bufLen, SShowRsp* pRsp);
void    tFreeSShowRsp(SShowRsp* pRsp);
D
dapan1121 已提交
1535

1536
typedef struct {
1537
  char    db[TSDB_DB_FNAME_LEN];
H
Haojun Liao 已提交
1538
  char    tb[TSDB_TABLE_NAME_LEN];
1539
  char    user[TSDB_USER_LEN];
wmmhello's avatar
wmmhello 已提交
1540
  char    filterTb[TSDB_TABLE_NAME_LEN];
1541 1542 1543
  int64_t showId;
} SRetrieveTableReq;

1544 1545 1546 1547 1548 1549
typedef struct SSysTableSchema {
  int8_t   type;
  col_id_t colId;
  int32_t  bytes;
} SSysTableSchema;

1550 1551 1552 1553 1554 1555 1556 1557
int32_t tSerializeSRetrieveTableReq(void* buf, int32_t bufLen, SRetrieveTableReq* pReq);
int32_t tDeserializeSRetrieveTableReq(void* buf, int32_t bufLen, SRetrieveTableReq* pReq);

typedef struct {
  int64_t useconds;
  int8_t  completed;  // all results are returned to client
  int8_t  precision;
  int8_t  compressed;
L
Liu Jicong 已提交
1558
  int8_t  streamBlockType;
1559
  int32_t compLen;
1560
  int32_t numOfBlocks;
1561 1562
  int64_t numOfRows;  // from int32_t change to int64_t
  int64_t numOfCols;
1563 1564
  int64_t skey;
  int64_t ekey;
1565 1566 1567
  int64_t version;                         // for stream
  TSKEY   watermark;                       // for stream
  char    parTbName[TSDB_TABLE_NAME_LEN];  // for stream
1568 1569 1570
  char    data[];
} SRetrieveTableRsp;

H
Haojun Liao 已提交
1571
typedef struct {
L
Liu Jicong 已提交
1572 1573 1574 1575 1576 1577 1578 1579
  int64_t handle;
  int64_t useconds;
  int8_t  completed;  // all results are returned to client
  int8_t  precision;
  int8_t  compressed;
  int32_t compLen;
  int32_t numOfRows;
  char    data[];
H
Haojun Liao 已提交
1580 1581
} SRetrieveMetaTableRsp;

D
dapan1121 已提交
1582
typedef struct SExplainExecInfo {
1583 1584
  double   startupCost;
  double   totalCost;
D
dapan1121 已提交
1585
  uint64_t numOfRows;
1586
  uint32_t verboseLen;
dengyihao's avatar
dengyihao 已提交
1587
  void*    verboseInfo;
D
dapan1121 已提交
1588 1589
} SExplainExecInfo;

D
dapan1121 已提交
1590
typedef struct {
D
dapan1121 已提交
1591
  int32_t           numOfPlans;
dengyihao's avatar
dengyihao 已提交
1592
  SExplainExecInfo* subplanInfo;
D
dapan1121 已提交
1593 1594
} SExplainRsp;

1595 1596
typedef struct {
  SExplainRsp rsp;
1597 1598 1599 1600
  uint64_t    qId;
  uint64_t    tId;
  int64_t     rId;
  int32_t     eId;
1601 1602
} SExplainLocalRsp;

1603 1604 1605 1606 1607 1608 1609 1610 1611
typedef struct STableScanAnalyzeInfo {
  uint64_t totalRows;
  uint64_t totalCheckedRows;
  uint32_t totalBlocks;
  uint32_t loadBlocks;
  uint32_t loadBlockStatis;
  uint32_t skipBlocks;
  uint32_t filterOutBlocks;
  double   elapsedTime;
1612
  double   filterTime;
1613 1614
} STableScanAnalyzeInfo;

D
dapan1121 已提交
1615 1616
int32_t tSerializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
int32_t tDeserializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
1617
void    tFreeSExplainRsp(SExplainRsp* pRsp);
D
dapan1121 已提交
1618

D
dapan1121 已提交
1619
typedef struct {
S
Shengliang Guan 已提交
1620
  char    fqdn[TSDB_FQDN_LEN];  // end point, hostname:port
1621
  int32_t port;
S
Shengliang Guan 已提交
1622
} SCreateDnodeReq;
S
Shengliang Guan 已提交
1623

S
Shengliang Guan 已提交
1624 1625 1626
int32_t tSerializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);
int32_t tDeserializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);

S
Shengliang Guan 已提交
1627 1628
typedef struct {
  int32_t dnodeId;
1629 1630
  char    fqdn[TSDB_FQDN_LEN];
  int32_t port;
1631
  int8_t  force;
D
dapan1121 已提交
1632
  int8_t  unsafe;
S
Shengliang Guan 已提交
1633
} SDropDnodeReq;
S
Shengliang Guan 已提交
1634

S
Shengliang Guan 已提交
1635 1636 1637
int32_t tSerializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);
int32_t tDeserializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);

C
cadem 已提交
1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652
enum {
  RESTORE_TYPE__ALL = 1,
  RESTORE_TYPE__MNODE,
  RESTORE_TYPE__VNODE,
  RESTORE_TYPE__QNODE,
};

typedef struct {
  int32_t dnodeId;
  int8_t  restoreType;
} SRestoreDnodeReq;

int32_t tSerializeSRestoreDnodeReq(void* buf, int32_t bufLen, SRestoreDnodeReq* pReq);
int32_t tDeserializeSRestoreDnodeReq(void* buf, int32_t bufLen, SRestoreDnodeReq* pReq);

S
Shengliang Guan 已提交
1653 1654
typedef struct {
  int32_t dnodeId;
1655
  char    config[TSDB_DNODE_CONFIG_LEN];
S
Shengliang Guan 已提交
1656
  char    value[TSDB_DNODE_VALUE_LEN];
S
Shengliang Guan 已提交
1657
} SMCfgDnodeReq;
D
dapan1121 已提交
1658

S
Shengliang Guan 已提交
1659 1660 1661
int32_t tSerializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);
int32_t tDeserializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);

S
Shengliang Guan 已提交
1662 1663 1664 1665 1666 1667 1668 1669
typedef struct {
  char config[TSDB_DNODE_CONFIG_LEN];
  char value[TSDB_DNODE_VALUE_LEN];
} SDCfgDnodeReq;

int32_t tSerializeSDCfgDnodeReq(void* buf, int32_t bufLen, SDCfgDnodeReq* pReq);
int32_t tDeserializeSDCfgDnodeReq(void* buf, int32_t bufLen, SDCfgDnodeReq* pReq);

S
Shengliang Guan 已提交
1670 1671
typedef struct {
  int32_t dnodeId;
dengyihao's avatar
dengyihao 已提交
1672
} SMCreateMnodeReq, SMDropMnodeReq, SDDropMnodeReq, SMCreateQnodeReq, SMDropQnodeReq, SDCreateQnodeReq, SDDropQnodeReq,
S
Shengliang Guan 已提交
1673
    SMCreateSnodeReq, SMDropSnodeReq, SDCreateSnodeReq, SDDropSnodeReq;
S
Shengliang Guan 已提交
1674

S
Shengliang Guan 已提交
1675 1676
int32_t tSerializeSCreateDropMQSNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
int32_t tDeserializeSCreateDropMQSNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
S
Shengliang Guan 已提交
1677

D
dapan1121 已提交
1678
typedef struct {
S
Shengliang Guan 已提交
1679
  int8_t   replica;
S
Shengliang Guan 已提交
1680
  SReplica replicas[TSDB_MAX_REPLICA];
C
cadem 已提交
1681 1682 1683 1684
  int8_t   learnerReplica;
  SReplica learnerReplicas[TSDB_MAX_LEARNER_REPLICA];
  int64_t  lastIndex;
} SDCreateMnodeReq, SDAlterMnodeReq, SDAlterMnodeTypeReq;
D
dapan1121 已提交
1685

S
Shengliang Guan 已提交
1686 1687 1688
int32_t tSerializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);
int32_t tDeserializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);

S
Shengliang Guan 已提交
1689
typedef struct {
X
Xiaoyu Wang 已提交
1690
  char queryStrId[TSDB_QUERY_ID_LEN];
S
Shengliang Guan 已提交
1691
} SKillQueryReq;
S
Shengliang Guan 已提交
1692

S
Shengliang Guan 已提交
1693 1694 1695
int32_t tSerializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);
int32_t tDeserializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);

S
Shengliang Guan 已提交
1696
typedef struct {
D
dapan1121 已提交
1697
  uint32_t connId;
S
Shengliang Guan 已提交
1698
} SKillConnReq;
D
dapan1121 已提交
1699

S
Shengliang Guan 已提交
1700 1701 1702
int32_t tSerializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);
int32_t tDeserializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);

S
Shengliang Guan 已提交
1703 1704 1705 1706 1707 1708 1709
typedef struct {
  int32_t transId;
} SKillTransReq;

int32_t tSerializeSKillTransReq(void* buf, int32_t bufLen, SKillTransReq* pReq);
int32_t tDeserializeSKillTransReq(void* buf, int32_t bufLen, SKillTransReq* pReq);

X
Xiaoyu Wang 已提交
1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 1729 1730 1731 1732 1733 1734
typedef struct {
  int32_t useless;  // useless
} SBalanceVgroupReq;

int32_t tSerializeSBalanceVgroupReq(void* buf, int32_t bufLen, SBalanceVgroupReq* pReq);
int32_t tDeserializeSBalanceVgroupReq(void* buf, int32_t bufLen, SBalanceVgroupReq* pReq);

typedef struct {
  int32_t vgId1;
  int32_t vgId2;
} SMergeVgroupReq;

int32_t tSerializeSMergeVgroupReq(void* buf, int32_t bufLen, SMergeVgroupReq* pReq);
int32_t tDeserializeSMergeVgroupReq(void* buf, int32_t bufLen, SMergeVgroupReq* pReq);

typedef struct {
  int32_t vgId;
  int32_t dnodeId1;
  int32_t dnodeId2;
  int32_t dnodeId3;
} SRedistributeVgroupReq;

int32_t tSerializeSRedistributeVgroupReq(void* buf, int32_t bufLen, SRedistributeVgroupReq* pReq);
int32_t tDeserializeSRedistributeVgroupReq(void* buf, int32_t bufLen, SRedistributeVgroupReq* pReq);

C
cadem 已提交
1735 1736 1737 1738 1739 1740 1741 1742
typedef struct {
  int32_t useless;
} SBalanceVgroupLeaderReq;

int32_t tSerializeSBalanceVgroupLeaderReq(void* buf, int32_t bufLen, SBalanceVgroupLeaderReq* pReq);
int32_t tDeserializeSBalanceVgroupLeaderReq(void* buf, int32_t bufLen, SBalanceVgroupLeaderReq* pReq);

typedef struct {
1743
  int32_t vgId;
C
cadem 已提交
1744
} SForceBecomeFollowerReq;
C
cadem 已提交
1745

C
cadem 已提交
1746 1747
int32_t tSerializeSForceBecomeFollowerReq(void* buf, int32_t bufLen, SForceBecomeFollowerReq* pReq);
int32_t tDeserializeSForceBecomeFollowerReq(void* buf, int32_t bufLen, SForceBecomeFollowerReq* pReq);
C
cadem 已提交
1748

1749 1750 1751 1752 1753 1754 1755
typedef struct {
  int32_t vgId;
} SSplitVgroupReq;

int32_t tSerializeSSplitVgroupReq(void* buf, int32_t bufLen, SSplitVgroupReq* pReq);
int32_t tDeserializeSSplitVgroupReq(void* buf, int32_t bufLen, SSplitVgroupReq* pReq);

D
dapan1121 已提交
1756 1757 1758 1759
typedef struct {
  char user[TSDB_USER_LEN];
  char spi;
  char encrypt;
1760 1761
  char secret[TSDB_PASSWORD_LEN];
  char ckey[TSDB_PASSWORD_LEN];
S
Shengliang Guan 已提交
1762
} SAuthReq, SAuthRsp;
D
dapan1121 已提交
1763

S
Shengliang Guan 已提交
1764 1765 1766
int32_t tSerializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);
int32_t tDeserializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);

D
dapan1121 已提交
1767
typedef struct {
S
Shengliang Guan 已提交
1768
  int32_t statusCode;
S
Shengliang Guan 已提交
1769
  char    details[1024];
S
Shengliang Guan 已提交
1770 1771 1772 1773
} SServerStatusRsp;

int32_t tSerializeSServerStatusRsp(void* buf, int32_t bufLen, SServerStatusRsp* pRsp);
int32_t tDeserializeSServerStatusRsp(void* buf, int32_t bufLen, SServerStatusRsp* pRsp);
D
dapan1121 已提交
1774

1775 1776 1777 1778 1779 1780 1781
/**
 * The layout of the query message payload is as following:
 * +--------------------+---------------------------------+
 * |Sql statement       | Physical plan                   |
 * |(denoted by sqlLen) |(In JSON, denoted by contentLen) |
 * +--------------------+---------------------------------+
 */
L
Liu Jicong 已提交
1782
typedef struct SSubQueryMsg {
D
dapan1121 已提交
1783
  SMsgHead header;
D
dapan1121 已提交
1784
  uint64_t sId;
H
Hongze Cheng 已提交
1785 1786
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1787
  int64_t  refId;
D
dapan1121 已提交
1788
  int32_t  execId;
D
dapan1121 已提交
1789
  int32_t  msgMask;
D
dapan1121 已提交
1790
  int8_t   taskType;
D
dapan1121 已提交
1791
  int8_t   explain;
D
dapan1121 已提交
1792
  int8_t   needFetch;
D
dapan1121 已提交
1793
  uint32_t sqlLen;
L
Liu Jicong 已提交
1794
  char*    sql;
D
dapan1121 已提交
1795
  uint32_t msgLen;
L
Liu Jicong 已提交
1796
  char*    msg;
D
dapan1121 已提交
1797
} SSubQueryMsg;
D
dapan 已提交
1798

L
Liu Jicong 已提交
1799 1800 1801
int32_t tSerializeSSubQueryMsg(void* buf, int32_t bufLen, SSubQueryMsg* pReq);
int32_t tDeserializeSSubQueryMsg(void* buf, int32_t bufLen, SSubQueryMsg* pReq);
void    tFreeSSubQueryMsg(SSubQueryMsg* pReq);
D
dapan1121 已提交
1802

1803 1804 1805 1806 1807 1808 1809
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
} SSinkDataReq;

D
dapan1121 已提交
1810 1811 1812 1813 1814
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1815
  int32_t  execId;
D
dapan1121 已提交
1816 1817
} SQueryContinueReq;

S
Shengliang Guan 已提交
1818
typedef struct {
D
dapan1121 已提交
1819
  SMsgHead header;
D
dapan1121 已提交
1820
  uint64_t sId;
H
Hongze Cheng 已提交
1821 1822
  uint64_t queryId;
  uint64_t taskId;
S
Shengliang Guan 已提交
1823
} SResReadyReq;
D
dapan 已提交
1824

S
Shengliang Guan 已提交
1825
typedef struct {
D
dapan1121 已提交
1826
  int32_t code;
L
Liu Jicong 已提交
1827
  char    tbFName[TSDB_TABLE_FNAME_LEN];
1828 1829
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
1830 1831
} SResReadyRsp;

S
Shengliang Guan 已提交
1832
typedef struct {
D
dapan1121 已提交
1833
  SMsgHead header;
D
dapan1121 已提交
1834
  uint64_t sId;
H
Hongze Cheng 已提交
1835 1836
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1837
  int32_t  execId;
S
Shengliang Guan 已提交
1838
} SResFetchReq;
D
dapan 已提交
1839

L
Liu Jicong 已提交
1840 1841
int32_t tSerializeSResFetchReq(void* buf, int32_t bufLen, SResFetchReq* pReq);
int32_t tDeserializeSResFetchReq(void* buf, int32_t bufLen, SResFetchReq* pReq);
D
dapan1121 已提交
1842

S
Shengliang Guan 已提交
1843
typedef struct {
D
dapan1121 已提交
1844
  SMsgHead header;
D
dapan1121 已提交
1845
  uint64_t sId;
S
Shengliang Guan 已提交
1846
} SSchTasksStatusReq;
D
dapan1121 已提交
1847

S
Shengliang Guan 已提交
1848
typedef struct {
H
Hongze Cheng 已提交
1849 1850
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1851
  int64_t  refId;
D
dapan1121 已提交
1852
  int32_t  execId;
H
Hongze Cheng 已提交
1853
  int8_t   status;
D
dapan1121 已提交
1854 1855
} STaskStatus;

S
Shengliang Guan 已提交
1856
typedef struct {
L
Liu Jicong 已提交
1857 1858
  int64_t refId;
  SArray* taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1859 1860
} SSchedulerStatusRsp;

D
dapan1121 已提交
1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875
typedef struct {
  uint64_t queryId;
  uint64_t taskId;
  int8_t   action;
} STaskAction;

typedef struct SQueryNodeEpId {
  int32_t nodeId;  // vgId or qnodeId
  SEp     ep;
} SQueryNodeEpId;

typedef struct {
  SMsgHead       header;
  uint64_t       sId;
  SQueryNodeEpId epId;
L
Liu Jicong 已提交
1876
  SArray*        taskAction;  // SArray<STaskAction>
D
dapan1121 已提交
1877 1878
} SSchedulerHbReq;

L
Liu Jicong 已提交
1879 1880 1881
int32_t tSerializeSSchedulerHbReq(void* buf, int32_t bufLen, SSchedulerHbReq* pReq);
int32_t tDeserializeSSchedulerHbReq(void* buf, int32_t bufLen, SSchedulerHbReq* pReq);
void    tFreeSSchedulerHbReq(SSchedulerHbReq* pReq);
D
dapan1121 已提交
1882 1883 1884

typedef struct {
  SQueryNodeEpId epId;
L
Liu Jicong 已提交
1885
  SArray*        taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1886 1887
} SSchedulerHbRsp;

L
Liu Jicong 已提交
1888 1889 1890
int32_t tSerializeSSchedulerHbRsp(void* buf, int32_t bufLen, SSchedulerHbRsp* pRsp);
int32_t tDeserializeSSchedulerHbRsp(void* buf, int32_t bufLen, SSchedulerHbRsp* pRsp);
void    tFreeSSchedulerHbRsp(SSchedulerHbRsp* pRsp);
D
dapan1121 已提交
1891

S
Shengliang Guan 已提交
1892
typedef struct {
D
dapan1121 已提交
1893
  SMsgHead header;
D
dapan1121 已提交
1894
  uint64_t sId;
H
Hongze Cheng 已提交
1895 1896
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1897
  int64_t  refId;
D
dapan1121 已提交
1898
  int32_t  execId;
S
Shengliang Guan 已提交
1899
} STaskCancelReq;
D
dapan1121 已提交
1900

S
Shengliang Guan 已提交
1901
typedef struct {
D
dapan1121 已提交
1902 1903 1904
  int32_t code;
} STaskCancelRsp;

S
Shengliang Guan 已提交
1905
typedef struct {
D
dapan1121 已提交
1906
  SMsgHead header;
D
dapan1121 已提交
1907
  uint64_t sId;
H
Hongze Cheng 已提交
1908 1909
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1910
  int64_t  refId;
D
dapan1121 已提交
1911
  int32_t  execId;
S
Shengliang Guan 已提交
1912
} STaskDropReq;
D
dapan1121 已提交
1913

1914 1915
int32_t tSerializeSTaskDropReq(void* buf, int32_t bufLen, STaskDropReq* pReq);
int32_t tDeserializeSTaskDropReq(void* buf, int32_t bufLen, STaskDropReq* pReq);
L
Liu Jicong 已提交
1916 1917
int32_t tSerializeSTaskDropReq(void* buf, int32_t bufLen, STaskDropReq* pReq);
int32_t tDeserializeSTaskDropReq(void* buf, int32_t bufLen, STaskDropReq* pReq);
D
dapan1121 已提交
1918

L
Liu Jicong 已提交
1919 1920
int32_t tSerializeSQueryTableRsp(void* buf, int32_t bufLen, SQueryTableRsp* pRsp);
int32_t tDeserializeSQueryTableRsp(void* buf, int32_t bufLen, SQueryTableRsp* pRsp);
D
dapan1121 已提交
1921

S
Shengliang Guan 已提交
1922
typedef struct {
D
dapan1121 已提交
1923 1924 1925
  int32_t code;
} STaskDropRsp;

X
Xiaoyu Wang 已提交
1926 1927 1928
#define STREAM_TRIGGER_AT_ONCE        1
#define STREAM_TRIGGER_WINDOW_CLOSE   2
#define STREAM_TRIGGER_MAX_DELAY      3
5
54liuyao 已提交
1929
#define STREAM_DEFAULT_IGNORE_EXPIRED 1
1930 1931 1932
#define STREAM_FILL_HISTORY_ON        1
#define STREAM_FILL_HISTORY_OFF       0
#define STREAM_DEFAULT_FILL_HISTORY   STREAM_FILL_HISTORY_OFF
L
liuyao 已提交
1933
#define STREAM_DEFAULT_IGNORE_UPDATE  1
1934 1935
#define STREAM_CREATE_STABLE_TRUE     1
#define STREAM_CREATE_STABLE_FALSE    0
X
Xiaoyu Wang 已提交
1936

1937 1938 1939 1940 1941
typedef struct SColLocation {
  int16_t  slotId;
  col_id_t colId;
  int8_t   type;
} SColLocation;
X
Xiaoyu Wang 已提交
1942

L
Liu Jicong 已提交
1943
typedef struct {
L
Liu Jicong 已提交
1944
  char    name[TSDB_STREAM_FNAME_LEN];
L
Liu Jicong 已提交
1945 1946
  char    sourceDB[TSDB_DB_FNAME_LEN];
  char    targetStbFullName[TSDB_TABLE_FNAME_LEN];
1947 1948
  char*   sql;
  char*   ast;
L
Liu Jicong 已提交
1949
  int8_t  igExists;
1950
  int8_t  triggerType;
L
Liu Jicong 已提交
1951 1952
  int8_t  igExpired;
  int8_t  fillHistory;  // process data inserted before creating stream
1953
  int64_t maxDelay;
X
Xiaoyu Wang 已提交
1954
  int64_t watermark;
1955 1956
  int32_t numOfTags;
  SArray* pTags;  // array of SField
1957 1958
  // 3.0.20
  int64_t checkpointFreq;  // ms
1959
  // 3.0.2.3
1960 1961
  int8_t   createStb;
  uint64_t targetStbUid;
X
Xiaoyu Wang 已提交
1962
  SArray*  fillNullCols;  // array of SColLocation
X
Xiaoyu Wang 已提交
1963
  int64_t  deleteMark;
X
Xiaoyu Wang 已提交
1964
  int8_t   igUpdate;
L
Liu Jicong 已提交
1965
} SCMCreateStreamReq;
L
Liu Jicong 已提交
1966

L
Liu Jicong 已提交
1967 1968 1969 1970 1971 1972 1973 1974
typedef struct {
  int64_t streamId;
} SCMCreateStreamRsp;

int32_t tSerializeSCMCreateStreamReq(void* buf, int32_t bufLen, const SCMCreateStreamReq* pReq);
int32_t tDeserializeSCMCreateStreamReq(void* buf, int32_t bufLen, SCMCreateStreamReq* pReq);
void    tFreeSCMCreateStreamReq(SCMCreateStreamReq* pReq);

L
Liu Jicong 已提交
1975
typedef struct {
L
Liu Jicong 已提交
1976
  char    name[TSDB_STREAM_FNAME_LEN];
L
Liu Jicong 已提交
1977 1978 1979 1980 1981 1982 1983 1984 1985
  int64_t streamId;
  char*   sql;
  char*   executorMsg;
} SMVCreateStreamReq, SMSCreateStreamReq;

typedef struct {
  int64_t streamId;
} SMVCreateStreamRsp, SMSCreateStreamRsp;

L
Liu Jicong 已提交
1986 1987 1988 1989 1990 1991
enum {
  TOPIC_SUB_TYPE__DB = 1,
  TOPIC_SUB_TYPE__TABLE,
  TOPIC_SUB_TYPE__COLUMN,
};

L
Liu Jicong 已提交
1992
typedef struct {
L
Liu Jicong 已提交
1993 1994
  char   name[TSDB_TOPIC_FNAME_LEN];  // accout.topic
  int8_t igExists;
L
Liu Jicong 已提交
1995
  int8_t subType;
L
Liu Jicong 已提交
1996
  int8_t withMeta;
L
Liu Jicong 已提交
1997
  char*  sql;
L
Liu Jicong 已提交
1998
  char   subDbName[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1999 2000 2001 2002
  union {
    char* ast;
    char  subStbName[TSDB_TABLE_FNAME_LEN];
  };
L
Liu Jicong 已提交
2003 2004 2005 2006 2007
} SCMCreateTopicReq;

int32_t tSerializeSCMCreateTopicReq(void* buf, int32_t bufLen, const SCMCreateTopicReq* pReq);
int32_t tDeserializeSCMCreateTopicReq(void* buf, int32_t bufLen, SCMCreateTopicReq* pReq);
void    tFreeSCMCreateTopicReq(SCMCreateTopicReq* pReq);
L
Liu Jicong 已提交
2008 2009 2010

typedef struct {
  int64_t topicId;
L
Liu Jicong 已提交
2011
} SCMCreateTopicRsp;
L
Liu Jicong 已提交
2012

L
Liu Jicong 已提交
2013 2014
int32_t tSerializeSCMCreateTopicRsp(void* buf, int32_t bufLen, const SCMCreateTopicRsp* pRsp);
int32_t tDeserializeSCMCreateTopicRsp(void* buf, int32_t bufLen, SCMCreateTopicRsp* pRsp);
L
Liu Jicong 已提交
2015

2016 2017
typedef struct {
  int64_t consumerId;
L
Liu Jicong 已提交
2018
} SMqConsumerLostMsg, SMqConsumerRecoverMsg, SMqConsumerClearMsg;
2019

L
Liu Jicong 已提交
2020
typedef struct {
dengyihao's avatar
dengyihao 已提交
2021 2022 2023 2024
  int64_t consumerId;
  char    cgroup[TSDB_CGROUP_LEN];
  char    clientId[256];
  SArray* topicNames;  // SArray<char**>
L
Liu Jicong 已提交
2025 2026
} SCMSubscribeReq;

S
Shengliang Guan 已提交
2027 2028
static FORCE_INLINE int32_t tSerializeSCMSubscribeReq(void** buf, const SCMSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2029
  tlen += taosEncodeFixedI64(buf, pReq->consumerId);
2030
  tlen += taosEncodeString(buf, pReq->cgroup);
L
Liu Jicong 已提交
2031
  tlen += taosEncodeString(buf, pReq->clientId);
L
Liu Jicong 已提交
2032

L
Liu Jicong 已提交
2033 2034 2035 2036
  int32_t topicNum = taosArrayGetSize(pReq->topicNames);
  tlen += taosEncodeFixedI32(buf, topicNum);

  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
2037
    tlen += taosEncodeString(buf, (char*)taosArrayGetP(pReq->topicNames, i));
L
Liu Jicong 已提交
2038
  }
L
Liu Jicong 已提交
2039 2040 2041 2042 2043
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeReq(void* buf, SCMSubscribeReq* pReq) {
  buf = taosDecodeFixedI64(buf, &pReq->consumerId);
2044
  buf = taosDecodeStringTo(buf, pReq->cgroup);
L
Liu Jicong 已提交
2045
  buf = taosDecodeStringTo(buf, pReq->clientId);
L
Liu Jicong 已提交
2046 2047 2048 2049 2050 2051

  int32_t topicNum;
  buf = taosDecodeFixedI32(buf, &topicNum);

  pReq->topicNames = taosArrayInit(topicNum, sizeof(void*));
  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
2052
    char* name;
L
Liu Jicong 已提交
2053 2054
    buf = taosDecodeString(buf, &name);
    taosArrayPush(pReq->topicNames, &name);
L
Liu Jicong 已提交
2055
  }
L
Liu Jicong 已提交
2056 2057 2058
  return buf;
}

L
Liu Jicong 已提交
2059
typedef struct SMqSubTopic {
L
Liu Jicong 已提交
2060
  int32_t vgId;
L
Liu Jicong 已提交
2061 2062 2063 2064 2065
  int64_t topicId;
  SEpSet  epSet;
} SMqSubTopic;

typedef struct {
L
Liu Jicong 已提交
2066
  int32_t     topicNum;
L
Liu Jicong 已提交
2067
  SMqSubTopic topics[];
L
Liu Jicong 已提交
2068 2069
} SCMSubscribeRsp;

S
Shengliang Guan 已提交
2070 2071
static FORCE_INLINE int32_t tSerializeSCMSubscribeRsp(void** buf, const SCMSubscribeRsp* pRsp) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2072
  tlen += taosEncodeFixedI32(buf, pRsp->topicNum);
S
Shengliang Guan 已提交
2073
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
2074 2075 2076 2077
    tlen += taosEncodeFixedI32(buf, pRsp->topics[i].vgId);
    tlen += taosEncodeFixedI64(buf, pRsp->topics[i].topicId);
    tlen += taosEncodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
2078 2079 2080 2081
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeRsp(void* buf, SCMSubscribeRsp* pRsp) {
L
Liu Jicong 已提交
2082
  buf = taosDecodeFixedI32(buf, &pRsp->topicNum);
S
Shengliang Guan 已提交
2083
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
2084 2085 2086 2087
    buf = taosDecodeFixedI32(buf, &pRsp->topics[i].vgId);
    buf = taosDecodeFixedI64(buf, &pRsp->topics[i].topicId);
    buf = taosDecodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
2088 2089 2090 2091 2092 2093 2094 2095
  return buf;
}

typedef struct {
  int64_t topicId;
  int64_t consumerId;
  int64_t consumerGroupId;
  int64_t offset;
L
Liu Jicong 已提交
2096 2097 2098
  char*   sql;
  char*   logicalPlan;
  char*   physicalPlan;
L
Liu Jicong 已提交
2099 2100
} SMVSubscribeReq;

S
Shengliang Guan 已提交
2101 2102
static FORCE_INLINE int32_t tSerializeSMVSubscribeReq(void** buf, SMVSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123
  tlen += taosEncodeFixedI64(buf, pReq->topicId);
  tlen += taosEncodeFixedI64(buf, pReq->consumerId);
  tlen += taosEncodeFixedI64(buf, pReq->consumerGroupId);
  tlen += taosEncodeFixedI64(buf, pReq->offset);
  tlen += taosEncodeString(buf, pReq->sql);
  tlen += taosEncodeString(buf, pReq->logicalPlan);
  tlen += taosEncodeString(buf, pReq->physicalPlan);
  return tlen;
}

static FORCE_INLINE void* tDeserializeSMVSubscribeReq(void* buf, SMVSubscribeReq* pReq) {
  buf = taosDecodeFixedI64(buf, &pReq->topicId);
  buf = taosDecodeFixedI64(buf, &pReq->consumerId);
  buf = taosDecodeFixedI64(buf, &pReq->consumerGroupId);
  buf = taosDecodeFixedI64(buf, &pReq->offset);
  buf = taosDecodeString(buf, &pReq->sql);
  buf = taosDecodeString(buf, &pReq->logicalPlan);
  buf = taosDecodeString(buf, &pReq->physicalPlan);
  return buf;
}

L
Liu Jicong 已提交
2124
typedef struct {
2125 2126 2127
  char    key[TSDB_SUBSCRIBE_KEY_LEN];
  SArray* removedConsumers;  // SArray<int64_t>
  SArray* newConsumers;      // SArray<int64_t>
L
Liu Jicong 已提交
2128
} SMqRebInfo;
L
Liu Jicong 已提交
2129

L
Liu Jicong 已提交
2130 2131 2132
static FORCE_INLINE SMqRebInfo* tNewSMqRebSubscribe(const char* key) {
  SMqRebInfo* pRebInfo = (SMqRebInfo*)taosMemoryCalloc(1, sizeof(SMqRebInfo));
  if (pRebInfo == NULL) {
L
Liu Jicong 已提交
2133
    return NULL;
L
Liu Jicong 已提交
2134
  }
L
Liu Jicong 已提交
2135
  tstrncpy(pRebInfo->key, key, TSDB_SUBSCRIBE_KEY_LEN);
L
Liu Jicong 已提交
2136 2137
  pRebInfo->removedConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->removedConsumers == NULL) {
L
Liu Jicong 已提交
2138 2139
    goto _err;
  }
L
Liu Jicong 已提交
2140 2141
  pRebInfo->newConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->newConsumers == NULL) {
L
Liu Jicong 已提交
2142 2143
    goto _err;
  }
L
Liu Jicong 已提交
2144
  return pRebInfo;
L
Liu Jicong 已提交
2145
_err:
L
Liu Jicong 已提交
2146 2147 2148
  taosArrayDestroy(pRebInfo->removedConsumers);
  taosArrayDestroy(pRebInfo->newConsumers);
  taosMemoryFreeClear(pRebInfo);
L
Liu Jicong 已提交
2149 2150 2151
  return NULL;
}

L
Liu Jicong 已提交
2152 2153
// this message is sent from mnode to mnode(read thread to write thread),
// so there is no need for serialization or deserialization
L
Liu Jicong 已提交
2154
typedef struct {
2155
  SHashObj* rebSubHash;  // SHashObj<key, SMqRebSubscribe>
L
Liu Jicong 已提交
2156 2157
} SMqDoRebalanceMsg;

2158 2159 2160 2161 2162 2163
typedef struct {
  int64_t streamId;
  int64_t checkpointId;
  char    streamName[TSDB_STREAM_FNAME_LEN];
} SMStreamDoCheckpointMsg;

L
Liu Jicong 已提交
2164
typedef struct {
L
Liu Jicong 已提交
2165
  int64_t status;
L
Liu Jicong 已提交
2166 2167
} SMVSubscribeRsp;

L
Liu Jicong 已提交
2168
typedef struct {
2169
  char   name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2170
  int8_t igNotExists;
S
Shengliang Guan 已提交
2171 2172
} SMDropTopicReq;

S
Shengliang Guan 已提交
2173
int32_t tSerializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
S
Shengliang Guan 已提交
2174
int32_t tDeserializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
L
Liu Jicong 已提交
2175

2176 2177 2178 2179 2180 2181 2182 2183 2184
typedef struct {
  char   topic[TSDB_TOPIC_FNAME_LEN];
  char   cgroup[TSDB_CGROUP_LEN];
  int8_t igNotExists;
} SMDropCgroupReq;

int32_t tSerializeSMDropCgroupReq(void* buf, int32_t bufLen, SMDropCgroupReq* pReq);
int32_t tDeserializeSMDropCgroupReq(void* buf, int32_t bufLen, SMDropCgroupReq* pReq);

L
Liu Jicong 已提交
2185 2186 2187 2188
typedef struct {
  int8_t reserved;
} SMDropCgroupRsp;

L
Liu Jicong 已提交
2189 2190 2191 2192
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
  SSchema schema;
S
Shengliang Guan 已提交
2193
} SAlterTopicReq;
L
Liu Jicong 已提交
2194 2195 2196 2197

typedef struct {
  SMsgHead head;
  char     name[TSDB_TABLE_FNAME_LEN];
L
Liu Jicong 已提交
2198
  int64_t  tuid;
L
Liu Jicong 已提交
2199 2200 2201 2202 2203
  int32_t  sverson;
  int32_t  execLen;
  char*    executor;
  int32_t  sqlLen;
  char*    sql;
S
Shengliang Guan 已提交
2204
} SDCreateTopicReq;
L
Liu Jicong 已提交
2205 2206 2207 2208

typedef struct {
  SMsgHead head;
  char     name[TSDB_TABLE_FNAME_LEN];
L
Liu Jicong 已提交
2209
  int64_t  tuid;
S
Shengliang Guan 已提交
2210
} SDDropTopicReq;
S
Shengliang Guan 已提交
2211

C
Cary Xu 已提交
2212
typedef struct {
2213 2214
  int64_t maxdelay[2];
  int64_t watermark[2];
2215
  int64_t deleteMark[2];
2216 2217
  int32_t qmsgLen[2];
  char*   qmsg[2];  // pAst:qmsg:SRetention => trigger aggr task1/2
C
Cary Xu 已提交
2218 2219
} SRSmaParam;

H
Hongze Cheng 已提交
2220 2221
int32_t tEncodeSRSmaParam(SEncoder* pCoder, const SRSmaParam* pRSmaParam);
int32_t tDecodeSRSmaParam(SDecoder* pCoder, SRSmaParam* pRSmaParam);
H
Hongze Cheng 已提交
2222

H
Hongze Cheng 已提交
2223
// TDMT_VND_CREATE_STB ==============
H
Hongze Cheng 已提交
2224
typedef struct SVCreateStbReq {
H
Hongze Cheng 已提交
2225
  char*          name;
H
Hongze Cheng 已提交
2226 2227
  tb_uid_t       suid;
  int8_t         rollup;
2228
  SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
2229
  SSchemaWrapper schemaTag;
C
Cary Xu 已提交
2230
  SRSmaParam     rsmaParam;
wmmhello's avatar
wmmhello 已提交
2231 2232
  int32_t        alterOriDataLen;
  void*          alterOriData;
H
Hongze Cheng 已提交
2233 2234
} SVCreateStbReq;

H
Hongze Cheng 已提交
2235 2236
int tEncodeSVCreateStbReq(SEncoder* pCoder, const SVCreateStbReq* pReq);
int tDecodeSVCreateStbReq(SDecoder* pCoder, SVCreateStbReq* pReq);
H
Hongze Cheng 已提交
2237

H
Hongze Cheng 已提交
2238
// TDMT_VND_DROP_STB ==============
H
Hongze Cheng 已提交
2239
typedef struct SVDropStbReq {
H
Hongze Cheng 已提交
2240 2241
  char*    name;
  tb_uid_t suid;
H
Hongze Cheng 已提交
2242 2243
} SVDropStbReq;

H
Hongze Cheng 已提交
2244 2245
int32_t tEncodeSVDropStbReq(SEncoder* pCoder, const SVDropStbReq* pReq);
int32_t tDecodeSVDropStbReq(SDecoder* pCoder, SVDropStbReq* pReq);
H
Hongze Cheng 已提交
2246

H
Hongze Cheng 已提交
2247
// TDMT_VND_CREATE_TABLE ==============
H
Hongze Cheng 已提交
2248
#define TD_CREATE_IF_NOT_EXISTS 0x1
H
more  
Hongze Cheng 已提交
2249
typedef struct SVCreateTbReq {
H
Hongze Cheng 已提交
2250
  int32_t  flags;
H
Hongze Cheng 已提交
2251
  char*    name;
H
Hongze Cheng 已提交
2252 2253 2254
  tb_uid_t uid;
  int64_t  ctime;
  int32_t  ttl;
wmmhello's avatar
wmmhello 已提交
2255 2256
  int32_t  commentLen;
  char*    comment;
H
Hongze Cheng 已提交
2257
  int8_t   type;
C
Cary Xu 已提交
2258 2259
  union {
    struct {
2260
      char*    stbName;  // super table name
X
Xiaoyu Wang 已提交
2261
      uint8_t  tagNum;
H
Hongze Cheng 已提交
2262
      tb_uid_t suid;
wmmhello's avatar
wmmhello 已提交
2263
      SArray*  tagName;
H
Hongze Cheng 已提交
2264
      uint8_t* pTag;
H
Hongze Cheng 已提交
2265
    } ctb;
H
more  
Hongze Cheng 已提交
2266
    struct {
2267
      SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
2268
    } ntb;
H
more  
Hongze Cheng 已提交
2269
  };
H
Hongze Cheng 已提交
2270
} SVCreateTbReq;
H
Hongze Cheng 已提交
2271

H
Hongze Cheng 已提交
2272 2273 2274
int  tEncodeSVCreateTbReq(SEncoder* pCoder, const SVCreateTbReq* pReq);
int  tDecodeSVCreateTbReq(SDecoder* pCoder, SVCreateTbReq* pReq);
void tDestroySVCreateTbReq(SVCreateTbReq* pReq, int32_t flags);
H
Hongze Cheng 已提交
2275

C
Cary Xu 已提交
2276
static FORCE_INLINE void tdDestroySVCreateTbReq(SVCreateTbReq* req) {
X
Xiaoyu Wang 已提交
2277 2278 2279 2280
  if (NULL == req) {
    return;
  }

C
Cary Xu 已提交
2281
  taosMemoryFreeClear(req->name);
wmmhello's avatar
wmmhello 已提交
2282
  taosMemoryFreeClear(req->comment);
C
Cary Xu 已提交
2283 2284
  if (req->type == TSDB_CHILD_TABLE) {
    taosMemoryFreeClear(req->ctb.pTag);
2285
    taosMemoryFreeClear(req->ctb.stbName);
wmmhello's avatar
wmmhello 已提交
2286
    taosArrayDestroy(req->ctb.tagName);
wmmhello's avatar
wmmhello 已提交
2287
    req->ctb.tagName = NULL;
C
Cary Xu 已提交
2288 2289 2290 2291 2292
  } else if (req->type == TSDB_NORMAL_TABLE) {
    taosMemoryFreeClear(req->ntb.schemaRow.pSchema);
  }
}

H
more  
Hongze Cheng 已提交
2293
typedef struct {
H
Hongze Cheng 已提交
2294 2295 2296 2297 2298
  int32_t nReqs;
  union {
    SVCreateTbReq* pReqs;
    SArray*        pArray;
  };
H
more  
Hongze Cheng 已提交
2299
} SVCreateTbBatchReq;
H
more  
Hongze Cheng 已提交
2300

H
Hongze Cheng 已提交
2301 2302
int tEncodeSVCreateTbBatchReq(SEncoder* pCoder, const SVCreateTbBatchReq* pReq);
int tDecodeSVCreateTbBatchReq(SDecoder* pCoder, SVCreateTbBatchReq* pReq);
H
more  
Hongze Cheng 已提交
2303

H
more  
Hongze Cheng 已提交
2304
typedef struct {
2305 2306
  int32_t        code;
  STableMetaRsp* pMeta;
S
Shengliang Guan 已提交
2307
} SVCreateTbRsp, SVUpdateTbRsp;
H
more  
Hongze Cheng 已提交
2308

L
Liu Jicong 已提交
2309 2310
int  tEncodeSVCreateTbRsp(SEncoder* pCoder, const SVCreateTbRsp* pRsp);
int  tDecodeSVCreateTbRsp(SDecoder* pCoder, SVCreateTbRsp* pRsp);
2311
void tFreeSVCreateTbRsp(void* param);
H
Hongze Cheng 已提交
2312

S
Shengliang Guan 已提交
2313 2314
int32_t tSerializeSVCreateTbReq(void** buf, SVCreateTbReq* pReq);
void*   tDeserializeSVCreateTbReq(void* buf, SVCreateTbReq* pReq);
H
more  
Hongze Cheng 已提交
2315

H
more  
Hongze Cheng 已提交
2316
typedef struct {
H
Hongze Cheng 已提交
2317 2318 2319 2320 2321
  int32_t nRsps;
  union {
    SVCreateTbRsp* pRsps;
    SArray*        pArray;
  };
S
Shengliang Guan 已提交
2322
} SVCreateTbBatchRsp;
H
more  
Hongze Cheng 已提交
2323

H
Hongze Cheng 已提交
2324 2325
int tEncodeSVCreateTbBatchRsp(SEncoder* pCoder, const SVCreateTbBatchRsp* pRsp);
int tDecodeSVCreateTbBatchRsp(SDecoder* pCoder, SVCreateTbBatchRsp* pRsp);
H
Hongze Cheng 已提交
2326

L
Liu Jicong 已提交
2327 2328
int32_t tSerializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
int32_t tDeserializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
2329

H
Hongze Cheng 已提交
2330
// TDMT_VND_DROP_TABLE =================
S
Shengliang Guan 已提交
2331
typedef struct {
2332 2333 2334
  char*    name;
  uint64_t suid;  // for tmq in wal format
  int8_t   igNotExists;
S
Shengliang Guan 已提交
2335 2336 2337
} SVDropTbReq;

typedef struct {
H
Hongze Cheng 已提交
2338
  int32_t code;
S
Shengliang Guan 已提交
2339 2340
} SVDropTbRsp;

H
Hongze Cheng 已提交
2341 2342 2343 2344 2345 2346 2347 2348
typedef struct {
  int32_t nReqs;
  union {
    SVDropTbReq* pReqs;
    SArray*      pArray;
  };
} SVDropTbBatchReq;

H
Hongze Cheng 已提交
2349 2350
int32_t tEncodeSVDropTbBatchReq(SEncoder* pCoder, const SVDropTbBatchReq* pReq);
int32_t tDecodeSVDropTbBatchReq(SDecoder* pCoder, SVDropTbBatchReq* pReq);
H
Hongze Cheng 已提交
2351 2352 2353 2354 2355 2356 2357 2358 2359

typedef struct {
  int32_t nRsps;
  union {
    SVDropTbRsp* pRsps;
    SArray*      pArray;
  };
} SVDropTbBatchRsp;

H
Hongze Cheng 已提交
2360 2361
int32_t tEncodeSVDropTbBatchRsp(SEncoder* pCoder, const SVDropTbBatchRsp* pRsp);
int32_t tDecodeSVDropTbBatchRsp(SDecoder* pCoder, SVDropTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
2362

H
Hongze Cheng 已提交
2363 2364
// TDMT_VND_ALTER_TABLE =====================
typedef struct {
2365 2366 2367 2368
  char*   tbName;
  int8_t  action;
  char*   colName;
  int32_t colId;
H
Hongze Cheng 已提交
2369
  // TSDB_ALTER_TABLE_ADD_COLUMN
H
Hongze Cheng 已提交
2370 2371 2372
  int8_t  type;
  int8_t  flags;
  int32_t bytes;
H
Hongze Cheng 已提交
2373 2374
  // TSDB_ALTER_TABLE_DROP_COLUMN
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES
wmmhello's avatar
wmmhello 已提交
2375
  int8_t  colModType;
H
Hongze Cheng 已提交
2376
  int32_t colModBytes;
H
Hongze Cheng 已提交
2377
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME
H
Hongze Cheng 已提交
2378
  char* colNewName;
H
Hongze Cheng 已提交
2379
  // TSDB_ALTER_TABLE_UPDATE_TAG_VAL
H
Hongze Cheng 已提交
2380 2381
  char*    tagName;
  int8_t   isNull;
wmmhello's avatar
wmmhello 已提交
2382
  int8_t   tagType;
H
Hongze Cheng 已提交
2383 2384
  uint32_t nTagVal;
  uint8_t* pTagVal;
H
Hongze Cheng 已提交
2385
  // TSDB_ALTER_TABLE_UPDATE_OPTIONS
H
Hongze Cheng 已提交
2386 2387
  int8_t  updateTTL;
  int32_t newTTL;
wmmhello's avatar
wmmhello 已提交
2388
  int32_t newCommentLen;
H
Hongze Cheng 已提交
2389
  char*   newComment;
H
Hongze Cheng 已提交
2390 2391 2392 2393 2394 2395
} SVAlterTbReq;

int32_t tEncodeSVAlterTbReq(SEncoder* pEncoder, const SVAlterTbReq* pReq);
int32_t tDecodeSVAlterTbReq(SDecoder* pDecoder, SVAlterTbReq* pReq);

typedef struct {
D
dapan1121 已提交
2396 2397
  int32_t        code;
  STableMetaRsp* pMeta;
H
Hongze Cheng 已提交
2398 2399 2400 2401 2402 2403
} SVAlterTbRsp;

int32_t tEncodeSVAlterTbRsp(SEncoder* pEncoder, const SVAlterTbRsp* pRsp);
int32_t tDecodeSVAlterTbRsp(SDecoder* pDecoder, SVAlterTbRsp* pRsp);
// ======================

S
Shengliang Guan 已提交
2404 2405 2406 2407 2408 2409 2410 2411 2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422
typedef struct {
  SMsgHead head;
  int64_t  uid;
  int32_t  tid;
  int16_t  tversion;
  int16_t  colId;
  int8_t   type;
  int16_t  bytes;
  int32_t  tagValLen;
  int16_t  numOfTags;
  int32_t  schemaLen;
  char     data[];
} SUpdateTagValReq;

typedef struct {
  SMsgHead head;
} SUpdateTagValRsp;

typedef struct {
H
Hongze Cheng 已提交
2423 2424 2425
  SMsgHead head;
} SVShowTablesReq;

S
Shengliang Guan 已提交
2426
typedef struct {
H
Hongze Cheng 已提交
2427
  SMsgHead head;
H
Haojun Liao 已提交
2428
  int32_t  id;
H
Hongze Cheng 已提交
2429 2430
} SVShowTablesFetchReq;

S
Shengliang Guan 已提交
2431
typedef struct {
H
Hongze Cheng 已提交
2432 2433 2434 2435 2436 2437 2438 2439 2440
  int64_t useconds;
  int8_t  completed;  // all results are returned to client
  int8_t  precision;
  int8_t  compressed;
  int32_t compLen;
  int32_t numOfRows;
  char    data[];
} SVShowTablesFetchRsp;

L
Liu Jicong 已提交
2441
typedef struct {
L
Liu Jicong 已提交
2442 2443
  int64_t consumerId;
  int32_t epoch;
L
Liu Jicong 已提交
2444
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2445
} SMqAskEpReq;
L
Liu Jicong 已提交
2446

2447 2448 2449 2450 2451 2452 2453 2454 2455
typedef struct {
  int64_t consumerId;
  int32_t epoch;
} SMqHbReq;

typedef struct {
  int8_t reserved;
} SMqHbRsp;

L
Liu Jicong 已提交
2456
typedef struct {
D
dapan1121 已提交
2457
  int32_t key;
L
Liu Jicong 已提交
2458 2459 2460 2461 2462
  int32_t valueLen;
  void*   value;
} SKv;

typedef struct {
D
dapan1121 已提交
2463
  int64_t tscRid;
D
dapan1121 已提交
2464
  int8_t  connType;
L
Liu Jicong 已提交
2465 2466 2467
} SClientHbKey;

typedef struct {
D
dapan1121 已提交
2468
  int64_t tid;
2469
  char    status[TSDB_JOB_STATUS_LEN];
D
dapan1121 已提交
2470 2471 2472 2473 2474 2475
} SQuerySubDesc;

typedef struct {
  char     sql[TSDB_SHOW_SQL_LEN];
  uint64_t queryId;
  int64_t  useconds;
L
Liu Jicong 已提交
2476
  int64_t  stime;  // timestamp precision ms
D
dapan1121 已提交
2477
  int64_t  reqRid;
2478
  bool     stableQuery;
D
dapan1121 已提交
2479 2480
  char     fqdn[TSDB_FQDN_LEN];
  int32_t  subPlanNum;
2481
  SArray*  subDesc;  // SArray<SQuerySubDesc>
D
dapan1121 已提交
2482 2483 2484
} SQueryDesc;

typedef struct {
2485 2486
  uint32_t connId;
  SArray*  queryDesc;  // SArray<SQueryDesc>
D
dapan1121 已提交
2487 2488 2489 2490 2491 2492 2493 2494 2495 2496
} SQueryHbReqBasic;

typedef struct {
  uint32_t connId;
  uint64_t killRid;
  int32_t  totalDnodes;
  int32_t  onlineDnodes;
  int8_t   killConnection;
  int8_t   align[3];
  SEpSet   epSet;
L
Liu Jicong 已提交
2497
  SArray*  pQnodeList;
D
dapan1121 已提交
2498 2499
} SQueryHbRspBasic;

D
dapan1121 已提交
2500 2501 2502 2503 2504 2505 2506
typedef struct SAppClusterSummary {
  uint64_t numOfInsertsReq;
  uint64_t numOfInsertRows;
  uint64_t insertElapsedTime;
  uint64_t insertBytes;  // submit to tsdb since launched.

  uint64_t fetchBytes;
D
dapan1121 已提交
2507
  uint64_t numOfQueryReq;
D
dapan1121 已提交
2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521
  uint64_t queryElapsedTime;
  uint64_t numOfSlowQueries;
  uint64_t totalRequests;
  uint64_t currentRequests;  // the number of SRequestObj
} SAppClusterSummary;

typedef struct {
  int64_t            appId;
  int32_t            pid;
  char               name[TSDB_APP_NAME_LEN];
  int64_t            startTime;
  SAppClusterSummary summary;
} SAppHbReq;

D
dapan1121 已提交
2522 2523
typedef struct {
  SClientHbKey      connKey;
D
dapan1121 已提交
2524
  int64_t           clusterId;
D
dapan1121 已提交
2525
  SAppHbReq         app;
D
dapan1121 已提交
2526 2527
  SQueryHbReqBasic* query;
  SHashObj*         info;  // hash<Skv.key, Skv>
L
Liu Jicong 已提交
2528 2529 2530 2531 2532 2533 2534 2535
} SClientHbReq;

typedef struct {
  int64_t reqId;
  SArray* reqs;  // SArray<SClientHbReq>
} SClientHbBatchReq;

typedef struct {
D
dapan1121 已提交
2536 2537 2538 2539
  SClientHbKey      connKey;
  int32_t           status;
  SQueryHbRspBasic* query;
  SArray*           info;  // Array<Skv>
L
Liu Jicong 已提交
2540 2541 2542 2543 2544
} SClientHbRsp;

typedef struct {
  int64_t reqId;
  int64_t rspId;
dengyihao's avatar
dengyihao 已提交
2545
  int32_t svrTimestamp;
L
Liu Jicong 已提交
2546 2547 2548
  SArray* rsps;  // SArray<SClientHbRsp>
} SClientHbBatchRsp;

2549
static FORCE_INLINE uint32_t hbKeyHashFunc(const char* key, uint32_t keyLen) { return taosIntHash_64(key, keyLen); }
L
Liu Jicong 已提交
2550

2551 2552
static FORCE_INLINE void tFreeReqKvHash(SHashObj* info) {
  void* pIter = taosHashIterate(info, NULL);
D
dapan1121 已提交
2553 2554
  while (pIter != NULL) {
    SKv* kv = (SKv*)pIter;
wafwerar's avatar
wafwerar 已提交
2555
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2556 2557 2558 2559
    pIter = taosHashIterate(info, pIter);
  }
}

D
dapan1121 已提交
2560 2561 2562 2563 2564 2565 2566 2567
static FORCE_INLINE void tFreeClientHbQueryDesc(void* pDesc) {
  SQueryDesc* desc = (SQueryDesc*)pDesc;
  if (desc->subDesc) {
    taosArrayDestroy(desc->subDesc);
    desc->subDesc = NULL;
  }
}

2568
static FORCE_INLINE void tFreeClientHbReq(void* pReq) {
L
Liu Jicong 已提交
2569
  SClientHbReq* req = (SClientHbReq*)pReq;
D
dapan1121 已提交
2570 2571 2572 2573 2574 2575
  if (req->query) {
    if (req->query->queryDesc) {
      taosArrayDestroyEx(req->query->queryDesc, tFreeClientHbQueryDesc);
    }
    taosMemoryFreeClear(req->query);
  }
2576

D
dapan1121 已提交
2577 2578 2579
  if (req->info) {
    tFreeReqKvHash(req->info);
    taosHashCleanup(req->info);
D
dapan1121 已提交
2580
    req->info = NULL;
D
dapan1121 已提交
2581
  }
L
Liu Jicong 已提交
2582 2583
}

S
Shengliang Guan 已提交
2584 2585
int32_t tSerializeSClientHbBatchReq(void* buf, int32_t bufLen, const SClientHbBatchReq* pReq);
int32_t tDeserializeSClientHbBatchReq(void* buf, int32_t bufLen, SClientHbBatchReq* pReq);
L
Liu Jicong 已提交
2586

D
dapan1121 已提交
2587
static FORCE_INLINE void tFreeClientHbBatchReq(void* pReq) {
dengyihao's avatar
dengyihao 已提交
2588
  if (pReq == NULL) return;
2589
  SClientHbBatchReq* req = (SClientHbBatchReq*)pReq;
D
dapan1121 已提交
2590
  taosArrayDestroyEx(req->reqs, tFreeClientHbReq);
wafwerar's avatar
wafwerar 已提交
2591
  taosMemoryFree(pReq);
L
Liu Jicong 已提交
2592 2593
}

2594 2595
static FORCE_INLINE void tFreeClientKv(void* pKv) {
  SKv* kv = (SKv*)pKv;
D
dapan1121 已提交
2596
  if (kv) {
wafwerar's avatar
wafwerar 已提交
2597
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2598 2599 2600
  }
}

2601
static FORCE_INLINE void tFreeClientHbRsp(void* pRsp) {
D
dapan1121 已提交
2602
  SClientHbRsp* rsp = (SClientHbRsp*)pRsp;
D
dapan1121 已提交
2603 2604 2605 2606
  if (rsp->query) {
    taosArrayDestroy(rsp->query->pQnodeList);
    taosMemoryFreeClear(rsp->query);
  }
D
dapan1121 已提交
2607 2608 2609 2610
  if (rsp->info) taosArrayDestroyEx(rsp->info, tFreeClientKv);
}

static FORCE_INLINE void tFreeClientHbBatchRsp(void* pRsp) {
2611
  SClientHbBatchRsp* rsp = (SClientHbBatchRsp*)pRsp;
D
dapan1121 已提交
2612 2613 2614
  taosArrayDestroyEx(rsp->rsps, tFreeClientHbRsp);
}

S
Shengliang Guan 已提交
2615 2616
int32_t tSerializeSClientHbBatchRsp(void* buf, int32_t bufLen, const SClientHbBatchRsp* pBatchRsp);
int32_t tDeserializeSClientHbBatchRsp(void* buf, int32_t bufLen, SClientHbBatchRsp* pBatchRsp);
H
Hongze Cheng 已提交
2617
void    tFreeSClientHbBatchRsp(SClientHbBatchRsp* pBatchRsp);
L
Liu Jicong 已提交
2618

H
Hongze Cheng 已提交
2619
static FORCE_INLINE int32_t tEncodeSKv(SEncoder* pEncoder, const SKv* pKv) {
S
Shengliang Guan 已提交
2620 2621
  if (tEncodeI32(pEncoder, pKv->key) < 0) return -1;
  if (tEncodeI32(pEncoder, pKv->valueLen) < 0) return -1;
H
Hongze Cheng 已提交
2622
  if (tEncodeBinary(pEncoder, (uint8_t*)pKv->value, pKv->valueLen) < 0) return -1;
S
Shengliang Guan 已提交
2623
  return 0;
L
Liu Jicong 已提交
2624 2625
}

H
Hongze Cheng 已提交
2626
static FORCE_INLINE int32_t tDecodeSKv(SDecoder* pDecoder, SKv* pKv) {
S
Shengliang Guan 已提交
2627 2628
  if (tDecodeI32(pDecoder, &pKv->key) < 0) return -1;
  if (tDecodeI32(pDecoder, &pKv->valueLen) < 0) return -1;
wafwerar's avatar
wafwerar 已提交
2629
  pKv->value = taosMemoryMalloc(pKv->valueLen + 1);
S
Shengliang Guan 已提交
2630 2631 2632
  if (pKv->value == NULL) return -1;
  if (tDecodeCStrTo(pDecoder, (char*)pKv->value) < 0) return -1;
  return 0;
L
Liu Jicong 已提交
2633 2634
}

H
Hongze Cheng 已提交
2635
static FORCE_INLINE int32_t tEncodeSClientHbKey(SEncoder* pEncoder, const SClientHbKey* pKey) {
D
dapan1121 已提交
2636
  if (tEncodeI64(pEncoder, pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2637
  if (tEncodeI8(pEncoder, pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2638
  return 0;
L
Liu Jicong 已提交
2639 2640
}

H
Hongze Cheng 已提交
2641
static FORCE_INLINE int32_t tDecodeSClientHbKey(SDecoder* pDecoder, SClientHbKey* pKey) {
D
dapan1121 已提交
2642
  if (tDecodeI64(pDecoder, &pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2643
  if (tDecodeI8(pDecoder, &pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2644
  return 0;
L
Liu Jicong 已提交
2645 2646
}

2647
typedef struct {
L
Liu Jicong 已提交
2648
  int32_t vgId;
2649 2650
  // TODO stas
} SMqReportVgInfo;
L
Liu Jicong 已提交
2651

2652
static FORCE_INLINE int32_t taosEncodeSMqVgInfo(void** buf, const SMqReportVgInfo* pVgInfo) {
S
Shengliang Guan 已提交
2653
  int32_t tlen = 0;
L
Liu Jicong 已提交
2654 2655 2656 2657
  tlen += taosEncodeFixedI32(buf, pVgInfo->vgId);
  return tlen;
}

2658
static FORCE_INLINE void* taosDecodeSMqVgInfo(void* buf, SMqReportVgInfo* pVgInfo) {
L
Liu Jicong 已提交
2659 2660 2661 2662
  buf = taosDecodeFixedI32(buf, &pVgInfo->vgId);
  return buf;
}

2663
typedef struct {
L
Liu Jicong 已提交
2664 2665 2666
  int32_t epoch;
  int64_t topicUid;
  char    name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2667
  SArray* pVgInfo;  // SArray<SMqHbVgInfo>
2668
} SMqTopicInfo;
L
Liu Jicong 已提交
2669

2670
static FORCE_INLINE int32_t taosEncodeSMqTopicInfoMsg(void** buf, const SMqTopicInfo* pTopicInfo) {
S
Shengliang Guan 已提交
2671
  int32_t tlen = 0;
L
Liu Jicong 已提交
2672 2673 2674 2675 2676 2677
  tlen += taosEncodeFixedI32(buf, pTopicInfo->epoch);
  tlen += taosEncodeFixedI64(buf, pTopicInfo->topicUid);
  tlen += taosEncodeString(buf, pTopicInfo->name);
  int32_t sz = taosArrayGetSize(pTopicInfo->pVgInfo);
  tlen += taosEncodeFixedI32(buf, sz);
  for (int32_t i = 0; i < sz; i++) {
2678
    SMqReportVgInfo* pVgInfo = (SMqReportVgInfo*)taosArrayGet(pTopicInfo->pVgInfo, i);
L
Liu Jicong 已提交
2679 2680 2681 2682 2683
    tlen += taosEncodeSMqVgInfo(buf, pVgInfo);
  }
  return tlen;
}

2684
static FORCE_INLINE void* taosDecodeSMqTopicInfoMsg(void* buf, SMqTopicInfo* pTopicInfo) {
L
Liu Jicong 已提交
2685 2686 2687 2688 2689
  buf = taosDecodeFixedI32(buf, &pTopicInfo->epoch);
  buf = taosDecodeFixedI64(buf, &pTopicInfo->topicUid);
  buf = taosDecodeStringTo(buf, pTopicInfo->name);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
2690
  pTopicInfo->pVgInfo = taosArrayInit(sz, sizeof(SMqReportVgInfo));
L
Liu Jicong 已提交
2691
  for (int32_t i = 0; i < sz; i++) {
2692
    SMqReportVgInfo vgInfo;
L
Liu Jicong 已提交
2693 2694 2695 2696 2697 2698
    buf = taosDecodeSMqVgInfo(buf, &vgInfo);
    taosArrayPush(pTopicInfo->pVgInfo, &vgInfo);
  }
  return buf;
}

2699
typedef struct {
2700 2701 2702 2703
  int32_t status;  // ask hb endpoint
  int32_t epoch;
  int64_t consumerId;
  SArray* pTopics;  // SArray<SMqHbTopicInfo>
2704
} SMqReportReq;
L
Liu Jicong 已提交
2705

2706
static FORCE_INLINE int32_t taosEncodeSMqReportMsg(void** buf, const SMqReportReq* pMsg) {
S
Shengliang Guan 已提交
2707
  int32_t tlen = 0;
L
Liu Jicong 已提交
2708 2709 2710 2711 2712
  tlen += taosEncodeFixedI32(buf, pMsg->status);
  tlen += taosEncodeFixedI32(buf, pMsg->epoch);
  tlen += taosEncodeFixedI64(buf, pMsg->consumerId);
  int32_t sz = taosArrayGetSize(pMsg->pTopics);
  tlen += taosEncodeFixedI32(buf, sz);
S
Shengliang Guan 已提交
2713
  for (int32_t i = 0; i < sz; i++) {
2714 2715
    SMqTopicInfo* topicInfo = (SMqTopicInfo*)taosArrayGet(pMsg->pTopics, i);
    tlen += taosEncodeSMqTopicInfoMsg(buf, topicInfo);
L
Liu Jicong 已提交
2716 2717 2718 2719
  }
  return tlen;
}

2720
static FORCE_INLINE void* taosDecodeSMqReportMsg(void* buf, SMqReportReq* pMsg) {
L
Liu Jicong 已提交
2721 2722 2723 2724 2725
  buf = taosDecodeFixedI32(buf, &pMsg->status);
  buf = taosDecodeFixedI32(buf, &pMsg->epoch);
  buf = taosDecodeFixedI64(buf, &pMsg->consumerId);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
2726
  pMsg->pTopics = taosArrayInit(sz, sizeof(SMqTopicInfo));
S
Shengliang Guan 已提交
2727
  for (int32_t i = 0; i < sz; i++) {
2728 2729
    SMqTopicInfo topicInfo;
    buf = taosDecodeSMqTopicInfoMsg(buf, &topicInfo);
L
Liu Jicong 已提交
2730 2731 2732 2733 2734
    taosArrayPush(pMsg->pTopics, &topicInfo);
  }
  return buf;
}

L
Liu Jicong 已提交
2735 2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746
typedef struct {
  SMsgHead head;
  int64_t  leftForVer;
  int32_t  vgId;
  int64_t  consumerId;
  char     subKey[TSDB_SUBSCRIBE_KEY_LEN];
} SMqVDeleteReq;

typedef struct {
  int8_t reserved;
} SMqVDeleteRsp;

L
Liu Jicong 已提交
2747
typedef struct {
L
Liu Jicong 已提交
2748 2749
  char   name[TSDB_STREAM_FNAME_LEN];
  int8_t igNotExists;
L
Liu Jicong 已提交
2750
} SMDropStreamReq;
L
Liu Jicong 已提交
2751 2752 2753

typedef struct {
  int8_t reserved;
L
Liu Jicong 已提交
2754
} SMDropStreamRsp;
L
Liu Jicong 已提交
2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765

typedef struct {
  SMsgHead head;
  int64_t  leftForVer;
  int32_t  taskId;
} SVDropStreamTaskReq;

typedef struct {
  int8_t reserved;
} SVDropStreamTaskRsp;

L
Liu Jicong 已提交
2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786
int32_t tSerializeSMDropStreamReq(void* buf, int32_t bufLen, const SMDropStreamReq* pReq);
int32_t tDeserializeSMDropStreamReq(void* buf, int32_t bufLen, SMDropStreamReq* pReq);

typedef struct {
  char   name[TSDB_STREAM_FNAME_LEN];
  int8_t igNotExists;
} SMRecoverStreamReq;

typedef struct {
  int8_t reserved;
} SMRecoverStreamRsp;

typedef struct {
  int64_t recoverObjUid;
  int32_t taskId;
  int32_t hasCheckPoint;
} SMVStreamGatherInfoReq;

int32_t tSerializeSMRecoverStreamReq(void* buf, int32_t bufLen, const SMRecoverStreamReq* pReq);
int32_t tDeserializeSMRecoverStreamReq(void* buf, int32_t bufLen, SMRecoverStreamReq* pReq);

2787 2788 2789 2790 2791 2792
typedef struct {
  int64_t leftForVer;
  int32_t vgId;
  int64_t oldConsumerId;
  int64_t newConsumerId;
  char    subKey[TSDB_SUBSCRIBE_KEY_LEN];
L
Liu Jicong 已提交
2793
  int8_t  subType;
L
Liu Jicong 已提交
2794
  int8_t  withMeta;
dengyihao's avatar
dengyihao 已提交
2795
  char*   qmsg;  // SubPlanToString
L
Liu Jicong 已提交
2796
  int64_t suid;
2797 2798 2799 2800 2801 2802 2803 2804 2805
} SMqRebVgReq;

static FORCE_INLINE int32_t tEncodeSMqRebVgReq(void** buf, const SMqRebVgReq* pReq) {
  int32_t tlen = 0;
  tlen += taosEncodeFixedI64(buf, pReq->leftForVer);
  tlen += taosEncodeFixedI32(buf, pReq->vgId);
  tlen += taosEncodeFixedI64(buf, pReq->oldConsumerId);
  tlen += taosEncodeFixedI64(buf, pReq->newConsumerId);
  tlen += taosEncodeString(buf, pReq->subKey);
L
Liu Jicong 已提交
2806
  tlen += taosEncodeFixedI8(buf, pReq->subType);
L
Liu Jicong 已提交
2807
  tlen += taosEncodeFixedI8(buf, pReq->withMeta);
L
Liu Jicong 已提交
2808
  if (pReq->subType == TOPIC_SUB_TYPE__COLUMN) {
L
Liu Jicong 已提交
2809
    tlen += taosEncodeString(buf, pReq->qmsg);
L
Liu Jicong 已提交
2810 2811
  } else if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    tlen += taosEncodeFixedI64(buf, pReq->suid);
L
Liu Jicong 已提交
2812
  }
2813 2814 2815 2816 2817 2818 2819 2820 2821
  return tlen;
}

static FORCE_INLINE void* tDecodeSMqRebVgReq(const void* buf, SMqRebVgReq* pReq) {
  buf = taosDecodeFixedI64(buf, &pReq->leftForVer);
  buf = taosDecodeFixedI32(buf, &pReq->vgId);
  buf = taosDecodeFixedI64(buf, &pReq->oldConsumerId);
  buf = taosDecodeFixedI64(buf, &pReq->newConsumerId);
  buf = taosDecodeStringTo(buf, pReq->subKey);
L
Liu Jicong 已提交
2822
  buf = taosDecodeFixedI8(buf, &pReq->subType);
L
Liu Jicong 已提交
2823
  buf = taosDecodeFixedI8(buf, &pReq->withMeta);
L
Liu Jicong 已提交
2824
  if (pReq->subType == TOPIC_SUB_TYPE__COLUMN) {
L
Liu Jicong 已提交
2825
    buf = taosDecodeString(buf, &pReq->qmsg);
L
Liu Jicong 已提交
2826 2827
  } else if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    buf = taosDecodeFixedI64(buf, &pReq->suid);
L
Liu Jicong 已提交
2828
  }
2829 2830 2831
  return (void*)buf;
}

L
Liu Jicong 已提交
2832 2833 2834 2835
typedef struct {
  char    topic[TSDB_TOPIC_FNAME_LEN];
  int64_t ntbUid;
  SArray* colIdList;  // SArray<int16_t>
2836
} STqCheckInfo;
L
Liu Jicong 已提交
2837

2838 2839
int32_t tEncodeSTqCheckInfo(SEncoder* pEncoder, const STqCheckInfo* pInfo);
int32_t tDecodeSTqCheckInfo(SDecoder* pDecoder, STqCheckInfo* pInfo);
L
Liu Jicong 已提交
2840
void    tDeleteSTqCheckInfo(STqCheckInfo* pInfo);
2841 2842 2843 2844

typedef struct {
  char topic[TSDB_TOPIC_FNAME_LEN];
} STqDelCheckInfoReq;
L
Liu Jicong 已提交
2845

L
Liu Jicong 已提交
2846 2847 2848 2849
typedef struct {
  int32_t vgId;
  int64_t offset;
  char    topicName[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2850
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2851 2852 2853
} SMqOffset;

typedef struct {
2854
  int64_t    consumerId;
L
Liu Jicong 已提交
2855 2856
  int32_t    num;
  SMqOffset* offsets;
L
Liu Jicong 已提交
2857
} SMqCMCommitOffsetReq;
L
Liu Jicong 已提交
2858 2859 2860

typedef struct {
  int32_t reserved;
L
Liu Jicong 已提交
2861
} SMqCMCommitOffsetRsp;
L
Liu Jicong 已提交
2862

H
Hongze Cheng 已提交
2863 2864 2865 2866
int32_t tEncodeSMqOffset(SEncoder* encoder, const SMqOffset* pOffset);
int32_t tDecodeSMqOffset(SDecoder* decoder, SMqOffset* pOffset);
int32_t tEncodeSMqCMCommitOffsetReq(SEncoder* encoder, const SMqCMCommitOffsetReq* pReq);
int32_t tDecodeSMqCMCommitOffsetReq(SDecoder* decoder, SMqCMCommitOffsetReq* pReq);
L
Liu Jicong 已提交
2867

2868 2869
// tqOffset
enum {
L
Liu Jicong 已提交
2870 2871 2872 2873 2874 2875
  TMQ_OFFSET__RESET_NONE = -3,
  TMQ_OFFSET__RESET_EARLIEAST = -2,
  TMQ_OFFSET__RESET_LATEST = -1,
  TMQ_OFFSET__LOG = 1,
  TMQ_OFFSET__SNAPSHOT_DATA = 2,
  TMQ_OFFSET__SNAPSHOT_META = 3,
2876 2877 2878 2879 2880
};

typedef struct {
  int8_t type;
  union {
wmmhello's avatar
wmmhello 已提交
2881
    // snapshot
2882 2883 2884 2885
    struct {
      int64_t uid;
      int64_t ts;
    };
L
Liu Jicong 已提交
2886
    // log
2887 2888 2889 2890
    struct {
      int64_t version;
    };
  };
L
Liu Jicong 已提交
2891 2892
} STqOffsetVal;

L
Liu Jicong 已提交
2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908
static FORCE_INLINE void tqOffsetResetToData(STqOffsetVal* pOffsetVal, int64_t uid, int64_t ts) {
  pOffsetVal->type = TMQ_OFFSET__SNAPSHOT_DATA;
  pOffsetVal->uid = uid;
  pOffsetVal->ts = ts;
}

static FORCE_INLINE void tqOffsetResetToMeta(STqOffsetVal* pOffsetVal, int64_t uid) {
  pOffsetVal->type = TMQ_OFFSET__SNAPSHOT_META;
  pOffsetVal->uid = uid;
}

static FORCE_INLINE void tqOffsetResetToLog(STqOffsetVal* pOffsetVal, int64_t ver) {
  pOffsetVal->type = TMQ_OFFSET__LOG;
  pOffsetVal->version = ver;
}

L
Liu Jicong 已提交
2909 2910 2911 2912 2913 2914 2915 2916
int32_t tEncodeSTqOffsetVal(SEncoder* pEncoder, const STqOffsetVal* pOffsetVal);
int32_t tDecodeSTqOffsetVal(SDecoder* pDecoder, STqOffsetVal* pOffsetVal);
int32_t tFormatOffset(char* buf, int32_t maxLen, const STqOffsetVal* pVal);
bool    tOffsetEqual(const STqOffsetVal* pLeft, const STqOffsetVal* pRight);

typedef struct {
  STqOffsetVal val;
  char         subKey[TSDB_SUBSCRIBE_KEY_LEN];
2917 2918 2919 2920 2921
} STqOffset;

int32_t tEncodeSTqOffset(SEncoder* pEncoder, const STqOffset* pOffset);
int32_t tDecodeSTqOffset(SDecoder* pDecoder, STqOffset* pOffset);

2922 2923 2924 2925 2926 2927 2928 2929
typedef struct SMqVgOffset {
  int64_t   consumerId;
  STqOffset offset;
} SMqVgOffset;

int32_t tEncodeMqVgOffset(SEncoder* pEncoder, const SMqVgOffset* pOffset);
int32_t tDecodeMqVgOffset(SDecoder* pDecoder, SMqVgOffset* pOffset);

5
54liuyao 已提交
2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949
typedef struct {
  SMsgHead head;
  int32_t  taskId;
} SVPauseStreamTaskReq;

typedef struct {
  int8_t reserved;
} SVPauseStreamTaskRsp;

typedef struct {
  char   name[TSDB_STREAM_FNAME_LEN];
  int8_t igNotExists;
} SMPauseStreamReq;

int32_t tSerializeSMPauseStreamReq(void* buf, int32_t bufLen, const SMPauseStreamReq* pReq);
int32_t tDeserializeSMPauseStreamReq(void* buf, int32_t bufLen, SMPauseStreamReq* pReq);

typedef struct {
  SMsgHead head;
  int32_t  taskId;
5
54liuyao 已提交
2950
  int8_t   igUntreated;
5
54liuyao 已提交
2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965
} SVResumeStreamTaskReq;

typedef struct {
  int8_t reserved;
} SVResumeStreamTaskRsp;

typedef struct {
  char   name[TSDB_STREAM_FNAME_LEN];
  int8_t igNotExists;
  int8_t igUntreated;
} SMResumeStreamReq;

int32_t tSerializeSMResumeStreamReq(void* buf, int32_t bufLen, const SMResumeStreamReq* pReq);
int32_t tDeserializeSMResumeStreamReq(void* buf, int32_t bufLen, SMResumeStreamReq* pReq);

S
Shengliang Guan 已提交
2966 2967 2968 2969 2970 2971 2972
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  char    stb[TSDB_TABLE_FNAME_LEN];
  int8_t  igExists;
  int8_t  intervalUnit;
  int8_t  slidingUnit;
  int8_t  timezone;
S
sma  
Shengliang Guan 已提交
2973
  int32_t dstVgId;  // for stream
S
Shengliang Guan 已提交
2974 2975 2976
  int64_t interval;
  int64_t offset;
  int64_t sliding;
2977 2978
  int64_t maxDelay;
  int64_t watermark;
S
sma  
Shengliang Guan 已提交
2979 2980 2981 2982
  int32_t exprLen;        // strlen + 1
  int32_t tagsFilterLen;  // strlen + 1
  int32_t sqlLen;         // strlen + 1
  int32_t astLen;         // strlen + 1
L
Liu Jicong 已提交
2983
  char*   expr;
S
Shengliang Guan 已提交
2984
  char*   tagsFilter;
S
sma  
Shengliang Guan 已提交
2985 2986
  char*   sql;
  char*   ast;
2987
  int64_t deleteMark;
S
Shengliang Guan 已提交
2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000 3001
} SMCreateSmaReq;

int32_t tSerializeSMCreateSmaReq(void* buf, int32_t bufLen, SMCreateSmaReq* pReq);
int32_t tDeserializeSMCreateSmaReq(void* buf, int32_t bufLen, SMCreateSmaReq* pReq);
void    tFreeSMCreateSmaReq(SMCreateSmaReq* pReq);

typedef struct {
  char   name[TSDB_TABLE_FNAME_LEN];
  int8_t igNotExists;
} SMDropSmaReq;

int32_t tSerializeSMDropSmaReq(void* buf, int32_t bufLen, SMDropSmaReq* pReq);
int32_t tDeserializeSMDropSmaReq(void* buf, int32_t bufLen, SMDropSmaReq* pReq);

dengyihao's avatar
dengyihao 已提交
3002 3003 3004 3005
typedef struct {
  char   dbFName[TSDB_DB_FNAME_LEN];
  char   stbName[TSDB_TABLE_NAME_LEN];
  char   colName[TSDB_COL_NAME_LEN];
X
Xiaoyu Wang 已提交
3006
  char   idxName[TSDB_INDEX_FNAME_LEN];
dengyihao's avatar
dengyihao 已提交
3007 3008 3009 3010 3011 3012
  int8_t idxType;
} SCreateTagIndexReq;

int32_t tSerializeSCreateTagIdxReq(void* buf, int32_t bufLen, SCreateTagIndexReq* pReq);
int32_t tDeserializeSCreateTagIdxReq(void* buf, int32_t bufLen, SCreateTagIndexReq* pReq);

dengyihao's avatar
dengyihao 已提交
3013
typedef SMDropSmaReq SDropTagIndexReq;
dengyihao's avatar
dengyihao 已提交
3014

dengyihao's avatar
dengyihao 已提交
3015 3016 3017
int32_t tSerializeSDropTagIdxReq(void* buf, int32_t bufLen, SDropTagIndexReq* pReq);
int32_t tDeserializeSDropTagIdxReq(void* buf, int32_t bufLen, SDropTagIndexReq* pReq);

C
Cary Xu 已提交
3018
typedef struct {
C
Cary Xu 已提交
3019 3020 3021 3022 3023 3024 3025 3026 3027 3028 3029 3030 3031 3032 3033 3034 3035 3036 3037 3038
  int8_t         version;       // for compatibility(default 0)
  int8_t         intervalUnit;  // MACRO: TIME_UNIT_XXX
  int8_t         slidingUnit;   // MACRO: TIME_UNIT_XXX
  int8_t         timezoneInt;   // sma data expired if timezone changes.
  int32_t        dstVgId;
  char           indexName[TSDB_INDEX_NAME_LEN];
  int32_t        exprLen;
  int32_t        tagsFilterLen;
  int64_t        indexUid;
  tb_uid_t       tableUid;  // super/child/common table uid
  tb_uid_t       dstTbUid;  // for dstVgroup
  int64_t        interval;
  int64_t        offset;  // use unit by precision of DB
  int64_t        sliding;
  char*          dstTbName;  // for dstVgroup
  char*          expr;       // sma expression
  char*          tagsFilter;
  SSchemaWrapper schemaRow;  // for dstVgroup
  SSchemaWrapper schemaTag;  // for dstVgroup
} STSma;                     // Time-range-wise SMA
C
Cary Xu 已提交
3039

3040
typedef STSma SVCreateTSmaReq;
C
Cary Xu 已提交
3041 3042

typedef struct {
C
Cary Xu 已提交
3043 3044 3045
  int8_t  type;  // 0 status report, 1 update data
  int64_t indexUid;
  int64_t skey;  // start TS key of interval/sliding window
C
Cary Xu 已提交
3046 3047 3048
} STSmaMsg;

typedef struct {
C
Cary Xu 已提交
3049
  int64_t indexUid;
C
Cary Xu 已提交
3050
  char    indexName[TSDB_INDEX_NAME_LEN];
C
Cary Xu 已提交
3051
} SVDropTSmaReq;
3052

C
Cary Xu 已提交
3053
typedef struct {
L
Liu Jicong 已提交
3054
  int tmp;  // TODO: to avoid compile error
C
Cary Xu 已提交
3055 3056
} SVCreateTSmaRsp, SVDropTSmaRsp;

3057
#if 0
C
Cary Xu 已提交
3058 3059 3060 3061
int32_t tSerializeSVCreateTSmaReq(void** buf, SVCreateTSmaReq* pReq);
void*   tDeserializeSVCreateTSmaReq(void* buf, SVCreateTSmaReq* pReq);
int32_t tSerializeSVDropTSmaReq(void** buf, SVDropTSmaReq* pReq);
void*   tDeserializeSVDropTSmaReq(void* buf, SVDropTSmaReq* pReq);
3062
#endif
C
Cary Xu 已提交
3063

3064 3065 3066 3067
int32_t tEncodeSVCreateTSmaReq(SEncoder* pCoder, const SVCreateTSmaReq* pReq);
int32_t tDecodeSVCreateTSmaReq(SDecoder* pCoder, SVCreateTSmaReq* pReq);
int32_t tEncodeSVDropTSmaReq(SEncoder* pCoder, const SVDropTSmaReq* pReq);
int32_t tDecodeSVDropTSmaReq(SDecoder* pCoder, SVDropTSmaReq* pReq);
C
Cary Xu 已提交
3068

C
Cary Xu 已提交
3069
typedef struct {
3070 3071
  int32_t number;
  STSma*  tSma;
C
Cary Xu 已提交
3072 3073
} STSmaWrapper;

C
Cary Xu 已提交
3074
static FORCE_INLINE void tDestroyTSma(STSma* pSma) {
C
Cary Xu 已提交
3075
  if (pSma) {
C
Cary Xu 已提交
3076
    taosMemoryFreeClear(pSma->dstTbName);
wafwerar's avatar
wafwerar 已提交
3077 3078
    taosMemoryFreeClear(pSma->expr);
    taosMemoryFreeClear(pSma->tagsFilter);
C
Cary Xu 已提交
3079 3080 3081
  }
}

C
Cary Xu 已提交
3082
static FORCE_INLINE void tDestroyTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
C
Cary Xu 已提交
3083 3084
  if (pSW) {
    if (pSW->tSma) {
C
Cary Xu 已提交
3085 3086
      if (deepCopy) {
        for (uint32_t i = 0; i < pSW->number; ++i) {
C
Cary Xu 已提交
3087
          tDestroyTSma(pSW->tSma + i);
C
Cary Xu 已提交
3088
        }
C
Cary Xu 已提交
3089
      }
wafwerar's avatar
wafwerar 已提交
3090
      taosMemoryFreeClear(pSW->tSma);
C
Cary Xu 已提交
3091
    }
C
Cary Xu 已提交
3092 3093 3094
  }
}

C
Cary Xu 已提交
3095 3096
static FORCE_INLINE void* tFreeTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
  tDestroyTSmaWrapper(pSW, deepCopy);
C
Cary Xu 已提交
3097
  taosMemoryFreeClear(pSW);
C
Cary Xu 已提交
3098
  return NULL;
C
Cary Xu 已提交
3099 3100
}

3101 3102
int32_t tEncodeSVCreateTSmaReq(SEncoder* pCoder, const SVCreateTSmaReq* pReq);
int32_t tDecodeSVCreateTSmaReq(SDecoder* pCoder, SVCreateTSmaReq* pReq);
C
Cary Xu 已提交
3103

3104
int32_t tEncodeTSma(SEncoder* pCoder, const STSma* pSma);
C
Cary Xu 已提交
3105
int32_t tDecodeTSma(SDecoder* pCoder, STSma* pSma, bool deepCopy);
C
Cary Xu 已提交
3106

3107 3108 3109 3110
static int32_t tEncodeTSmaWrapper(SEncoder* pEncoder, const STSmaWrapper* pReq) {
  if (tEncodeI32(pEncoder, pReq->number) < 0) return -1;
  for (int32_t i = 0; i < pReq->number; ++i) {
    tEncodeTSma(pEncoder, pReq->tSma + i);
C
Cary Xu 已提交
3111
  }
3112
  return 0;
C
Cary Xu 已提交
3113 3114
}

C
Cary Xu 已提交
3115
static int32_t tDecodeTSmaWrapper(SDecoder* pDecoder, STSmaWrapper* pReq, bool deepCopy) {
3116 3117
  if (tDecodeI32(pDecoder, &pReq->number) < 0) return -1;
  for (int32_t i = 0; i < pReq->number; ++i) {
C
Cary Xu 已提交
3118
    tDecodeTSma(pDecoder, pReq->tSma + i, deepCopy);
C
Cary Xu 已提交
3119
  }
3120
  return 0;
C
Cary Xu 已提交
3121
}
L
Liu Jicong 已提交
3122

dengyihao's avatar
dengyihao 已提交
3123
typedef struct {
dengyihao's avatar
dengyihao 已提交
3124
  int idx;
dengyihao's avatar
dengyihao 已提交
3125 3126 3127 3128 3129 3130
} SMCreateFullTextReq;

int32_t tSerializeSMCreateFullTextReq(void* buf, int32_t bufLen, SMCreateFullTextReq* pReq);
int32_t tDeserializeSMCreateFullTextReq(void* buf, int32_t bufLen, SMCreateFullTextReq* pReq);
void    tFreeSMCreateFullTextReq(SMCreateFullTextReq* pReq);

dengyihao's avatar
dengyihao 已提交
3131 3132 3133 3134 3135 3136 3137 3138
typedef struct {
  char   name[TSDB_TABLE_FNAME_LEN];
  int8_t igNotExists;
} SMDropFullTextReq;

int32_t tSerializeSMDropFullTextReq(void* buf, int32_t bufLen, SMDropFullTextReq* pReq);
int32_t tDeserializeSMDropFullTextReq(void* buf, int32_t bufLen, SMDropFullTextReq* pReq);

D
dapan1121 已提交
3139 3140 3141 3142 3143 3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156
typedef struct {
  char indexFName[TSDB_INDEX_FNAME_LEN];
} SUserIndexReq;

int32_t tSerializeSUserIndexReq(void* buf, int32_t bufLen, SUserIndexReq* pReq);
int32_t tDeserializeSUserIndexReq(void* buf, int32_t bufLen, SUserIndexReq* pReq);

typedef struct {
  char dbFName[TSDB_DB_FNAME_LEN];
  char tblFName[TSDB_TABLE_FNAME_LEN];
  char colName[TSDB_COL_NAME_LEN];
  char indexType[TSDB_INDEX_TYPE_LEN];
  char indexExts[TSDB_INDEX_EXTS_LEN];
} SUserIndexRsp;

int32_t tSerializeSUserIndexRsp(void* buf, int32_t bufLen, const SUserIndexRsp* pRsp);
int32_t tDeserializeSUserIndexRsp(void* buf, int32_t bufLen, SUserIndexRsp* pRsp);

D
dapan1121 已提交
3157 3158 3159 3160 3161 3162 3163 3164
typedef struct {
  char tbFName[TSDB_TABLE_FNAME_LEN];
} STableIndexReq;

int32_t tSerializeSTableIndexReq(void* buf, int32_t bufLen, STableIndexReq* pReq);
int32_t tDeserializeSTableIndexReq(void* buf, int32_t bufLen, STableIndexReq* pReq);

typedef struct {
3165 3166 3167 3168 3169 3170
  int8_t  intervalUnit;
  int8_t  slidingUnit;
  int64_t interval;
  int64_t offset;
  int64_t sliding;
  int64_t dstTbUid;
X
Xiaoyu Wang 已提交
3171
  int32_t dstVgId;
3172 3173
  SEpSet  epSet;
  char*   expr;
D
dapan1121 已提交
3174 3175 3176
} STableIndexInfo;

typedef struct {
D
dapan1121 已提交
3177 3178
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
3179 3180 3181
  uint64_t suid;
  int32_t  version;
  SArray*  pIndex;
D
dapan1121 已提交
3182 3183 3184 3185
} STableIndexRsp;

int32_t tSerializeSTableIndexRsp(void* buf, int32_t bufLen, const STableIndexRsp* pRsp);
int32_t tDeserializeSTableIndexRsp(void* buf, int32_t bufLen, STableIndexRsp* pRsp);
3186
void    tFreeSerializeSTableIndexRsp(STableIndexRsp* pRsp);
C
Cary Xu 已提交
3187 3188

void tFreeSTableIndexInfo(void* pInfo);
D
dapan1121 已提交
3189

L
Liu Jicong 已提交
3190 3191 3192 3193
typedef struct {
  int8_t  mqMsgType;
  int32_t code;
  int32_t epoch;
L
Liu Jicong 已提交
3194
  int64_t consumerId;
3195 3196
  int64_t walsver;
  int64_t walever;
L
Liu Jicong 已提交
3197 3198
} SMqRspHead;

L
Liu Jicong 已提交
3199
typedef struct {
3200 3201 3202 3203 3204 3205 3206 3207
  SMsgHead     head;
  char         subKey[TSDB_SUBSCRIBE_KEY_LEN];
  int8_t       withTbName;
  int8_t       useSnapshot;
  int32_t      epoch;
  uint64_t     reqId;
  int64_t      consumerId;
  int64_t      timeout;
L
Liu Jicong 已提交
3208
  STqOffsetVal reqOffset;
L
Liu Jicong 已提交
3209
} SMqPollReq;
L
Liu Jicong 已提交
3210

L
Liu Jicong 已提交
3211 3212
int32_t tSerializeSMqPollReq(void* buf, int32_t bufLen, SMqPollReq* pReq);
int32_t tDeserializeSMqPollReq(void* buf, int32_t bufLen, SMqPollReq* pReq);
D
dapan1121 已提交
3213

L
Liu Jicong 已提交
3214
typedef struct {
L
Liu Jicong 已提交
3215
  int32_t vgId;
L
Liu Jicong 已提交
3216
  int64_t offset;
L
Liu Jicong 已提交
3217 3218 3219
  SEpSet  epSet;
} SMqSubVgEp;

L
Liu Jicong 已提交
3220 3221 3222 3223 3224 3225 3226 3227 3228 3229 3230 3231 3232 3233 3234
static FORCE_INLINE int32_t tEncodeSMqSubVgEp(void** buf, const SMqSubVgEp* pVgEp) {
  int32_t tlen = 0;
  tlen += taosEncodeFixedI32(buf, pVgEp->vgId);
  tlen += taosEncodeFixedI64(buf, pVgEp->offset);
  tlen += taosEncodeSEpSet(buf, &pVgEp->epSet);
  return tlen;
}

static FORCE_INLINE void* tDecodeSMqSubVgEp(void* buf, SMqSubVgEp* pVgEp) {
  buf = taosDecodeFixedI32(buf, &pVgEp->vgId);
  buf = taosDecodeFixedI64(buf, &pVgEp->offset);
  buf = taosDecodeSEpSet(buf, &pVgEp->epSet);
  return buf;
}

L
Liu Jicong 已提交
3235
typedef struct {
L
Liu Jicong 已提交
3236
  char           topic[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
3237
  char           db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
3238 3239
  SArray*        vgs;  // SArray<SMqSubVgEp>
  SSchemaWrapper schema;
L
Liu Jicong 已提交
3240 3241
} SMqSubTopicEp;

3242 3243 3244
int32_t tEncodeMqSubTopicEp(void** buf, const SMqSubTopicEp* pTopicEp);
void*   tDecodeMqSubTopicEp(void* buf, SMqSubTopicEp* pTopicEp);
void    tDeleteMqSubTopicEp(SMqSubTopicEp* pSubTopicEp);
L
Liu Jicong 已提交
3245

L
Liu Jicong 已提交
3246
typedef struct {
L
Liu Jicong 已提交
3247
  SMqRspHead   head;
3248
  STqOffsetVal rspOffset;
L
Liu Jicong 已提交
3249 3250 3251
  int16_t      resMsgType;
  int32_t      metaRspLen;
  void*        metaRsp;
L
Liu Jicong 已提交
3252 3253
} SMqMetaRsp;

3254 3255
int32_t tEncodeMqMetaRsp(SEncoder* pEncoder, const SMqMetaRsp* pRsp);
int32_t tDecodeMqMetaRsp(SDecoder* pDecoder, SMqMetaRsp* pRsp);
L
Liu Jicong 已提交
3256

L
Liu Jicong 已提交
3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269
typedef struct {
  SMqRspHead   head;
  STqOffsetVal reqOffset;
  STqOffsetVal rspOffset;
  int32_t      blockNum;
  int8_t       withTbName;
  int8_t       withSchema;
  SArray*      blockDataLen;
  SArray*      blockData;
  SArray*      blockTbName;
  SArray*      blockSchema;
} SMqDataRsp;

3270 3271 3272
int32_t tEncodeMqDataRsp(SEncoder* pEncoder, const SMqDataRsp* pRsp);
int32_t tDecodeMqDataRsp(SDecoder* pDecoder, SMqDataRsp* pRsp);
void    tDeleteMqDataRsp(SMqDataRsp* pRsp);
L
Liu Jicong 已提交
3273

L
Liu Jicong 已提交
3274 3275 3276 3277 3278 3279 3280 3281 3282 3283 3284
typedef struct {
  SMqRspHead   head;
  STqOffsetVal reqOffset;
  STqOffsetVal rspOffset;
  int32_t      blockNum;
  int8_t       withTbName;
  int8_t       withSchema;
  SArray*      blockDataLen;
  SArray*      blockData;
  SArray*      blockTbName;
  SArray*      blockSchema;
D
dapan1121 已提交
3285
  // the following attributes are extended from SMqDataRsp
3286 3287 3288
  int32_t createTableNum;
  SArray* createTableLen;
  SArray* createTableReq;
L
Liu Jicong 已提交
3289 3290 3291 3292
} STaosxRsp;

int32_t tEncodeSTaosxRsp(SEncoder* pEncoder, const STaosxRsp* pRsp);
int32_t tDecodeSTaosxRsp(SDecoder* pDecoder, STaosxRsp* pRsp);
3293
void    tDeleteSTaosxRsp(STaosxRsp* pRsp);
L
Liu Jicong 已提交
3294

L
Liu Jicong 已提交
3295
typedef struct {
L
Liu Jicong 已提交
3296
  SMqRspHead head;
L
Liu Jicong 已提交
3297 3298
  char       cgroup[TSDB_CGROUP_LEN];
  SArray*    topics;  // SArray<SMqSubTopicEp>
L
Liu Jicong 已提交
3299
} SMqAskEpRsp;
L
Liu Jicong 已提交
3300

L
Liu Jicong 已提交
3301
static FORCE_INLINE int32_t tEncodeSMqAskEpRsp(void** buf, const SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
3302
  int32_t tlen = 0;
L
Liu Jicong 已提交
3303
  // tlen += taosEncodeString(buf, pRsp->cgroup);
L
Liu Jicong 已提交
3304 3305 3306 3307
  int32_t sz = taosArrayGetSize(pRsp->topics);
  tlen += taosEncodeFixedI32(buf, sz);
  for (int32_t i = 0; i < sz; i++) {
    SMqSubTopicEp* pVgEp = (SMqSubTopicEp*)taosArrayGet(pRsp->topics, i);
3308
    tlen += tEncodeMqSubTopicEp(buf, pVgEp);
L
Liu Jicong 已提交
3309 3310 3311 3312
  }
  return tlen;
}

L
Liu Jicong 已提交
3313
static FORCE_INLINE void* tDecodeSMqAskEpRsp(void* buf, SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
3314
  // buf = taosDecodeStringTo(buf, pRsp->cgroup);
L
Liu Jicong 已提交
3315 3316 3317 3318 3319 3320 3321 3322
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
  pRsp->topics = taosArrayInit(sz, sizeof(SMqSubTopicEp));
  if (pRsp->topics == NULL) {
    return NULL;
  }
  for (int32_t i = 0; i < sz; i++) {
    SMqSubTopicEp topicEp;
3323
    buf = tDecodeMqSubTopicEp(buf, &topicEp);
L
Liu Jicong 已提交
3324 3325 3326 3327
    taosArrayPush(pRsp->topics, &topicEp);
  }
  return buf;
}
dengyihao's avatar
dengyihao 已提交
3328

L
Liu Jicong 已提交
3329
static FORCE_INLINE void tDeleteSMqAskEpRsp(SMqAskEpRsp* pRsp) {
3330
  taosArrayDestroyEx(pRsp->topics, (FDelete)tDeleteMqSubTopicEp);
L
Liu Jicong 已提交
3331 3332
}

H
Hongze Cheng 已提交
3333 3334
#define TD_AUTO_CREATE_TABLE 0x1
typedef struct {
H
Hongze Cheng 已提交
3335 3336 3337 3338 3339 3340
  int64_t       suid;
  int64_t       uid;
  int32_t       sver;
  uint32_t      nData;
  uint8_t*      pData;
  SVCreateTbReq cTbReq;
H
Hongze Cheng 已提交
3341 3342 3343 3344 3345 3346 3347 3348 3349 3350 3351
} SVSubmitBlk;

typedef struct {
  int32_t flags;
  int32_t nBlocks;
  union {
    SArray*      pArray;
    SVSubmitBlk* pBlocks;
  };
} SVSubmitReq;

H
Hongze Cheng 已提交
3352 3353
int32_t tEncodeSVSubmitReq(SEncoder* pCoder, const SVSubmitReq* pReq);
int32_t tDecodeSVSubmitReq(SDecoder* pCoder, SVSubmitReq* pReq);
H
Hongze Cheng 已提交
3354

H
more  
Hongze Cheng 已提交
3355
typedef struct {
D
dapan1121 已提交
3356 3357 3358 3359 3360 3361 3362 3363
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
  uint32_t sqlLen;
  uint32_t phyLen;
  char*    sql;
  char*    msg;
H
more  
Hongze Cheng 已提交
3364 3365
} SVDeleteReq;

C
Cary Xu 已提交
3366 3367
int32_t tSerializeSVDeleteReq(void* buf, int32_t bufLen, SVDeleteReq* pReq);
int32_t tDeserializeSVDeleteReq(void* buf, int32_t bufLen, SVDeleteReq* pReq);
C
Cary Xu 已提交
3368

H
more  
Hongze Cheng 已提交
3369
typedef struct {
C
Cary Xu 已提交
3370
  int64_t affectedRows;
H
more  
Hongze Cheng 已提交
3371 3372
} SVDeleteRsp;

C
Cary Xu 已提交
3373 3374 3375
int32_t tEncodeSVDeleteRsp(SEncoder* pCoder, const SVDeleteRsp* pReq);
int32_t tDecodeSVDeleteRsp(SDecoder* pCoder, SVDeleteRsp* pReq);

H
Hongze Cheng 已提交
3376 3377 3378 3379 3380 3381
typedef struct SDeleteRes {
  uint64_t suid;
  SArray*  uidList;
  int64_t  skey;
  int64_t  ekey;
  int64_t  affectedRows;
3382 3383
  char     tableFName[TSDB_TABLE_NAME_LEN];
  char     tsColName[TSDB_COL_NAME_LEN];
H
Hongze Cheng 已提交
3384 3385 3386 3387 3388
} SDeleteRes;

int32_t tEncodeDeleteRes(SEncoder* pCoder, const SDeleteRes* pRes);
int32_t tDecodeDeleteRes(SDecoder* pCoder, SDeleteRes* pRes);

3389
typedef struct {
3390 3391
  // int64_t uid;
  char    tbname[TSDB_TABLE_NAME_LEN];
L
Liu Jicong 已提交
3392 3393
  int64_t startTs;
  int64_t endTs;
3394 3395 3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406
} SSingleDeleteReq;

int32_t tEncodeSSingleDeleteReq(SEncoder* pCoder, const SSingleDeleteReq* pReq);
int32_t tDecodeSSingleDeleteReq(SDecoder* pCoder, SSingleDeleteReq* pReq);

typedef struct {
  int64_t suid;
  SArray* deleteReqs;  // SArray<SSingleDeleteReq>
} SBatchDeleteReq;

int32_t tEncodeSBatchDeleteReq(SEncoder* pCoder, const SBatchDeleteReq* pReq);
int32_t tDecodeSBatchDeleteReq(SDecoder* pCoder, SBatchDeleteReq* pReq);

D
dapan1121 已提交
3407
typedef struct {
D
dapan1121 已提交
3408
  int32_t msgIdx;
D
dapan1121 已提交
3409 3410 3411 3412 3413
  int32_t msgType;
  int32_t msgLen;
  void*   msg;
} SBatchMsg;

3414
typedef struct {
L
Liu Jicong 已提交
3415 3416
  SMsgHead header;
  SArray*  pMsgs;  // SArray<SBatchMsg>
3417 3418
} SBatchReq;

D
dapan1121 已提交
3419 3420
typedef struct {
  int32_t reqType;
D
dapan1121 已提交
3421
  int32_t msgIdx;
D
dapan1121 已提交
3422 3423 3424
  int32_t msgLen;
  int32_t rspCode;
  void*   msg;
D
dapan1121 已提交
3425 3426 3427
} SBatchRspMsg;

typedef struct {
L
Liu Jicong 已提交
3428
  SArray* pRsps;  // SArray<SBatchRspMsg>
D
dapan1121 已提交
3429 3430
} SBatchRsp;

L
Liu Jicong 已提交
3431 3432
int32_t                  tSerializeSBatchReq(void* buf, int32_t bufLen, SBatchReq* pReq);
int32_t                  tDeserializeSBatchReq(void* buf, int32_t bufLen, SBatchReq* pReq);
D
dapan1121 已提交
3433 3434 3435 3436 3437 3438 3439 3440
static FORCE_INLINE void tFreeSBatchReqMsg(void* msg) {
  if (NULL == msg) {
    return;
  }
  SBatchMsg* pMsg = (SBatchMsg*)msg;
  taosMemoryFree(pMsg->msg);
}

L
Liu Jicong 已提交
3441 3442
int32_t tSerializeSBatchRsp(void* buf, int32_t bufLen, SBatchRsp* pRsp);
int32_t tDeserializeSBatchRsp(void* buf, int32_t bufLen, SBatchRsp* pRsp);
D
dapan1121 已提交
3443 3444

static FORCE_INLINE void tFreeSBatchRspMsg(void* p) {
D
dapan1121 已提交
3445 3446 3447 3448
  if (NULL == p) {
    return;
  }

D
dapan1121 已提交
3449
  SBatchRspMsg* pRsp = (SBatchRspMsg*)p;
D
dapan1121 已提交
3450 3451 3452
  taosMemoryFree(pRsp->msg);
}

L
Liu Jicong 已提交
3453 3454 3455 3456
int32_t tSerializeSMqAskEpReq(void* buf, int32_t bufLen, SMqAskEpReq* pReq);
int32_t tDeserializeSMqAskEpReq(void* buf, int32_t bufLen, SMqAskEpReq* pReq);
int32_t tSerializeSMqHbReq(void* buf, int32_t bufLen, SMqHbReq* pReq);
int32_t tDeserializeSMqHbReq(void* buf, int32_t bufLen, SMqHbReq* pReq);
H
Hongze Cheng 已提交
3457 3458 3459 3460
int32_t tSerializeSMqAskEpReq(void* buf, int32_t bufLen, SMqAskEpReq* pReq);
int32_t tDeserializeSMqAskEpReq(void* buf, int32_t bufLen, SMqAskEpReq* pReq);
int32_t tSerializeSMqHbReq(void* buf, int32_t bufLen, SMqHbReq* pReq);
int32_t tDeserializeSMqHbReq(void* buf, int32_t bufLen, SMqHbReq* pReq);
D
dapan1121 已提交
3461

H
Hongze Cheng 已提交
3462 3463 3464
#define SUBMIT_REQ_AUTO_CREATE_TABLE  0x1
#define SUBMIT_REQ_COLUMN_DATA_FORMAT 0x2

H
Hongze Cheng 已提交
3465
typedef struct {
H
Hongze Cheng 已提交
3466 3467 3468 3469 3470
  int32_t        flags;
  SVCreateTbReq* pCreateTbReq;
  int64_t        suid;
  int64_t        uid;
  int32_t        sver;
H
Hongze Cheng 已提交
3471 3472 3473 3474 3475 3476 3477
  union {
    SArray* aRowP;
    SArray* aCol;
  };
} SSubmitTbData;

typedef struct {
H
Hongze Cheng 已提交
3478
  SArray* aSubmitTbData;  // SArray<SSubmitTbData>
H
Hongze Cheng 已提交
3479 3480
} SSubmitReq2;

3481 3482 3483 3484 3485 3486
typedef struct {
  SMsgHead header;
  int64_t  version;
  char     data[];  // SSubmitReq2
} SSubmitReq2Msg;

3487 3488 3489 3490
int32_t tEncodeSubmitReq(SEncoder* pCoder, const SSubmitReq2* pReq);
int32_t tDecodeSubmitReq(SDecoder* pCoder, SSubmitReq2* pReq);
void    tDestroySubmitTbData(SSubmitTbData* pTbData, int32_t flag);
void    tDestroySubmitReq(SSubmitReq2* pReq, int32_t flag);
H
Hongze Cheng 已提交
3491

H
Hongze Cheng 已提交
3492 3493 3494 3495 3496 3497 3498
typedef struct {
  int32_t affectedRows;
  SArray* aCreateTbRsp;  // SArray<SVCreateTbRsp>
} SSubmitRsp2;

int32_t tEncodeSSubmitRsp2(SEncoder* pCoder, const SSubmitRsp2* pRsp);
int32_t tDecodeSSubmitRsp2(SDecoder* pCoder, SSubmitRsp2* pRsp);
H
Hongze Cheng 已提交
3499
void    tDestroySSubmitRsp2(SSubmitRsp2* pRsp, int32_t flag);
H
Hongze Cheng 已提交
3500 3501 3502

#define TSDB_MSG_FLG_ENCODE 0x1
#define TSDB_MSG_FLG_DECODE 0x2
3503
#define TSDB_MSG_FLG_CMPT   0x3
H
Hongze Cheng 已提交
3504

L
Liu Jicong 已提交
3505
typedef struct {
L
Liu Jicong 已提交
3506 3507 3508 3509 3510 3511 3512 3513 3514
  union {
    struct {
      void*   msgStr;
      int32_t msgLen;
      int64_t ver;
    };
    void* pDataBlock;
  };
} SPackedData;
D
dapan1121 已提交
3515

L
Liu Jicong 已提交
3516 3517
#pragma pack(pop)

D
dapan1121 已提交
3518 3519 3520 3521 3522
#ifdef __cplusplus
}
#endif

#endif /*_TD_COMMON_TAOS_MSG_H_*/