tmsg.h 73.9 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 58 59
#define TMSG_SEG_SEQ(TYPE)  ((TYPE)&0xff)
#define TMSG_INFO(TYPE)     tMsgInfo[tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE)]
#define TMSG_INDEX(TYPE)    (tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE))
D
dapan1121 已提交
60

H
Hongze Cheng 已提交
61 62
typedef uint16_t tmsg_t;

H
Hongze Cheng 已提交
63
/* ------------------------ OTHER DEFINITIONS ------------------------ */
D
dapan1121 已提交
64
// IE type
L
Liu Jicong 已提交
65 66 67 68
#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 已提交
69
#define TSDB_IE_TYPE_NEW_VERSION 5
L
Liu Jicong 已提交
70
#define TSDB_IE_TYPE_DNODE_EXT   6
D
dapan1121 已提交
71 72
#define TSDB_IE_TYPE_DNODE_STATE 7

73
enum { CONN_TYPE__QUERY = 1, CONN_TYPE__TMQ, CONN_TYPE__UDFD, CONN_TYPE__MAX };
L
Liu Jicong 已提交
74

D
dapan1121 已提交
75
enum {
D
dapan 已提交
76 77
  HEARTBEAT_KEY_USER_AUTHINFO = 1,
  HEARTBEAT_KEY_DBINFO,
D
dapan1121 已提交
78
  HEARTBEAT_KEY_STBINFO,
D
dapan1121 已提交
79
  HEARTBEAT_KEY_MQ_TMP,
D
dapan1121 已提交
80 81
};

S
Shengliang Guan 已提交
82 83
typedef enum _mgmt_table {
  TSDB_MGMT_TABLE_START,
D
dapan1121 已提交
84 85
  TSDB_MGMT_TABLE_DNODE,
  TSDB_MGMT_TABLE_MNODE,
86
  TSDB_MGMT_TABLE_MODULE,
S
Shengliang Guan 已提交
87 88 89
  TSDB_MGMT_TABLE_QNODE,
  TSDB_MGMT_TABLE_SNODE,
  TSDB_MGMT_TABLE_BNODE,
90 91 92 93
  TSDB_MGMT_TABLE_CLUSTER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_FUNC,
  TSDB_MGMT_TABLE_INDEX,
S
Shengliang Guan 已提交
94
  TSDB_MGMT_TABLE_STB,
D
dapan1121 已提交
95
  TSDB_MGMT_TABLE_STREAMS,
96 97
  TSDB_MGMT_TABLE_TABLE,
  TSDB_MGMT_TABLE_USER,
D
dapan1121 已提交
98
  TSDB_MGMT_TABLE_GRANTS,
99 100 101
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_TOPICS,
  TSDB_MGMT_TABLE_CONSUMERS,
L
Liu Jicong 已提交
102
  TSDB_MGMT_TABLE_SUBSCRIPTIONS,
103 104 105 106 107
  TSDB_MGMT_TABLE_TRANS,
  TSDB_MGMT_TABLE_SMAS,
  TSDB_MGMT_TABLE_CONFIGS,
  TSDB_MGMT_TABLE_CONNS,
  TSDB_MGMT_TABLE_QUERIES,
D
dapan1121 已提交
108 109
  TSDB_MGMT_TABLE_VNODES,
  TSDB_MGMT_TABLE_MAX,
S
Shengliang Guan 已提交
110
} EShowType;
D
dapan1121 已提交
111

112 113 114 115
#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 已提交
116 117
#define TSDB_ALTER_TABLE_ADD_COLUMN          5
#define TSDB_ALTER_TABLE_DROP_COLUMN         6
S
Shengliang Guan 已提交
118
#define TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES 7
L
Liu Jicong 已提交
119
#define TSDB_ALTER_TABLE_UPDATE_TAG_BYTES    8
120 121
#define TSDB_ALTER_TABLE_UPDATE_OPTIONS      9
#define TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME  10
D
dapan1121 已提交
122

L
Liu Jicong 已提交
123 124
#define TSDB_FILL_NONE      0
#define TSDB_FILL_NULL      1
H
Hongze Cheng 已提交
125
#define TSDB_FILL_SET_VALUE 2
L
Liu Jicong 已提交
126 127 128 129 130 131 132 133
#define TSDB_FILL_LINEAR    3
#define TSDB_FILL_PREV      4
#define TSDB_FILL_NEXT      5

#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
S
Shengliang Guan 已提交
134 135 136 137
#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
S
Shengliang Guan 已提交
138

D
dapan1121 已提交
139 140
#define TSDB_ALTER_USER_PRIVILEGES 0x2

H
Hongze Cheng 已提交
141
#define TSDB_KILL_MSG_LEN 30
D
dapan1121 已提交
142

D
dapan1121 已提交
143 144
#define TSDB_TABLE_NUM_UNIT 100000

L
Liu Jicong 已提交
145
#define TSDB_VN_READ_ACCCESS  ((char)0x1)
H
Hongze Cheng 已提交
146
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
L
Liu Jicong 已提交
147
#define TSDB_VN_ALL_ACCCESS   (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
D
dapan1121 已提交
148

H
Hongze Cheng 已提交
149
#define TSDB_COL_NORMAL 0x0u  // the normal column of the table
L
Liu Jicong 已提交
150 151 152 153
#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 已提交
154

L
Liu Jicong 已提交
155
#define TSDB_COL_IS_TAG(f)        (((f & (~(TSDB_COL_NULL))) & TSDB_COL_TAG) != 0)
H
Hongze Cheng 已提交
156
#define TSDB_COL_IS_NORMAL_COL(f) ((f & (~(TSDB_COL_NULL))) == TSDB_COL_NORMAL)
L
Liu Jicong 已提交
157 158
#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 已提交
159

L
Liu Jicong 已提交
160 161
#define TD_SUPER_TABLE  TSDB_SUPER_TABLE
#define TD_CHILD_TABLE  TSDB_CHILD_TABLE
S
Shengliang Guan 已提交
162 163
#define TD_NORMAL_TABLE TSDB_NORMAL_TABLE

S
Shengliang Guan 已提交
164
typedef struct {
S
Shengliang Guan 已提交
165
  int32_t vgId;
D
dapan1121 已提交
166 167
  char*   dbFName;
  char*   tbName;
D
dapan1121 已提交
168 169
} SBuildTableMetaInput;

S
Shengliang Guan 已提交
170
typedef struct {
D
dapan1121 已提交
171
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
172
  int64_t dbId;
173
  int32_t vgVersion;
L
Liu Jicong 已提交
174
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
D
dapan1121 已提交
175 176
} SBuildUseDBInput;

S
Shengliang Guan 已提交
177 178 179 180
typedef struct SField {
  char    name[TSDB_COL_NAME_LEN];
  uint8_t type;
  int32_t bytes;
181
  int8_t  flags;
S
Shengliang Guan 已提交
182 183
} SField;

S
Shengliang Guan 已提交
184
typedef struct SRetention {
C
Cary Xu 已提交
185 186
  int64_t freq;
  int64_t keep;
S
sma  
Shengliang Guan 已提交
187 188
  int8_t  freqUnit;
  int8_t  keepUnit;
S
Shengliang Guan 已提交
189 190
} SRetention;

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

D
dapan1121 已提交
193 194 195
#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 已提交
196
typedef struct SEp {
D
dapan1121 已提交
197
  char     fqdn[TSDB_FQDN_LEN];
D
dapan1121 已提交
198
  uint16_t port;
H
Haojun Liao 已提交
199
} SEp;
D
dapan1121 已提交
200

S
Shengliang Guan 已提交
201
typedef struct {
D
dapan1121 已提交
202
  int32_t contLen;
L
Liu Jicong 已提交
203
  int32_t vgId;
D
dapan1121 已提交
204 205 206 207
} SMsgHead;

// Submit message for one table
typedef struct SSubmitBlk {
208
  int64_t uid;        // table unique id
L
Liu Jicong 已提交
209
  int64_t suid;       // stable id
210 211 212 213
  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
  int16_t numOfRows;  // total number of rows in current submit block
C
Cary Xu 已提交
214
  int16_t padding;    // TODO just for padding here
215
  char    data[];
D
dapan1121 已提交
216 217 218
} SSubmitBlk;

// Submit message for this TSDB
S
Shengliang Guan 已提交
219
typedef struct {
S
Shengliang Guan 已提交
220
  SMsgHead header;
H
Hongze Cheng 已提交
221
  int64_t  version;
S
Shengliang Guan 已提交
222 223 224
  int32_t  length;
  int32_t  numOfBlocks;
  char     blocks[];
S
Shengliang Guan 已提交
225
} SSubmitReq;
D
dapan1121 已提交
226

H
Hongze Cheng 已提交
227 228 229
typedef struct {
  int32_t totalLen;
  int32_t len;
230
  STSRow* row;
H
Hongze Cheng 已提交
231 232 233
} SSubmitBlkIter;

typedef struct {
C
Cary Xu 已提交
234 235 236
  int32_t totalLen;
  int32_t len;
  // head of SSubmitBlk
C
Cary Xu 已提交
237 238 239 240 241 242
  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
  int16_t numOfRows;  // total number of rows in current submit block
C
Cary Xu 已提交
243
  // head of SSubmitBlk
C
Cary Xu 已提交
244
  const void* pMsg;
H
Hongze Cheng 已提交
245
} SSubmitMsgIter;
C
Cary Xu 已提交
246

H
Hongze Cheng 已提交
247
int32_t tInitSubmitMsgIter(SSubmitReq* pMsg, SSubmitMsgIter* pIter);
S
Shengliang Guan 已提交
248
int32_t tGetSubmitMsgNext(SSubmitMsgIter* pIter, SSubmitBlk** pPBlock);
C
Cary Xu 已提交
249
int32_t tInitSubmitBlkIter(SSubmitMsgIter* pMsgIter, SSubmitBlk* pBlock, SSubmitBlkIter* pIter);
C
Cary Xu 已提交
250
STSRow* tGetSubmitBlkNext(SSubmitBlkIter* pIter);
L
Liu Jicong 已提交
251
// for debug
H
Hongze Cheng 已提交
252
int32_t tPrintFixedSchemaSubmitReq(SSubmitReq* pReq, STSchema* pSchema);
H
Hongze Cheng 已提交
253

D
dapan1121 已提交
254
typedef struct {
H
Hongze Cheng 已提交
255
  int32_t code;
H
Hongze Cheng 已提交
256 257
  int8_t  hashMeta;
  int64_t uid;
D
dapan 已提交
258
  char*   tblFName;
H
Hongze Cheng 已提交
259 260
  int32_t numOfRows;
  int32_t affectedRows;
H
Hongze Cheng 已提交
261
  int64_t sver;
H
Hongze Cheng 已提交
262
} SSubmitBlkRsp;
D
dapan1121 已提交
263 264

typedef struct {
H
Hongze Cheng 已提交
265 266 267 268 269 270 271
  int32_t numOfRows;
  int32_t affectedRows;
  int32_t nBlocks;
  union {
    SArray*        pArray;
    SSubmitBlkRsp* pBlocks;
  };
S
Shengliang Guan 已提交
272
} SSubmitRsp;
D
dapan1121 已提交
273

H
Hongze Cheng 已提交
274 275
int32_t tEncodeSSubmitRsp(SEncoder* pEncoder, const SSubmitRsp* pRsp);
int32_t tDecodeSSubmitRsp(SDecoder* pDecoder, SSubmitRsp* pRsp);
H
Hongze Cheng 已提交
276
void    tFreeSSubmitRsp(SSubmitRsp* pRsp);
277

H
Hongze Cheng 已提交
278 279
#define COL_SMA_ON   ((int8_t)0x1)
#define COL_IDX_ON   ((int8_t)0x2)
H
Hongze Cheng 已提交
280 281
#define COL_SET_NULL ((int8_t)0x10)
#define COL_SET_VAL  ((int8_t)0x20)
D
dapan1121 已提交
282
typedef struct SSchema {
283
  int8_t   type;
H
Hongze Cheng 已提交
284
  int8_t   flags;
285 286 287
  col_id_t colId;
  int32_t  bytes;
  char     name[TSDB_COL_NAME_LEN];
D
dapan1121 已提交
288 289
} SSchema;

H
Hongze Cheng 已提交
290 291
#define COL_IS_SET(FLG)  ((FLG) & (COL_SET_VAL | COL_SET_NULL) != 0)
#define COL_CLR_SET(FLG) ((FLG) &= (~(COL_SET_VAL | COL_SET_NULL)))
H
Hongze Cheng 已提交
292

H
Hongze Cheng 已提交
293
#define IS_BSMA_ON(s) (((s)->flags & 0x01) == COL_SMA_ON)
C
Cary Xu 已提交
294

dengyihao's avatar
dengyihao 已提交
295
#define SSCHMEA_TYPE(s)  ((s)->type)
C
Cary Xu 已提交
296
#define SSCHMEA_FLAGS(s) ((s)->flags)
C
Cary Xu 已提交
297 298
#define SSCHMEA_COLID(s) ((s)->colId)
#define SSCHMEA_BYTES(s) ((s)->bytes)
dengyihao's avatar
dengyihao 已提交
299
#define SSCHMEA_NAME(s)  ((s)->name)
C
Cary Xu 已提交
300

H
Hongze Cheng 已提交
301 302
typedef struct {
  int32_t  nCols;
303
  int32_t  version;
H
Hongze Cheng 已提交
304 305 306
  SSchema* pSchema;
} SSchemaWrapper;

L
Liu Jicong 已提交
307 308 309 310
static FORCE_INLINE SSchemaWrapper* tCloneSSchemaWrapper(const SSchemaWrapper* pSchemaWrapper) {
  SSchemaWrapper* pSW = (SSchemaWrapper*)taosMemoryMalloc(sizeof(SSchemaWrapper));
  if (pSW == NULL) return pSW;
  pSW->nCols = pSchemaWrapper->nCols;
311
  pSW->version = pSchemaWrapper->version;
L
Liu Jicong 已提交
312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365
  pSW->pSchema = (SSchema*)taosMemoryCalloc(pSW->nCols, sizeof(SSchema));
  if (pSW->pSchema == NULL) {
    taosMemoryFree(pSW);
    return NULL;
  }
  memcpy(pSW->pSchema, pSchemaWrapper->pSchema, pSW->nCols * sizeof(SSchema));
  return pSW;
}

static FORCE_INLINE void tDeleteSSchemaWrapper(SSchemaWrapper* pSchemaWrapper) {
  taosMemoryFree(pSchemaWrapper->pSchema);
  taosMemoryFree(pSchemaWrapper);
}

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);
366
  tlen += taosEncodeVariantI32(buf, pSW->version);
L
Liu Jicong 已提交
367 368 369 370 371 372 373 374
  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);
375
  buf = taosDecodeVariantI32(buf, &pSW->version);
L
Liu Jicong 已提交
376 377 378 379 380 381 382 383 384 385 386 387 388
  pSW->pSchema = (SSchema*)taosMemoryCalloc(pSW->nCols, sizeof(SSchema));
  if (pSW->pSchema == NULL) {
    return NULL;
  }

  for (int32_t i = 0; i < pSW->nCols; i++) {
    buf = taosDecodeSSchema(buf, &pSW->pSchema[i]);
  }
  return (void*)buf;
}

static FORCE_INLINE int32_t tEncodeSSchemaWrapper(SEncoder* pEncoder, const SSchemaWrapper* pSW) {
  if (tEncodeI32v(pEncoder, pSW->nCols) < 0) return -1;
389
  if (tEncodeI32v(pEncoder, pSW->version) < 0) return -1;
L
Liu Jicong 已提交
390 391 392 393 394 395 396 397 398
  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;
399
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
L
Liu Jicong 已提交
400 401 402 403 404 405 406 407 408 409

  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 已提交
410 411
static FORCE_INLINE int32_t tDecodeSSchemaWrapperEx(SDecoder* pDecoder, SSchemaWrapper* pSW) {
  if (tDecodeI32v(pDecoder, &pSW->nCols) < 0) return -1;
412
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
C
Cary Xu 已提交
413 414 415 416 417 418 419 420 421 422

  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;
}

C
Cary Xu 已提交
423 424
STSchema* tdGetSTSChemaFromSSChema(SSchema** pSchema, int32_t nCols);

D
dapan1121 已提交
425
typedef struct {
S
Shengliang Guan 已提交
426 427
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  igExists;
S
sma  
Shengliang Guan 已提交
428 429
  float   xFilesFactor;
  int32_t delay;
S
sma  
Shengliang Guan 已提交
430
  int32_t ttl;
S
Shengliang Guan 已提交
431
  int32_t numOfColumns;
S
Shengliang Guan 已提交
432
  int32_t numOfTags;
S
sma  
Shengliang Guan 已提交
433
  int32_t commentLen;
434 435
  int32_t ast1Len;
  int32_t ast2Len;
S
sma  
Shengliang Guan 已提交
436 437
  SArray* pColumns;  // array of SField
  SArray* pTags;     // array of SField
S
sma  
Shengliang Guan 已提交
438
  char*   comment;
439 440
  char*   pAst1;
  char*   pAst2;
S
Shengliang Guan 已提交
441
} SMCreateStbReq;
D
dapan1121 已提交
442

S
Shengliang Guan 已提交
443 444
int32_t tSerializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
int32_t tDeserializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
445
void    tFreeSMCreateStbReq(SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
446

D
dapan1121 已提交
447 448 449
typedef struct {
  char   name[TSDB_TABLE_FNAME_LEN];
  int8_t igNotExists;
S
Shengliang Guan 已提交
450
} SMDropStbReq;
S
Shengliang Guan 已提交
451

S
Shengliang Guan 已提交
452 453
int32_t tSerializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
int32_t tDeserializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
S
Shengliang Guan 已提交
454

S
Shengliang Guan 已提交
455 456 457
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
458 459
  int32_t tagVer;
  int32_t colVer;
S
Shengliang Guan 已提交
460 461
  int32_t numOfFields;
  SArray* pFields;
X
Xiaoyu Wang 已提交
462 463 464
  int32_t ttl;
  int32_t commentLen;
  char*   comment;
S
Shengliang Guan 已提交
465
} SMAlterStbReq;
D
dapan1121 已提交
466

S
Shengliang Guan 已提交
467 468 469
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 已提交
470 471

typedef struct SEpSet {
472 473 474
  int8_t inUse;
  int8_t numOfEps;
  SEp    eps[TSDB_MAX_REPLICA];
D
dapan1121 已提交
475 476
} SEpSet;

H
Hongze Cheng 已提交
477 478
int32_t tEncodeSEpSet(SEncoder* pEncoder, const SEpSet* pEp);
int32_t tDecodeSEpSet(SDecoder* pDecoder, SEpSet* pEp);
S
Shengliang Guan 已提交
479
int32_t taosEncodeSEpSet(void** buf, const SEpSet* pEp);
480
void*   taosDecodeSEpSet(const void* buf, SEpSet* pEp);
L
Liu Jicong 已提交
481

482 483
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 已提交
484

D
dapan1121 已提交
485
typedef struct {
L
Liu Jicong 已提交
486
  int8_t  connType;
D
dapan1121 已提交
487
  int32_t pid;
S
Shengliang Guan 已提交
488 489
  char    app[TSDB_APP_NAME_LEN];
  char    db[TSDB_DB_NAME_LEN];
dengyihao's avatar
dengyihao 已提交
490 491
  char    user[TSDB_USER_LEN];
  char    passwd[TSDB_PASSWORD_LEN];
492
  int64_t startTime;
S
Shengliang Guan 已提交
493
} SConnectReq;
L
Liu Jicong 已提交
494

S
Shengliang Guan 已提交
495 496
int32_t tSerializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
int32_t tDeserializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
497

L
Liu Jicong 已提交
498
typedef struct {
499 500
  int32_t  acctId;
  int64_t  clusterId;
D
dapan1121 已提交
501
  uint32_t connId;
D
dapan 已提交
502
  int32_t  dnodeNum;
503 504 505 506
  int8_t   superUser;
  int8_t   connType;
  SEpSet   epSet;
  char     sVersion[128];
L
Liu Jicong 已提交
507
} SConnectRsp;
L
Liu Jicong 已提交
508

S
Shengliang Guan 已提交
509 510 511
int32_t tSerializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);
int32_t tDeserializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);

L
Liu Jicong 已提交
512 513 514 515 516 517 518 519
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
520
  int64_t maxStorage;
L
Liu Jicong 已提交
521
} SCreateAcctReq, SAlterAcctReq;
L
Liu Jicong 已提交
522

S
Shengliang Guan 已提交
523 524
int32_t tSerializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
int32_t tDeserializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
S
Shengliang Guan 已提交
525

L
Liu Jicong 已提交
526 527 528
typedef struct {
  char user[TSDB_USER_LEN];
} SDropUserReq, SDropAcctReq;
D
dapan1121 已提交
529

S
Shengliang Guan 已提交
530 531
int32_t tSerializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
int32_t tDeserializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
S
Shengliang Guan 已提交
532

D
dapan1121 已提交
533
typedef struct {
S
Shengliang Guan 已提交
534 535
  int8_t createType;
  int8_t superUser;  // denote if it is a super user or not
S
Shengliang Guan 已提交
536
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
537
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
538 539
} SCreateUserReq;

S
Shengliang Guan 已提交
540 541
int32_t tSerializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
int32_t tDeserializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
S
Shengliang Guan 已提交
542 543 544

typedef struct {
  int8_t alterType;
S
Shengliang Guan 已提交
545
  int8_t superUser;
S
Shengliang Guan 已提交
546
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
547
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
548 549 550
  char   dbname[TSDB_DB_FNAME_LEN];
} SAlterUserReq;

S
Shengliang Guan 已提交
551 552
int32_t tSerializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
int32_t tDeserializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
D
dapan1121 已提交
553

S
Shengliang Guan 已提交
554 555 556 557
typedef struct {
  char user[TSDB_USER_LEN];
} SGetUserAuthReq;

S
Shengliang Guan 已提交
558 559
int32_t tSerializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
int32_t tDeserializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
S
Shengliang Guan 已提交
560 561 562

typedef struct {
  char      user[TSDB_USER_LEN];
D
dapan 已提交
563
  int32_t   version;
S
Shengliang Guan 已提交
564
  int8_t    superAuth;
D
dapan 已提交
565
  SHashObj* createdDbs;
S
Shengliang Guan 已提交
566 567 568 569
  SHashObj* readDbs;
  SHashObj* writeDbs;
} SGetUserAuthRsp;

S
Shengliang Guan 已提交
570 571
int32_t tSerializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
int32_t tDeserializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
572
void    tFreeSGetUserAuthRsp(SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
573

D
dapan1121 已提交
574
typedef struct {
S
Shengliang Guan 已提交
575 576 577
  int16_t colId;     // column id
  int16_t colIndex;  // column index in colList if it is a normal column or index in tagColList if a tag
  int16_t flag;      // denote if it is a tag or a normal column
578
  char    name[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
579 580
} SColIndex;

S
Shengliang Guan 已提交
581
typedef struct {
D
dapan1121 已提交
582 583
  int16_t lowerRelOptr;
  int16_t upperRelOptr;
S
Shengliang Guan 已提交
584
  int16_t filterstr;  // denote if current column is char(binary/nchar)
D
dapan1121 已提交
585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601

  union {
    struct {
      int64_t lowerBndi;
      int64_t upperBndi;
    };
    struct {
      double lowerBndd;
      double upperBndd;
    };
    struct {
      int64_t pz;
      int64_t len;
    };
  };
} SColumnFilterInfo;

S
Shengliang Guan 已提交
602
typedef struct {
S
Shengliang Guan 已提交
603 604 605
  int16_t numOfFilters;
  union {
    int64_t            placeholder;
H
Hongze Cheng 已提交
606
    SColumnFilterInfo* filterInfo;
D
dapan1121 已提交
607 608 609
  };
} SColumnFilterList;
/*
L
Liu Jicong 已提交
610
 * for client side struct, only column id, type, bytes are necessary
D
dapan1121 已提交
611 612
 * But for data in vnode side, we need all the following information.
 */
S
Shengliang Guan 已提交
613
typedef struct {
H
Haojun Liao 已提交
614
  union {
615 616
    col_id_t colId;
    int16_t  slotId;
H
Haojun Liao 已提交
617 618
  };

L
Liu Jicong 已提交
619 620 621 622
  int16_t type;
  int32_t bytes;
  uint8_t precision;
  uint8_t scale;
D
dapan1121 已提交
623 624
} SColumnInfo;

S
Shengliang Guan 已提交
625
typedef struct {
L
Liu Jicong 已提交
626 627
  int64_t uid;
  TSKEY   key;  // last accessed ts, for subscription
D
dapan1121 已提交
628 629 630 631 632 633 634 635
} STableIdInfo;

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

typedef struct {
S
Shengliang Guan 已提交
636 637 638 639
  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 已提交
640 641
} STsBufInfo;

S
Shengliang Guan 已提交
642
typedef struct {
S
Shengliang Guan 已提交
643
  int32_t tz;  // query client timezone
D
dapan1121 已提交
644 645
  char    intervalUnit;
  char    slidingUnit;
646
  char    offsetUnit;
H
Haojun Liao 已提交
647
  int8_t  precision;
D
dapan1121 已提交
648 649 650 651 652 653
  int64_t interval;
  int64_t sliding;
  int64_t offset;
} SInterval;

typedef struct {
S
Shengliang Guan 已提交
654
  int32_t code;
D
dapan1121 已提交
655 656 657
  char    tbFName[TSDB_TABLE_FNAME_LEN];
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
658 659
} SQueryTableRsp;

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

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

D
dapan1121 已提交
664
typedef struct {
665
  char    db[TSDB_DB_FNAME_LEN];
666
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
667 668 669 670
  int32_t numOfStables;  // single_stable
  int32_t buffer;        // MB
  int32_t pageSize;
  int32_t pages;
S
Shengliang Guan 已提交
671 672 673 674
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
S
Shengliang Guan 已提交
675 676
  int32_t minRows;
  int32_t maxRows;
S
Shengliang Guan 已提交
677
  int32_t fsyncPeriod;
S
Shengliang Guan 已提交
678
  int8_t  walLevel;
S
Shengliang Guan 已提交
679 680 681
  int8_t  precision;  // time resolution
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
682
  int8_t  strict;
S
Shengliang Guan 已提交
683
  int8_t  cacheLastRow;
X
Xiaoyu Wang 已提交
684
  int8_t  schemaless;
S
Shengliang Guan 已提交
685
  int8_t  ignoreExist;
S
Shengliang Guan 已提交
686 687
  int32_t numOfRetensions;
  SArray* pRetensions;  // SRetention
S
Shengliang Guan 已提交
688
} SCreateDbReq;
S
Shengliang Guan 已提交
689

S
Shengliang Guan 已提交
690 691
int32_t tSerializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
int32_t tDeserializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
S
Shengliang Guan 已提交
692
void    tFreeSCreateDbReq(SCreateDbReq* pReq);
S
Shengliang Guan 已提交
693

S
Shengliang Guan 已提交
694
typedef struct {
695
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
696 697 698
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
S
Shengliang Guan 已提交
699
  int32_t daysPerFile;
S
Shengliang Guan 已提交
700 701 702 703 704
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t fsyncPeriod;
  int8_t  walLevel;
S
Shengliang Guan 已提交
705
  int8_t  strict;
S
Shengliang Guan 已提交
706
  int8_t  cacheLastRow;
X
Xiaoyu Wang 已提交
707
  int8_t  replications;
S
Shengliang Guan 已提交
708
} SAlterDbReq;
S
Shengliang Guan 已提交
709

S
Shengliang Guan 已提交
710 711 712
int32_t tSerializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);
int32_t tDeserializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);

S
Shengliang Guan 已提交
713
typedef struct {
S
Shengliang Guan 已提交
714
  char   db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
715
  int8_t ignoreNotExists;
S
Shengliang Guan 已提交
716
} SDropDbReq;
S
Shengliang Guan 已提交
717

S
Shengliang Guan 已提交
718 719 720
int32_t tSerializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);
int32_t tDeserializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);

S
Shengliang Guan 已提交
721
typedef struct {
L
Liu Jicong 已提交
722 723
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
S
Shengliang Guan 已提交
724 725
} SDropDbRsp;

S
Shengliang Guan 已提交
726 727 728
int32_t tSerializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);
int32_t tDeserializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);

S
Shengliang Guan 已提交
729 730
typedef struct {
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
731
  int64_t dbId;
732
  int32_t vgVersion;
L
Liu Jicong 已提交
733
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
S
Shengliang Guan 已提交
734
} SUseDbReq;
S
Shengliang Guan 已提交
735

S
Shengliang Guan 已提交
736 737
int32_t tSerializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
int32_t tDeserializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
S
Shengliang Guan 已提交
738 739

typedef struct {
L
Liu Jicong 已提交
740 741 742 743 744 745
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
  int32_t vgVersion;
  int32_t vgNum;
  int8_t  hashMethod;
  SArray* pVgroupInfos;  // Array of SVgroupInfo
S
Shengliang Guan 已提交
746 747
} SUseDbRsp;

L
Liu Jicong 已提交
748
int32_t tSerializeSUseDbRsp(void* buf, int32_t bufLen, const SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
749
int32_t tDeserializeSUseDbRsp(void* buf, int32_t bufLen, SUseDbRsp* pRsp);
H
Hongze Cheng 已提交
750 751
int32_t tSerializeSUseDbRspImp(SEncoder* pEncoder, const SUseDbRsp* pRsp);
int32_t tDeserializeSUseDbRspImp(SDecoder* pDecoder, SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
752 753
void    tFreeSUsedbRsp(SUseDbRsp* pRsp);

D
dapan1121 已提交
754
typedef struct {
dengyihao's avatar
dengyihao 已提交
755
  char db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
756 757 758 759 760 761 762
} SDbCfgReq;

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

typedef struct {
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
763 764 765 766
  int32_t numOfStables;
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
D
dapan1121 已提交
767 768 769 770 771 772 773 774 775 776 777
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t minRows;
  int32_t maxRows;
  int32_t fsyncPeriod;
  int8_t  walLevel;
  int8_t  precision;
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
778
  int8_t  strict;
D
dapan1121 已提交
779
  int8_t  cacheLastRow;
780 781
  int32_t numOfRetensions;
  SArray* pRetensions;
D
dapan1121 已提交
782 783 784 785 786
} SDbCfgRsp;

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

D
dapan1121 已提交
787 788 789 790 791 792 793 794
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);

typedef struct {
D
dapan1121 已提交
795
  SArray* addrsList;  // SArray<SQueryNodeAddr>
D
dapan1121 已提交
796 797 798 799 800 801
} 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 已提交
802 803 804 805 806
typedef struct SQueryNodeAddr {
  int32_t nodeId;  // vgId or qnodeId
  SEpSet  epSet;
} SQueryNodeAddr;

S
Shengliang Guan 已提交
807 808 809 810 811 812 813
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 已提交
814

D
dapan 已提交
815 816 817 818 819 820 821 822
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);

S
Shengliang Guan 已提交
823
typedef struct {
S
Shengliang Guan 已提交
824
  char db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
825
} SCompactDbReq;
S
Shengliang Guan 已提交
826

S
Shengliang Guan 已提交
827 828
int32_t tSerializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
int32_t tDeserializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
D
dapan1121 已提交
829 830

typedef struct {
S
Shengliang Guan 已提交
831
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang 已提交
832
  int8_t  igExists;
S
Shengliang Guan 已提交
833 834
  int8_t  funcType;
  int8_t  scriptType;
S
Shengliang Guan 已提交
835
  int8_t  outputType;
S
Shengliang Guan 已提交
836
  int32_t outputLen;
S
Shengliang Guan 已提交
837
  int32_t bufSize;
838
  int32_t codeLen;
S
Shengliang 已提交
839
  int64_t signature;
840 841
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
842
} SCreateFuncReq;
D
dapan1121 已提交
843

S
Shengliang Guan 已提交
844 845
int32_t tSerializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
int32_t tDeserializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
846
void    tFreeSCreateFuncReq(SCreateFuncReq* pReq);
S
Shengliang Guan 已提交
847

D
dapan1121 已提交
848
typedef struct {
S
Shengliang 已提交
849 850
  char   name[TSDB_FUNC_NAME_LEN];
  int8_t igNotExists;
S
Shengliang Guan 已提交
851
} SDropFuncReq;
S
Shengliang Guan 已提交
852

S
Shengliang Guan 已提交
853 854 855
int32_t tSerializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);
int32_t tDeserializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);

S
Shengliang Guan 已提交
856 857
typedef struct {
  int32_t numOfFuncs;
D
dapan1121 已提交
858
  bool    ignoreCodeComment;
S
Shengliang Guan 已提交
859
  SArray* pFuncNames;
S
Shengliang Guan 已提交
860
} SRetrieveFuncReq;
D
dapan1121 已提交
861

S
Shengliang Guan 已提交
862 863
int32_t tSerializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
int32_t tDeserializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
864
void    tFreeSRetrieveFuncReq(SRetrieveFuncReq* pReq);
S
Shengliang Guan 已提交
865

D
dapan1121 已提交
866 867
typedef struct {
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang Guan 已提交
868 869 870 871
  int8_t  funcType;
  int8_t  scriptType;
  int8_t  outputType;
  int32_t outputLen;
D
dapan1121 已提交
872
  int32_t bufSize;
S
Shengliang 已提交
873
  int64_t signature;
S
Shengliang Guan 已提交
874 875
  int32_t commentSize;
  int32_t codeSize;
876 877
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
878
} SFuncInfo;
D
dapan1121 已提交
879 880

typedef struct {
S
Shengliang Guan 已提交
881
  int32_t numOfFuncs;
S
Shengliang Guan 已提交
882
  SArray* pFuncInfos;
S
Shengliang Guan 已提交
883
} SRetrieveFuncRsp;
D
dapan1121 已提交
884

S
Shengliang Guan 已提交
885 886
int32_t tSerializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
int32_t tDeserializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
L
Liu Jicong 已提交
887
void    tFreeSFuncInfo(SFuncInfo* pInfo);
888
void    tFreeSRetrieveFuncRsp(SRetrieveFuncRsp* pRsp);
S
Shengliang Guan 已提交
889

D
dapan1121 已提交
890
typedef struct {
S
Shengliang Guan 已提交
891
  int32_t statusInterval;
S
Shengliang Guan 已提交
892
  int64_t checkTime;                  // 1970-01-01 00:00:00.000
S
Shengliang Guan 已提交
893 894 895
  char    timezone[TD_TIMEZONE_LEN];  // tsTimezone
  char    locale[TD_LOCALE_LEN];      // tsLocale
  char    charset[TD_LOCALE_LEN];     // tsCharset
S
Shengliang Guan 已提交
896
} SClusterCfg;
D
dapan1121 已提交
897

898 899 900 901 902 903 904 905 906 907 908 909
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 已提交
910 911
typedef struct {
  int32_t vgId;
S
Shengliang Guan 已提交
912
  int32_t syncState;
S
Shengliang Guan 已提交
913 914
  int64_t numOfTables;
  int64_t numOfTimeSeries;
S
Shengliang Guan 已提交
915 916 917
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
S
Shengliang Guan 已提交
918 919 920 921 922
  int64_t numOfSelectReqs;
  int64_t numOfInsertReqs;
  int64_t numOfInsertSuccessReqs;
  int64_t numOfBatchInsertReqs;
  int64_t numOfBatchInsertSuccessReqs;
S
Shengliang Guan 已提交
923 924
} SVnodeLoad;

S
Shengliang Guan 已提交
925 926 927 928
typedef struct {
  int32_t syncState;
} SMnodeLoad;

S
Shengliang Guan 已提交
929
typedef struct {
S
Shengliang Guan 已提交
930 931
  int32_t     sver;      // software version
  int64_t     dnodeVer;  // dnode table version in sdb
S
Shengliang Guan 已提交
932
  int32_t     dnodeId;
933
  int64_t     clusterId;
S
Shengliang Guan 已提交
934 935
  int64_t     rebootTime;
  int64_t     updateTime;
S
Shengliang Guan 已提交
936 937
  int32_t     numOfCores;
  int32_t     numOfSupportVnodes;
S
Shengliang Guan 已提交
938
  char        dnodeEp[TSDB_EP_LEN];
939
  SMnodeLoad  mload;
S
Shengliang Guan 已提交
940
  SClusterCfg clusterCfg;
S
Shengliang Guan 已提交
941
  SArray*     pVloads;  // array of SVnodeLoad
S
Shengliang Guan 已提交
942
} SStatusReq;
D
dapan1121 已提交
943

S
Shengliang Guan 已提交
944 945
int32_t tSerializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
int32_t tDeserializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
S
Shengliang Guan 已提交
946
void    tFreeSStatusReq(SStatusReq* pReq);
S
Shengliang Guan 已提交
947

D
dapan1121 已提交
948
typedef struct {
S
Shengliang Guan 已提交
949
  int32_t dnodeId;
950
  int64_t clusterId;
D
dapan1121 已提交
951 952 953
} SDnodeCfg;

typedef struct {
954 955 956
  int32_t id;
  int8_t  isMnode;
  SEp     ep;
D
dapan1121 已提交
957 958 959
} SDnodeEp;

typedef struct {
S
Shengliang Guan 已提交
960
  int64_t   dnodeVer;
S
Shengliang Guan 已提交
961
  SDnodeCfg dnodeCfg;
S
Shengliang Guan 已提交
962
  SArray*   pDnodeEps;  // Array of SDnodeEp
D
dapan1121 已提交
963 964
} SStatusRsp;

S
Shengliang Guan 已提交
965 966
int32_t tSerializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
int32_t tDeserializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
S
shm  
Shengliang Guan 已提交
967
void    tFreeSStatusRsp(SStatusRsp* pRsp);
S
Shengliang Guan 已提交
968 969

typedef struct {
S
Shengliang Guan 已提交
970 971 972 973 974
  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 已提交
975

D
dapan1121 已提交
976
typedef struct {
S
Shengliang Guan 已提交
977 978 979
  int32_t  id;
  uint16_t port;                 // node sync Port
  char     fqdn[TSDB_FQDN_LEN];  // node FQDN
S
Shengliang Guan 已提交
980 981 982
} SReplica;

typedef struct {
S
Shengliang Guan 已提交
983
  int32_t  vgId;
S
Shengliang Guan 已提交
984
  int32_t  dnodeId;
985
  char     db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
986
  int64_t  dbUid;
987
  int32_t  vgVersion;
L
Liu Jicong 已提交
988
  int32_t  numOfStables;
S
Shengliang Guan 已提交
989 990 991
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
S
Shengliang Guan 已提交
992 993 994 995
  int32_t  daysPerFile;
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
Shengliang Guan 已提交
996 997
  int32_t  minRows;
  int32_t  maxRows;
S
Shengliang Guan 已提交
998
  int32_t  fsyncPeriod;
D
dapan1121 已提交
999 1000
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1001
  int8_t   hashMethod;
S
Shengliang Guan 已提交
1002
  int8_t   walLevel;
S
Shengliang Guan 已提交
1003 1004
  int8_t   precision;
  int8_t   compression;
S
Shengliang Guan 已提交
1005
  int8_t   strict;
S
Shengliang Guan 已提交
1006
  int8_t   cacheLastRow;
S
Shengliang Guan 已提交
1007
  int8_t   replica;
S
Shengliang Guan 已提交
1008 1009
  int8_t   selfIndex;
  SReplica replicas[TSDB_MAX_REPLICA];
S
sma  
Shengliang Guan 已提交
1010 1011
  int32_t  numOfRetensions;
  SArray*  pRetensions;  // SRetention
S
Shengliang Guan 已提交
1012 1013 1014 1015

  // for tsma
  int8_t isTsma;

S
Shengliang Guan 已提交
1016
} SCreateVnodeReq;
D
dapan1121 已提交
1017

S
Shengliang Guan 已提交
1018 1019
int32_t tSerializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
int32_t tDeserializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
S
sma  
Shengliang Guan 已提交
1020
int32_t tFreeSCreateVnodeReq(SCreateVnodeReq* pReq);
S
Shengliang Guan 已提交
1021

S
Shengliang Guan 已提交
1022
typedef struct {
L
Liu Jicong 已提交
1023 1024 1025 1026
  int32_t vgId;
  int32_t dnodeId;
  int64_t dbUid;
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1027
} SDropVnodeReq;
S
Shengliang Guan 已提交
1028

S
Shengliang Guan 已提交
1029 1030
int32_t tSerializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
int32_t tDeserializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
S
Shengliang Guan 已提交
1031

S
Shengliang Guan 已提交
1032 1033 1034 1035 1036 1037 1038 1039 1040 1041
typedef struct {
  int64_t dbUid;
  char    db[TSDB_DB_FNAME_LEN];
} SCompactVnodeReq;

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

typedef struct {
  int32_t  vgVersion;
S
Shengliang Guan 已提交
1042 1043 1044
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
S
Shengliang Guan 已提交
1045
  int32_t  daysPerFile;
S
Shengliang Guan 已提交
1046 1047 1048
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
Shengliang Guan 已提交
1049
  int32_t  fsyncPeriod;
S
Shengliang Guan 已提交
1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060
  int8_t   walLevel;
  int8_t   strict;
  int8_t   cacheLastRow;
  int8_t   replica;
  int8_t   selfIndex;
  SReplica replicas[TSDB_MAX_REPLICA];
} SAlterVnodeReq;

int32_t tSerializeSAlterVnodeReq(void* buf, int32_t bufLen, SAlterVnodeReq* pReq);
int32_t tDeserializeSAlterVnodeReq(void* buf, int32_t bufLen, SAlterVnodeReq* pReq);

D
dapan1121 已提交
1061
typedef struct {
D
dapan1121 已提交
1062
  SMsgHead header;
D
dapan1121 已提交
1063 1064
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
S
Shengliang Guan 已提交
1065
} STableInfoReq;
D
dapan1121 已提交
1066

S
Shengliang Guan 已提交
1067 1068 1069
int32_t tSerializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);
int32_t tDeserializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);

D
dapan1121 已提交
1070
typedef struct {
S
Shengliang Guan 已提交
1071
  int8_t  metaClone;  // create local clone of the cached table meta
D
dapan1121 已提交
1072 1073 1074 1075
  int32_t numOfVgroups;
  int32_t numOfTables;
  int32_t numOfUdfs;
  char    tableNames[];
S
Shengliang Guan 已提交
1076
} SMultiTableInfoReq;
D
dapan1121 已提交
1077

H
Haojun Liao 已提交
1078
// todo refactor
D
dapan1121 已提交
1079
typedef struct SVgroupInfo {
1080 1081 1082
  int32_t  vgId;
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1083
  SEpSet   epSet;
L
Liu Jicong 已提交
1084 1085 1086 1087
  union {
    int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
    int32_t taskId;      // used in stream
  };
D
dapan1121 已提交
1088 1089
} SVgroupInfo;

D
dapan1121 已提交
1090
typedef struct {
H
Haojun Liao 已提交
1091 1092
  int32_t     numOfVgroups;
  SVgroupInfo vgroups[];
S
Shengliang Guan 已提交
1093
} SVgroupsInfo;
D
dapan1121 已提交
1094

S
Shengliang Guan 已提交
1095
typedef struct {
D
dapan1121 已提交
1096 1097 1098
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     stbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1099
  int64_t  dbId;
S
Shengliang Guan 已提交
1100 1101 1102 1103 1104 1105
  int32_t  numOfTags;
  int32_t  numOfColumns;
  int8_t   precision;
  int8_t   tableType;
  int32_t  sversion;
  int32_t  tversion;
L
Liu Jicong 已提交
1106 1107
  uint64_t suid;
  uint64_t tuid;
S
Shengliang Guan 已提交
1108
  int32_t  vgId;
S
Shengliang Guan 已提交
1109
  SSchema* pSchemas;
S
Shengliang Guan 已提交
1110
} STableMetaRsp;
D
dapan1121 已提交
1111

S
Shengliang Guan 已提交
1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123
int32_t tSerializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
int32_t tDeserializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
void    tFreeSTableMetaRsp(STableMetaRsp* pRsp);

typedef struct {
  SArray* pArray;  // Array of STableMetaRsp
} STableMetaBatchRsp;

int32_t tSerializeSTableMetaBatchRsp(void* buf, int32_t bufLen, STableMetaBatchRsp* pRsp);
int32_t tDeserializeSTableMetaBatchRsp(void* buf, int32_t bufLen, STableMetaBatchRsp* pRsp);
void    tFreeSTableMetaBatchRsp(STableMetaBatchRsp* pRsp);

S
Shengliang Guan 已提交
1124
typedef struct {
S
Shengliang Guan 已提交
1125 1126 1127 1128 1129 1130 1131 1132
  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 已提交
1133 1134 1135 1136 1137
} SMultiTableMeta;

typedef struct {
  int32_t dataLen;
  char    name[TSDB_TABLE_FNAME_LEN];
H
Hongze Cheng 已提交
1138
  char*   data;
D
dapan1121 已提交
1139 1140 1141 1142 1143 1144 1145 1146
} STagData;

/*
 * sql: show tables like '%a_%'
 * payload is the query condition, e.g., '%a_%'
 * payloadLen is the length of payload
 */
typedef struct {
L
Liu Jicong 已提交
1147
  int32_t type;
1148
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1149 1150
  int32_t payloadLen;
  char*   payload;
S
Shengliang Guan 已提交
1151
} SShowReq;
D
dapan1121 已提交
1152

S
Shengliang Guan 已提交
1153 1154 1155 1156
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 已提交
1157
typedef struct {
1158
  int64_t       showId;
S
Shengliang Guan 已提交
1159
  STableMetaRsp tableMeta;
S
Shengliang Guan 已提交
1160
} SShowRsp, SVShowTablesRsp;
D
dapan1121 已提交
1161

S
Shengliang Guan 已提交
1162 1163 1164
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 已提交
1165

1166
typedef struct {
1167
  char    db[TSDB_DB_FNAME_LEN];
H
Haojun Liao 已提交
1168
  char    tb[TSDB_TABLE_NAME_LEN];
1169 1170 1171
  int64_t showId;
} SRetrieveTableReq;

1172 1173 1174 1175 1176 1177
typedef struct SSysTableSchema {
  int8_t   type;
  col_id_t colId;
  int32_t  bytes;
} SSysTableSchema;

1178 1179 1180 1181 1182 1183 1184 1185 1186 1187
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;
  int32_t compLen;
  int32_t numOfRows;
1188
  int32_t numOfCols;
1189 1190 1191
  char    data[];
} SRetrieveTableRsp;

H
Haojun Liao 已提交
1192
typedef struct {
L
Liu Jicong 已提交
1193 1194 1195 1196 1197 1198 1199 1200
  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 已提交
1201 1202
} SRetrieveMetaTableRsp;

D
dapan1121 已提交
1203
typedef struct SExplainExecInfo {
1204 1205
  double   startupCost;
  double   totalCost;
D
dapan1121 已提交
1206
  uint64_t numOfRows;
1207
  uint32_t verboseLen;
dengyihao's avatar
dengyihao 已提交
1208
  void*    verboseInfo;
D
dapan1121 已提交
1209 1210
} SExplainExecInfo;

D
dapan1121 已提交
1211
typedef struct {
D
dapan1121 已提交
1212
  int32_t           numOfPlans;
dengyihao's avatar
dengyihao 已提交
1213
  SExplainExecInfo* subplanInfo;
D
dapan1121 已提交
1214 1215
} SExplainRsp;

1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227
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;
  uint64_t filterTime;
} STableScanAnalyzeInfo;

D
dapan1121 已提交
1228 1229
int32_t tSerializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
int32_t tDeserializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
D
dapan1121 已提交
1230

D
dapan1121 已提交
1231
typedef struct {
S
Shengliang Guan 已提交
1232
  char    fqdn[TSDB_FQDN_LEN];  // end point, hostname:port
1233
  int32_t port;
S
Shengliang Guan 已提交
1234
} SCreateDnodeReq;
S
Shengliang Guan 已提交
1235

S
Shengliang Guan 已提交
1236 1237 1238
int32_t tSerializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);
int32_t tDeserializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);

S
Shengliang Guan 已提交
1239 1240
typedef struct {
  int32_t dnodeId;
1241 1242
  char    fqdn[TSDB_FQDN_LEN];
  int32_t port;
S
Shengliang Guan 已提交
1243
} SDropDnodeReq;
S
Shengliang Guan 已提交
1244

S
Shengliang Guan 已提交
1245 1246 1247
int32_t tSerializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);
int32_t tDeserializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);

S
Shengliang Guan 已提交
1248 1249
typedef struct {
  int32_t dnodeId;
1250
  char    config[TSDB_DNODE_CONFIG_LEN];
S
Shengliang Guan 已提交
1251
  char    value[TSDB_DNODE_VALUE_LEN];
S
Shengliang Guan 已提交
1252
} SMCfgDnodeReq, SDCfgDnodeReq;
D
dapan1121 已提交
1253

S
Shengliang Guan 已提交
1254 1255 1256
int32_t tSerializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);
int32_t tDeserializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);

S
Shengliang Guan 已提交
1257 1258
typedef struct {
  int32_t dnodeId;
dengyihao's avatar
dengyihao 已提交
1259 1260 1261
} SMCreateMnodeReq, SMDropMnodeReq, SDDropMnodeReq, SMCreateQnodeReq, SMDropQnodeReq, SDCreateQnodeReq, SDDropQnodeReq,
    SMCreateSnodeReq, SMDropSnodeReq, SDCreateSnodeReq, SDDropSnodeReq, SMCreateBnodeReq, SMDropBnodeReq,
    SDCreateBnodeReq, SDDropBnodeReq;
S
Shengliang Guan 已提交
1262

1263 1264
int32_t tSerializeSCreateDropMQSBNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
int32_t tDeserializeSCreateDropMQSBNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
S
Shengliang Guan 已提交
1265

D
dapan1121 已提交
1266
typedef struct {
S
Shengliang Guan 已提交
1267
  int8_t   replica;
S
Shengliang Guan 已提交
1268
  SReplica replicas[TSDB_MAX_REPLICA];
S
Shengliang Guan 已提交
1269
} SDCreateMnodeReq, SDAlterMnodeReq;
D
dapan1121 已提交
1270

S
Shengliang Guan 已提交
1271 1272 1273
int32_t tSerializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);
int32_t tDeserializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);

S
Shengliang Guan 已提交
1274 1275 1276
typedef struct {
  int32_t connId;
  int32_t queryId;
S
Shengliang Guan 已提交
1277
} SKillQueryReq;
S
Shengliang Guan 已提交
1278

S
Shengliang Guan 已提交
1279 1280 1281
int32_t tSerializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);
int32_t tDeserializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);

S
Shengliang Guan 已提交
1282 1283
typedef struct {
  int32_t connId;
S
Shengliang Guan 已提交
1284
} SKillConnReq;
D
dapan1121 已提交
1285

S
Shengliang Guan 已提交
1286 1287 1288
int32_t tSerializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);
int32_t tDeserializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);

S
Shengliang Guan 已提交
1289 1290 1291 1292 1293 1294 1295
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);

D
dapan1121 已提交
1296 1297 1298 1299
typedef struct {
  char user[TSDB_USER_LEN];
  char spi;
  char encrypt;
1300 1301
  char secret[TSDB_PASSWORD_LEN];
  char ckey[TSDB_PASSWORD_LEN];
S
Shengliang Guan 已提交
1302
} SAuthReq, SAuthRsp;
D
dapan1121 已提交
1303

S
Shengliang Guan 已提交
1304 1305 1306
int32_t tSerializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);
int32_t tDeserializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);

D
dapan1121 已提交
1307
typedef struct {
S
Shengliang Guan 已提交
1308
  int32_t statusCode;
S
Shengliang Guan 已提交
1309
  char    details[1024];
S
Shengliang Guan 已提交
1310 1311 1312 1313
} SServerStatusRsp;

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

1315 1316 1317 1318 1319 1320 1321
/**
 * 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 已提交
1322
typedef struct SSubQueryMsg {
D
dapan1121 已提交
1323
  SMsgHead header;
D
dapan1121 已提交
1324
  uint64_t sId;
H
Hongze Cheng 已提交
1325 1326
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1327
  int64_t  refId;
D
dapan1121 已提交
1328
  int8_t   taskType;
D
dapan1121 已提交
1329
  int8_t   explain;
1330
  uint32_t sqlLen;  // the query sql,
1331
  uint32_t phyLen;
H
Hongze Cheng 已提交
1332
  char     msg[];
D
dapan1121 已提交
1333
} SSubQueryMsg;
D
dapan 已提交
1334

1335 1336 1337 1338 1339 1340 1341
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
} SSinkDataReq;

D
dapan1121 已提交
1342 1343 1344 1345 1346 1347 1348
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
} SQueryContinueReq;

S
Shengliang Guan 已提交
1349
typedef struct {
D
dapan1121 已提交
1350
  SMsgHead header;
D
dapan1121 已提交
1351
  uint64_t sId;
H
Hongze Cheng 已提交
1352 1353
  uint64_t queryId;
  uint64_t taskId;
S
Shengliang Guan 已提交
1354
} SResReadyReq;
D
dapan 已提交
1355

S
Shengliang Guan 已提交
1356
typedef struct {
D
dapan1121 已提交
1357
  int32_t code;
L
Liu Jicong 已提交
1358
  char    tbFName[TSDB_TABLE_FNAME_LEN];
1359 1360
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
1361 1362
} SResReadyRsp;

S
Shengliang Guan 已提交
1363
typedef struct {
D
dapan1121 已提交
1364
  SMsgHead header;
D
dapan1121 已提交
1365
  uint64_t sId;
H
Hongze Cheng 已提交
1366 1367
  uint64_t queryId;
  uint64_t taskId;
S
Shengliang Guan 已提交
1368
} SResFetchReq;
D
dapan 已提交
1369

S
Shengliang Guan 已提交
1370
typedef struct {
D
dapan1121 已提交
1371
  SMsgHead header;
D
dapan1121 已提交
1372
  uint64_t sId;
S
Shengliang Guan 已提交
1373
} SSchTasksStatusReq;
D
dapan1121 已提交
1374

S
Shengliang Guan 已提交
1375
typedef struct {
H
Hongze Cheng 已提交
1376 1377
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1378
  int64_t  refId;
H
Hongze Cheng 已提交
1379
  int8_t   status;
D
dapan1121 已提交
1380 1381
} STaskStatus;

S
Shengliang Guan 已提交
1382
typedef struct {
L
Liu Jicong 已提交
1383 1384
  int64_t refId;
  SArray* taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1385 1386
} SSchedulerStatusRsp;

D
dapan1121 已提交
1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401
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 已提交
1402
  SArray*        taskAction;  // SArray<STaskAction>
D
dapan1121 已提交
1403 1404
} SSchedulerHbReq;

L
Liu Jicong 已提交
1405 1406 1407
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 已提交
1408 1409 1410

typedef struct {
  SQueryNodeEpId epId;
L
Liu Jicong 已提交
1411
  SArray*        taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1412 1413
} SSchedulerHbRsp;

L
Liu Jicong 已提交
1414 1415 1416
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 已提交
1417

S
Shengliang Guan 已提交
1418
typedef struct {
D
dapan1121 已提交
1419
  SMsgHead header;
D
dapan1121 已提交
1420
  uint64_t sId;
H
Hongze Cheng 已提交
1421 1422
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1423
  int64_t  refId;
S
Shengliang Guan 已提交
1424
} STaskCancelReq;
D
dapan1121 已提交
1425

S
Shengliang Guan 已提交
1426
typedef struct {
D
dapan1121 已提交
1427 1428 1429
  int32_t code;
} STaskCancelRsp;

S
Shengliang Guan 已提交
1430
typedef struct {
D
dapan1121 已提交
1431
  SMsgHead header;
D
dapan1121 已提交
1432
  uint64_t sId;
H
Hongze Cheng 已提交
1433 1434
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1435
  int64_t  refId;
S
Shengliang Guan 已提交
1436
} STaskDropReq;
D
dapan1121 已提交
1437

S
Shengliang Guan 已提交
1438
typedef struct {
D
dapan1121 已提交
1439 1440 1441
  int32_t code;
} STaskDropRsp;

X
Xiaoyu Wang 已提交
1442 1443 1444
#define STREAM_TRIGGER_AT_ONCE      1
#define STREAM_TRIGGER_WINDOW_CLOSE 2

L
Liu Jicong 已提交
1445
typedef struct {
L
Liu Jicong 已提交
1446 1447 1448
  char    name[TSDB_TABLE_FNAME_LEN];
  char    sourceDB[TSDB_DB_FNAME_LEN];
  char    targetStbFullName[TSDB_TABLE_FNAME_LEN];
1449 1450 1451 1452
  int8_t  igExists;
  char*   sql;
  char*   ast;
  int8_t  triggerType;
X
Xiaoyu Wang 已提交
1453
  int64_t watermark;
L
Liu Jicong 已提交
1454
} SCMCreateStreamReq;
L
Liu Jicong 已提交
1455

L
Liu Jicong 已提交
1456 1457 1458 1459 1460 1461 1462 1463
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 已提交
1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474
typedef struct {
  char    name[TSDB_TOPIC_FNAME_LEN];
  int64_t streamId;
  char*   sql;
  char*   executorMsg;
} SMVCreateStreamReq, SMSCreateStreamReq;

typedef struct {
  int64_t streamId;
} SMVCreateStreamRsp, SMSCreateStreamRsp;

L
Liu Jicong 已提交
1475
typedef struct {
L
Liu Jicong 已提交
1476 1477 1478 1479 1480 1481 1482 1483
  char   name[TSDB_TOPIC_FNAME_LEN];  // accout.topic
  int8_t igExists;
  int8_t withTbName;
  int8_t withSchema;
  int8_t withTag;
  char*  sql;
  char*  ast;
  char   subscribeDbName[TSDB_DB_NAME_LEN];
L
Liu Jicong 已提交
1484 1485 1486 1487 1488
} 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 已提交
1489 1490 1491

typedef struct {
  int64_t topicId;
L
Liu Jicong 已提交
1492
} SCMCreateTopicRsp;
L
Liu Jicong 已提交
1493

L
Liu Jicong 已提交
1494 1495
int32_t tSerializeSCMCreateTopicRsp(void* buf, int32_t bufLen, const SCMCreateTopicRsp* pRsp);
int32_t tDeserializeSCMCreateTopicRsp(void* buf, int32_t bufLen, SCMCreateTopicRsp* pRsp);
L
Liu Jicong 已提交
1496

1497 1498
typedef struct {
  int64_t consumerId;
L
Liu Jicong 已提交
1499
} SMqConsumerLostMsg, SMqConsumerRecoverMsg;
1500

L
Liu Jicong 已提交
1501 1502
typedef struct {
  int64_t consumerId;
1503
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
1504
  char    clientId[256];
L
Liu Jicong 已提交
1505
  SArray* topicNames;  // SArray<char**>
L
Liu Jicong 已提交
1506 1507
} SCMSubscribeReq;

S
Shengliang Guan 已提交
1508 1509
static FORCE_INLINE int32_t tSerializeSCMSubscribeReq(void** buf, const SCMSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1510
  tlen += taosEncodeFixedI64(buf, pReq->consumerId);
1511
  tlen += taosEncodeString(buf, pReq->cgroup);
L
Liu Jicong 已提交
1512
  tlen += taosEncodeString(buf, pReq->clientId);
L
Liu Jicong 已提交
1513

L
Liu Jicong 已提交
1514 1515 1516 1517
  int32_t topicNum = taosArrayGetSize(pReq->topicNames);
  tlen += taosEncodeFixedI32(buf, topicNum);

  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
1518
    tlen += taosEncodeString(buf, (char*)taosArrayGetP(pReq->topicNames, i));
L
Liu Jicong 已提交
1519
  }
L
Liu Jicong 已提交
1520 1521 1522 1523 1524
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeReq(void* buf, SCMSubscribeReq* pReq) {
  buf = taosDecodeFixedI64(buf, &pReq->consumerId);
1525
  buf = taosDecodeStringTo(buf, pReq->cgroup);
L
Liu Jicong 已提交
1526
  buf = taosDecodeStringTo(buf, pReq->clientId);
L
Liu Jicong 已提交
1527 1528 1529 1530 1531 1532

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

  pReq->topicNames = taosArrayInit(topicNum, sizeof(void*));
  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
1533
    char* name;
L
Liu Jicong 已提交
1534 1535
    buf = taosDecodeString(buf, &name);
    taosArrayPush(pReq->topicNames, &name);
L
Liu Jicong 已提交
1536
  }
L
Liu Jicong 已提交
1537 1538 1539
  return buf;
}

L
Liu Jicong 已提交
1540
typedef struct SMqSubTopic {
L
Liu Jicong 已提交
1541
  int32_t vgId;
L
Liu Jicong 已提交
1542 1543 1544 1545 1546
  int64_t topicId;
  SEpSet  epSet;
} SMqSubTopic;

typedef struct {
L
Liu Jicong 已提交
1547
  int32_t     topicNum;
L
Liu Jicong 已提交
1548
  SMqSubTopic topics[];
L
Liu Jicong 已提交
1549 1550
} SCMSubscribeRsp;

S
Shengliang Guan 已提交
1551 1552
static FORCE_INLINE int32_t tSerializeSCMSubscribeRsp(void** buf, const SCMSubscribeRsp* pRsp) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1553
  tlen += taosEncodeFixedI32(buf, pRsp->topicNum);
S
Shengliang Guan 已提交
1554
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
1555 1556 1557 1558
    tlen += taosEncodeFixedI32(buf, pRsp->topics[i].vgId);
    tlen += taosEncodeFixedI64(buf, pRsp->topics[i].topicId);
    tlen += taosEncodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
1559 1560 1561 1562
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeRsp(void* buf, SCMSubscribeRsp* pRsp) {
L
Liu Jicong 已提交
1563
  buf = taosDecodeFixedI32(buf, &pRsp->topicNum);
S
Shengliang Guan 已提交
1564
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
1565 1566 1567 1568
    buf = taosDecodeFixedI32(buf, &pRsp->topics[i].vgId);
    buf = taosDecodeFixedI64(buf, &pRsp->topics[i].topicId);
    buf = taosDecodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
1569 1570 1571 1572 1573 1574 1575 1576
  return buf;
}

typedef struct {
  int64_t topicId;
  int64_t consumerId;
  int64_t consumerGroupId;
  int64_t offset;
L
Liu Jicong 已提交
1577 1578 1579
  char*   sql;
  char*   logicalPlan;
  char*   physicalPlan;
L
Liu Jicong 已提交
1580 1581
} SMVSubscribeReq;

S
Shengliang Guan 已提交
1582 1583
static FORCE_INLINE int32_t tSerializeSMVSubscribeReq(void** buf, SMVSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604
  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 已提交
1605
typedef struct {
1606 1607 1608 1609
  char    key[TSDB_SUBSCRIBE_KEY_LEN];
  SArray* lostConsumers;     // SArray<int64_t>
  SArray* removedConsumers;  // SArray<int64_t>
  SArray* newConsumers;      // SArray<int64_t>
L
Liu Jicong 已提交
1610
} SMqRebInfo;
L
Liu Jicong 已提交
1611

L
Liu Jicong 已提交
1612 1613 1614
static FORCE_INLINE SMqRebInfo* tNewSMqRebSubscribe(const char* key) {
  SMqRebInfo* pRebInfo = (SMqRebInfo*)taosMemoryCalloc(1, sizeof(SMqRebInfo));
  if (pRebInfo == NULL) {
L
Liu Jicong 已提交
1615
    return NULL;
L
Liu Jicong 已提交
1616
  }
L
Liu Jicong 已提交
1617 1618 1619
  strcpy(pRebInfo->key, key);
  pRebInfo->lostConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->lostConsumers == NULL) {
L
Liu Jicong 已提交
1620 1621
    goto _err;
  }
L
Liu Jicong 已提交
1622 1623
  pRebInfo->removedConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->removedConsumers == NULL) {
L
Liu Jicong 已提交
1624 1625
    goto _err;
  }
L
Liu Jicong 已提交
1626 1627
  pRebInfo->newConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->newConsumers == NULL) {
L
Liu Jicong 已提交
1628 1629
    goto _err;
  }
L
Liu Jicong 已提交
1630
  return pRebInfo;
L
Liu Jicong 已提交
1631
_err:
L
Liu Jicong 已提交
1632 1633 1634 1635
  taosArrayDestroy(pRebInfo->lostConsumers);
  taosArrayDestroy(pRebInfo->removedConsumers);
  taosArrayDestroy(pRebInfo->newConsumers);
  taosMemoryFreeClear(pRebInfo);
L
Liu Jicong 已提交
1636 1637 1638
  return NULL;
}

L
Liu Jicong 已提交
1639 1640
// 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 已提交
1641
typedef struct {
1642
  SHashObj* rebSubHash;  // SHashObj<key, SMqRebSubscribe>
L
Liu Jicong 已提交
1643 1644
} SMqDoRebalanceMsg;

L
Liu Jicong 已提交
1645
typedef struct {
L
Liu Jicong 已提交
1646
  int64_t status;
L
Liu Jicong 已提交
1647 1648
} SMVSubscribeRsp;

L
Liu Jicong 已提交
1649
typedef struct {
1650
  char   name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
1651
  int8_t igNotExists;
S
Shengliang Guan 已提交
1652 1653
} SMDropTopicReq;

S
Shengliang Guan 已提交
1654
int32_t tSerializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
S
Shengliang Guan 已提交
1655
int32_t tDeserializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
L
Liu Jicong 已提交
1656

1657 1658 1659 1660 1661 1662 1663 1664 1665
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 已提交
1666 1667 1668 1669
typedef struct {
  int8_t reserved;
} SMDropCgroupRsp;

L
Liu Jicong 已提交
1670 1671 1672 1673
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
  SSchema schema;
S
Shengliang Guan 已提交
1674
} SAlterTopicReq;
L
Liu Jicong 已提交
1675 1676 1677 1678

typedef struct {
  SMsgHead head;
  char     name[TSDB_TABLE_FNAME_LEN];
L
Liu Jicong 已提交
1679
  int64_t  tuid;
L
Liu Jicong 已提交
1680 1681 1682 1683 1684
  int32_t  sverson;
  int32_t  execLen;
  char*    executor;
  int32_t  sqlLen;
  char*    sql;
S
Shengliang Guan 已提交
1685
} SDCreateTopicReq;
L
Liu Jicong 已提交
1686 1687 1688 1689

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

C
Cary Xu 已提交
1693
typedef struct {
1694 1695 1696 1697 1698 1699
  float   xFilesFactor;
  int32_t delay;
  int32_t qmsg1Len;
  int32_t qmsg2Len;
  char*   qmsg1;  // pAst1:qmsg1:SRetention1 => trigger aggr task1
  char*   qmsg2;  // pAst2:qmsg2:SRetention2 => trigger aggr task2
C
Cary Xu 已提交
1700 1701
} SRSmaParam;

H
Hongze Cheng 已提交
1702 1703
int32_t tEncodeSRSmaParam(SEncoder* pCoder, const SRSmaParam* pRSmaParam);
int32_t tDecodeSRSmaParam(SDecoder* pCoder, SRSmaParam* pRSmaParam);
H
Hongze Cheng 已提交
1704

H
Hongze Cheng 已提交
1705
// TDMT_VND_CREATE_STB ==============
H
Hongze Cheng 已提交
1706
typedef struct SVCreateStbReq {
H
Hongze Cheng 已提交
1707
  char*          name;
H
Hongze Cheng 已提交
1708 1709
  tb_uid_t       suid;
  int8_t         rollup;
1710
  SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
1711 1712
  SSchemaWrapper schemaTag;
  SRSmaParam     pRSmaParam;
H
Hongze Cheng 已提交
1713 1714
} SVCreateStbReq;

H
Hongze Cheng 已提交
1715 1716
int tEncodeSVCreateStbReq(SEncoder* pCoder, const SVCreateStbReq* pReq);
int tDecodeSVCreateStbReq(SDecoder* pCoder, SVCreateStbReq* pReq);
H
Hongze Cheng 已提交
1717

H
Hongze Cheng 已提交
1718
// TDMT_VND_DROP_STB ==============
H
Hongze Cheng 已提交
1719
typedef struct SVDropStbReq {
H
Hongze Cheng 已提交
1720 1721
  char*    name;
  tb_uid_t suid;
H
Hongze Cheng 已提交
1722 1723
} SVDropStbReq;

H
Hongze Cheng 已提交
1724 1725
int32_t tEncodeSVDropStbReq(SEncoder* pCoder, const SVDropStbReq* pReq);
int32_t tDecodeSVDropStbReq(SDecoder* pCoder, SVDropStbReq* pReq);
H
Hongze Cheng 已提交
1726

H
Hongze Cheng 已提交
1727
// TDMT_VND_CREATE_TABLE ==============
H
Hongze Cheng 已提交
1728
#define TD_CREATE_IF_NOT_EXISTS 0x1
H
more  
Hongze Cheng 已提交
1729
typedef struct SVCreateTbReq {
H
Hongze Cheng 已提交
1730
  int32_t  flags;
H
Hongze Cheng 已提交
1731
  char*    name;
H
Hongze Cheng 已提交
1732 1733 1734 1735
  tb_uid_t uid;
  int64_t  ctime;
  int32_t  ttl;
  int8_t   type;
C
Cary Xu 已提交
1736 1737
  union {
    struct {
H
Hongze Cheng 已提交
1738 1739
      tb_uid_t suid;
      uint8_t* pTag;
H
Hongze Cheng 已提交
1740
    } ctb;
H
more  
Hongze Cheng 已提交
1741
    struct {
1742
      SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
1743
    } ntb;
H
more  
Hongze Cheng 已提交
1744
  };
H
Hongze Cheng 已提交
1745
} SVCreateTbReq;
H
Hongze Cheng 已提交
1746

H
Hongze Cheng 已提交
1747 1748
int tEncodeSVCreateTbReq(SEncoder* pCoder, const SVCreateTbReq* pReq);
int tDecodeSVCreateTbReq(SDecoder* pCoder, SVCreateTbReq* pReq);
H
Hongze Cheng 已提交
1749

H
more  
Hongze Cheng 已提交
1750
typedef struct {
H
Hongze Cheng 已提交
1751 1752 1753 1754 1755
  int32_t nReqs;
  union {
    SVCreateTbReq* pReqs;
    SArray*        pArray;
  };
H
more  
Hongze Cheng 已提交
1756
} SVCreateTbBatchReq;
H
more  
Hongze Cheng 已提交
1757

H
Hongze Cheng 已提交
1758 1759
int tEncodeSVCreateTbBatchReq(SEncoder* pCoder, const SVCreateTbBatchReq* pReq);
int tDecodeSVCreateTbBatchReq(SDecoder* pCoder, SVCreateTbBatchReq* pReq);
H
more  
Hongze Cheng 已提交
1760

H
more  
Hongze Cheng 已提交
1761
typedef struct {
D
dapan1121 已提交
1762
  int32_t code;
S
Shengliang Guan 已提交
1763
} SVCreateTbRsp, SVUpdateTbRsp;
H
more  
Hongze Cheng 已提交
1764

H
Hongze Cheng 已提交
1765 1766
int tEncodeSVCreateTbRsp(SEncoder* pCoder, const SVCreateTbRsp* pRsp);
int tDecodeSVCreateTbRsp(SDecoder* pCoder, SVCreateTbRsp* pRsp);
H
Hongze Cheng 已提交
1767

S
Shengliang Guan 已提交
1768 1769
int32_t tSerializeSVCreateTbReq(void** buf, SVCreateTbReq* pReq);
void*   tDeserializeSVCreateTbReq(void* buf, SVCreateTbReq* pReq);
H
more  
Hongze Cheng 已提交
1770

H
more  
Hongze Cheng 已提交
1771
typedef struct {
H
Hongze Cheng 已提交
1772 1773 1774 1775 1776
  int32_t nRsps;
  union {
    SVCreateTbRsp* pRsps;
    SArray*        pArray;
  };
S
Shengliang Guan 已提交
1777
} SVCreateTbBatchRsp;
H
more  
Hongze Cheng 已提交
1778

H
Hongze Cheng 已提交
1779 1780
int tEncodeSVCreateTbBatchRsp(SEncoder* pCoder, const SVCreateTbBatchRsp* pRsp);
int tDecodeSVCreateTbBatchRsp(SDecoder* pCoder, SVCreateTbBatchRsp* pRsp);
H
Hongze Cheng 已提交
1781

L
Liu Jicong 已提交
1782 1783
int32_t tSerializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
int32_t tDeserializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
1784

H
Hongze Cheng 已提交
1785
// TDMT_VND_DROP_TABLE =================
S
Shengliang Guan 已提交
1786
typedef struct {
H
Hongze Cheng 已提交
1787 1788
  char*  name;
  int8_t igNotExists;
S
Shengliang Guan 已提交
1789 1790 1791
} SVDropTbReq;

typedef struct {
H
Hongze Cheng 已提交
1792
  int32_t code;
S
Shengliang Guan 已提交
1793 1794
} SVDropTbRsp;

H
Hongze Cheng 已提交
1795 1796 1797 1798 1799 1800 1801 1802
typedef struct {
  int32_t nReqs;
  union {
    SVDropTbReq* pReqs;
    SArray*      pArray;
  };
} SVDropTbBatchReq;

H
Hongze Cheng 已提交
1803 1804
int32_t tEncodeSVDropTbBatchReq(SEncoder* pCoder, const SVDropTbBatchReq* pReq);
int32_t tDecodeSVDropTbBatchReq(SDecoder* pCoder, SVDropTbBatchReq* pReq);
H
Hongze Cheng 已提交
1805 1806 1807 1808 1809 1810 1811 1812 1813

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

H
Hongze Cheng 已提交
1814 1815
int32_t tEncodeSVDropTbBatchRsp(SEncoder* pCoder, const SVDropTbBatchRsp* pRsp);
int32_t tDecodeSVDropTbBatchRsp(SDecoder* pCoder, SVDropTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
1816

H
Hongze Cheng 已提交
1817 1818
// TDMT_VND_ALTER_TABLE =====================
typedef struct {
H
Hongze Cheng 已提交
1819 1820 1821
  char*  tbName;
  int8_t action;
  char*  colName;
H
Hongze Cheng 已提交
1822
  // TSDB_ALTER_TABLE_ADD_COLUMN
H
Hongze Cheng 已提交
1823 1824 1825
  int8_t  type;
  int8_t  flags;
  int32_t bytes;
H
Hongze Cheng 已提交
1826 1827
  // TSDB_ALTER_TABLE_DROP_COLUMN
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES
H
Hongze Cheng 已提交
1828
  int32_t colModBytes;
H
Hongze Cheng 已提交
1829
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME
H
Hongze Cheng 已提交
1830
  char* colNewName;
H
Hongze Cheng 已提交
1831
  // TSDB_ALTER_TABLE_UPDATE_TAG_VAL
H
Hongze Cheng 已提交
1832 1833 1834 1835
  char*    tagName;
  int8_t   isNull;
  uint32_t nTagVal;
  uint8_t* pTagVal;
H
Hongze Cheng 已提交
1836
  // TSDB_ALTER_TABLE_UPDATE_OPTIONS
H
Hongze Cheng 已提交
1837 1838 1839 1840
  int8_t  updateTTL;
  int32_t newTTL;
  int8_t  updateComment;
  char*   newComment;
H
Hongze Cheng 已提交
1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853
} SVAlterTbReq;

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

typedef struct {
  int32_t code;
} SVAlterTbRsp;

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

S
Shengliang Guan 已提交
1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872
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 已提交
1873 1874 1875
  SMsgHead head;
} SVShowTablesReq;

S
Shengliang Guan 已提交
1876
typedef struct {
H
Hongze Cheng 已提交
1877
  SMsgHead head;
H
Haojun Liao 已提交
1878
  int32_t  id;
H
Hongze Cheng 已提交
1879 1880
} SVShowTablesFetchReq;

S
Shengliang Guan 已提交
1881
typedef struct {
H
Hongze Cheng 已提交
1882 1883 1884 1885 1886 1887 1888 1889 1890
  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 已提交
1891
typedef struct {
L
Liu Jicong 已提交
1892 1893
  int64_t consumerId;
  int32_t epoch;
L
Liu Jicong 已提交
1894
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
1895
} SMqAskEpReq;
L
Liu Jicong 已提交
1896 1897

typedef struct {
D
dapan1121 已提交
1898
  int32_t key;
L
Liu Jicong 已提交
1899 1900 1901 1902 1903
  int32_t valueLen;
  void*   value;
} SKv;

typedef struct {
D
dapan1121 已提交
1904
  int64_t tscRid;
D
dapan1121 已提交
1905
  int8_t  connType;
L
Liu Jicong 已提交
1906 1907 1908
} SClientHbKey;

typedef struct {
D
dapan1121 已提交
1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921
  int64_t tid;
  int32_t status;
} SQuerySubDesc;

typedef struct {
  char     sql[TSDB_SHOW_SQL_LEN];
  uint64_t queryId;
  int64_t  useconds;
  int64_t  stime;
  int64_t  reqRid;
  int32_t  pid;
  char     fqdn[TSDB_FQDN_LEN];
  int32_t  subPlanNum;
1922
  SArray*  subDesc;  // SArray<SQuerySubDesc>
D
dapan1121 已提交
1923 1924 1925
} SQueryDesc;

typedef struct {
1926 1927 1928 1929
  uint32_t connId;
  int32_t  pid;
  char     app[TSDB_APP_NAME_LEN];
  SArray*  queryDesc;  // SArray<SQueryDesc>
D
dapan1121 已提交
1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944 1945
} SQueryHbReqBasic;

typedef struct {
  uint32_t connId;
  uint64_t killRid;
  int32_t  totalDnodes;
  int32_t  onlineDnodes;
  int8_t   killConnection;
  int8_t   align[3];
  SEpSet   epSet;
} SQueryHbRspBasic;

typedef struct {
  SClientHbKey      connKey;
  SQueryHbReqBasic* query;
  SHashObj*         info;  // hash<Skv.key, Skv>
L
Liu Jicong 已提交
1946 1947 1948 1949 1950 1951 1952 1953
} SClientHbReq;

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

typedef struct {
D
dapan1121 已提交
1954 1955 1956 1957
  SClientHbKey      connKey;
  int32_t           status;
  SQueryHbRspBasic* query;
  SArray*           info;  // Array<Skv>
L
Liu Jicong 已提交
1958 1959 1960 1961 1962 1963 1964 1965
} SClientHbRsp;

typedef struct {
  int64_t reqId;
  int64_t rspId;
  SArray* rsps;  // SArray<SClientHbRsp>
} SClientHbBatchRsp;

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

1968 1969
static FORCE_INLINE void tFreeReqKvHash(SHashObj* info) {
  void* pIter = taosHashIterate(info, NULL);
D
dapan1121 已提交
1970 1971
  while (pIter != NULL) {
    SKv* kv = (SKv*)pIter;
wafwerar's avatar
wafwerar 已提交
1972
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
1973 1974 1975 1976
    pIter = taosHashIterate(info, pIter);
  }
}

D
dapan1121 已提交
1977 1978 1979 1980 1981 1982 1983 1984
static FORCE_INLINE void tFreeClientHbQueryDesc(void* pDesc) {
  SQueryDesc* desc = (SQueryDesc*)pDesc;
  if (desc->subDesc) {
    taosArrayDestroy(desc->subDesc);
    desc->subDesc = NULL;
  }
}

1985
static FORCE_INLINE void tFreeClientHbReq(void* pReq) {
L
Liu Jicong 已提交
1986
  SClientHbReq* req = (SClientHbReq*)pReq;
D
dapan1121 已提交
1987 1988 1989 1990 1991 1992
  if (req->query) {
    if (req->query->queryDesc) {
      taosArrayDestroyEx(req->query->queryDesc, tFreeClientHbQueryDesc);
    }
    taosMemoryFreeClear(req->query);
  }
1993

D
dapan1121 已提交
1994 1995 1996
  if (req->info) {
    tFreeReqKvHash(req->info);
    taosHashCleanup(req->info);
D
dapan1121 已提交
1997
    req->info = NULL;
D
dapan1121 已提交
1998
  }
L
Liu Jicong 已提交
1999 2000
}

S
Shengliang Guan 已提交
2001 2002
int32_t tSerializeSClientHbBatchReq(void* buf, int32_t bufLen, const SClientHbBatchReq* pReq);
int32_t tDeserializeSClientHbBatchReq(void* buf, int32_t bufLen, SClientHbBatchReq* pReq);
L
Liu Jicong 已提交
2003

D
dapan1121 已提交
2004
static FORCE_INLINE void tFreeClientHbBatchReq(void* pReq) {
2005
  SClientHbBatchReq* req = (SClientHbBatchReq*)pReq;
D
dapan1121 已提交
2006
  taosArrayDestroyEx(req->reqs, tFreeClientHbReq);
wafwerar's avatar
wafwerar 已提交
2007
  taosMemoryFree(pReq);
L
Liu Jicong 已提交
2008 2009
}

2010 2011
static FORCE_INLINE void tFreeClientKv(void* pKv) {
  SKv* kv = (SKv*)pKv;
D
dapan1121 已提交
2012
  if (kv) {
wafwerar's avatar
wafwerar 已提交
2013
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2014 2015 2016
  }
}

2017
static FORCE_INLINE void tFreeClientHbRsp(void* pRsp) {
D
dapan1121 已提交
2018
  SClientHbRsp* rsp = (SClientHbRsp*)pRsp;
D
dapan1121 已提交
2019
  taosMemoryFreeClear(rsp->query);
D
dapan1121 已提交
2020 2021 2022 2023
  if (rsp->info) taosArrayDestroyEx(rsp->info, tFreeClientKv);
}

static FORCE_INLINE void tFreeClientHbBatchRsp(void* pRsp) {
2024
  SClientHbBatchRsp* rsp = (SClientHbBatchRsp*)pRsp;
D
dapan1121 已提交
2025 2026 2027
  taosArrayDestroyEx(rsp->rsps, tFreeClientHbRsp);
}

S
Shengliang Guan 已提交
2028 2029
int32_t tSerializeSClientHbBatchRsp(void* buf, int32_t bufLen, const SClientHbBatchRsp* pBatchRsp);
int32_t tDeserializeSClientHbBatchRsp(void* buf, int32_t bufLen, SClientHbBatchRsp* pBatchRsp);
H
Hongze Cheng 已提交
2030
void    tFreeSClientHbBatchRsp(SClientHbBatchRsp* pBatchRsp);
L
Liu Jicong 已提交
2031

H
Hongze Cheng 已提交
2032
static FORCE_INLINE int32_t tEncodeSKv(SEncoder* pEncoder, const SKv* pKv) {
S
Shengliang Guan 已提交
2033 2034
  if (tEncodeI32(pEncoder, pKv->key) < 0) return -1;
  if (tEncodeI32(pEncoder, pKv->valueLen) < 0) return -1;
H
Hongze Cheng 已提交
2035
  if (tEncodeBinary(pEncoder, (uint8_t*)pKv->value, pKv->valueLen) < 0) return -1;
S
Shengliang Guan 已提交
2036
  return 0;
L
Liu Jicong 已提交
2037 2038
}

H
Hongze Cheng 已提交
2039
static FORCE_INLINE int32_t tDecodeSKv(SDecoder* pDecoder, SKv* pKv) {
S
Shengliang Guan 已提交
2040 2041
  if (tDecodeI32(pDecoder, &pKv->key) < 0) return -1;
  if (tDecodeI32(pDecoder, &pKv->valueLen) < 0) return -1;
wafwerar's avatar
wafwerar 已提交
2042
  pKv->value = taosMemoryMalloc(pKv->valueLen + 1);
S
Shengliang Guan 已提交
2043 2044 2045
  if (pKv->value == NULL) return -1;
  if (tDecodeCStrTo(pDecoder, (char*)pKv->value) < 0) return -1;
  return 0;
L
Liu Jicong 已提交
2046 2047
}

H
Hongze Cheng 已提交
2048
static FORCE_INLINE int32_t tEncodeSClientHbKey(SEncoder* pEncoder, const SClientHbKey* pKey) {
D
dapan1121 已提交
2049
  if (tEncodeI64(pEncoder, pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2050
  if (tEncodeI8(pEncoder, pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2051
  return 0;
L
Liu Jicong 已提交
2052 2053
}

H
Hongze Cheng 已提交
2054
static FORCE_INLINE int32_t tDecodeSClientHbKey(SDecoder* pDecoder, SClientHbKey* pKey) {
D
dapan1121 已提交
2055
  if (tDecodeI64(pDecoder, &pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2056
  if (tDecodeI8(pDecoder, &pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2057
  return 0;
L
Liu Jicong 已提交
2058 2059 2060 2061 2062 2063
}

typedef struct SMqHbVgInfo {
  int32_t vgId;
} SMqHbVgInfo;

S
Shengliang Guan 已提交
2064 2065
static FORCE_INLINE int32_t taosEncodeSMqVgInfo(void** buf, const SMqHbVgInfo* pVgInfo) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078
  tlen += taosEncodeFixedI32(buf, pVgInfo->vgId);
  return tlen;
}

static FORCE_INLINE void* taosDecodeSMqVgInfo(void* buf, SMqHbVgInfo* pVgInfo) {
  buf = taosDecodeFixedI32(buf, &pVgInfo->vgId);
  return buf;
}

typedef struct SMqHbTopicInfo {
  int32_t epoch;
  int64_t topicUid;
  char    name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2079
  SArray* pVgInfo;  // SArray<SMqHbVgInfo>
L
Liu Jicong 已提交
2080 2081
} SMqHbTopicInfo;

S
Shengliang Guan 已提交
2082 2083
static FORCE_INLINE int32_t taosEncodeSMqHbTopicInfoMsg(void** buf, const SMqHbTopicInfo* pTopicInfo) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2084 2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107 2108 2109 2110 2111
  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++) {
    SMqHbVgInfo* pVgInfo = (SMqHbVgInfo*)taosArrayGet(pTopicInfo->pVgInfo, i);
    tlen += taosEncodeSMqVgInfo(buf, pVgInfo);
  }
  return tlen;
}

static FORCE_INLINE void* taosDecodeSMqHbTopicInfoMsg(void* buf, SMqHbTopicInfo* pTopicInfo) {
  buf = taosDecodeFixedI32(buf, &pTopicInfo->epoch);
  buf = taosDecodeFixedI64(buf, &pTopicInfo->topicUid);
  buf = taosDecodeStringTo(buf, pTopicInfo->name);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
  pTopicInfo->pVgInfo = taosArrayInit(sz, sizeof(SMqHbVgInfo));
  for (int32_t i = 0; i < sz; i++) {
    SMqHbVgInfo vgInfo;
    buf = taosDecodeSMqVgInfo(buf, &vgInfo);
    taosArrayPush(pTopicInfo->pVgInfo, &vgInfo);
  }
  return buf;
}

typedef struct SMqHbMsg {
2112 2113 2114 2115
  int32_t status;  // ask hb endpoint
  int32_t epoch;
  int64_t consumerId;
  SArray* pTopics;  // SArray<SMqHbTopicInfo>
L
Liu Jicong 已提交
2116 2117
} SMqHbMsg;

S
Shengliang Guan 已提交
2118 2119
static FORCE_INLINE int32_t taosEncodeSMqMsg(void** buf, const SMqHbMsg* pMsg) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2120 2121 2122 2123 2124
  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 已提交
2125
  for (int32_t i = 0; i < sz; i++) {
L
Liu Jicong 已提交
2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138
    SMqHbTopicInfo* topicInfo = (SMqHbTopicInfo*)taosArrayGet(pMsg->pTopics, i);
    tlen += taosEncodeSMqHbTopicInfoMsg(buf, topicInfo);
  }
  return tlen;
}

static FORCE_INLINE void* taosDecodeSMqMsg(void* buf, SMqHbMsg* pMsg) {
  buf = taosDecodeFixedI32(buf, &pMsg->status);
  buf = taosDecodeFixedI32(buf, &pMsg->epoch);
  buf = taosDecodeFixedI64(buf, &pMsg->consumerId);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
  pMsg->pTopics = taosArrayInit(sz, sizeof(SMqHbTopicInfo));
S
Shengliang Guan 已提交
2139
  for (int32_t i = 0; i < sz; i++) {
L
Liu Jicong 已提交
2140 2141 2142 2143 2144 2145 2146
    SMqHbTopicInfo topicInfo;
    buf = taosDecodeSMqHbTopicInfoMsg(buf, &topicInfo);
    taosArrayPush(pMsg->pTopics, &topicInfo);
  }
  return buf;
}

L
Liu Jicong 已提交
2147 2148 2149 2150 2151
enum {
  TOPIC_SUB_TYPE__DB = 1,
  TOPIC_SUB_TYPE__TABLE,
};

L
Liu Jicong 已提交
2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163
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;

2164 2165 2166 2167 2168 2169
typedef struct {
  int64_t leftForVer;
  int32_t vgId;
  int64_t oldConsumerId;
  int64_t newConsumerId;
  char    subKey[TSDB_SUBSCRIBE_KEY_LEN];
L
Liu Jicong 已提交
2170 2171 2172 2173
  int8_t  subType;
  int8_t  withTbName;
  int8_t  withSchema;
  int8_t  withTag;
2174 2175 2176 2177 2178 2179 2180 2181 2182 2183
  char*   qmsg;
} 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 已提交
2184 2185 2186 2187 2188 2189 2190
  tlen += taosEncodeFixedI8(buf, pReq->subType);
  tlen += taosEncodeFixedI8(buf, pReq->withTbName);
  tlen += taosEncodeFixedI8(buf, pReq->withSchema);
  tlen += taosEncodeFixedI8(buf, pReq->withTag);
  if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    tlen += taosEncodeString(buf, pReq->qmsg);
  }
2191 2192 2193 2194 2195 2196 2197 2198 2199
  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 已提交
2200 2201 2202 2203 2204 2205 2206
  buf = taosDecodeFixedI8(buf, &pReq->subType);
  buf = taosDecodeFixedI8(buf, &pReq->withTbName);
  buf = taosDecodeFixedI8(buf, &pReq->withSchema);
  buf = taosDecodeFixedI8(buf, &pReq->withTag);
  if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    buf = taosDecodeString(buf, &pReq->qmsg);
  }
2207 2208 2209
  return (void*)buf;
}

L
Liu Jicong 已提交
2210 2211 2212 2213
typedef struct {
  int32_t vgId;
  int64_t offset;
  char    topicName[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2214
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2215 2216 2217 2218 2219
} SMqOffset;

typedef struct {
  int32_t    num;
  SMqOffset* offsets;
L
Liu Jicong 已提交
2220
} SMqCMCommitOffsetReq;
L
Liu Jicong 已提交
2221 2222 2223

typedef struct {
  int32_t reserved;
L
Liu Jicong 已提交
2224
} SMqCMCommitOffsetRsp;
L
Liu Jicong 已提交
2225

H
Hongze Cheng 已提交
2226 2227 2228 2229
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 已提交
2230

S
Shengliang Guan 已提交
2231 2232 2233 2234 2235 2236 2237
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 已提交
2238
  int32_t dstVgId;  // for stream
S
Shengliang Guan 已提交
2239 2240 2241
  int64_t interval;
  int64_t offset;
  int64_t sliding;
S
sma  
Shengliang Guan 已提交
2242 2243 2244 2245
  int32_t exprLen;        // strlen + 1
  int32_t tagsFilterLen;  // strlen + 1
  int32_t sqlLen;         // strlen + 1
  int32_t astLen;         // strlen + 1
L
Liu Jicong 已提交
2246
  char*   expr;
S
Shengliang Guan 已提交
2247
  char*   tagsFilter;
S
sma  
Shengliang Guan 已提交
2248 2249
  char*   sql;
  char*   ast;
S
Shengliang Guan 已提交
2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263
} 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);

C
Cary Xu 已提交
2264
typedef struct {
H
Hongze Cheng 已提交
2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278
  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.
  char     indexName[TSDB_INDEX_NAME_LEN];
  int32_t  exprLen;
  int32_t  tagsFilterLen;
  int64_t  indexUid;
  tb_uid_t tableUid;  // super/child/common table uid
  int64_t  interval;
  int64_t  offset;  // use unit by precision of DB
  int64_t  sliding;
  char*    expr;  // sma expression
  char*    tagsFilter;
C
Cary Xu 已提交
2279
} STSma;  // Time-range-wise SMA
C
Cary Xu 已提交
2280

2281
typedef STSma SVCreateTSmaReq;
C
Cary Xu 已提交
2282 2283

typedef struct {
C
Cary Xu 已提交
2284 2285 2286
  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 已提交
2287 2288 2289
} STSmaMsg;

typedef struct {
C
Cary Xu 已提交
2290
  int64_t indexUid;
C
Cary Xu 已提交
2291
  char    indexName[TSDB_INDEX_NAME_LEN];
C
Cary Xu 已提交
2292
} SVDropTSmaReq;
2293

C
Cary Xu 已提交
2294
typedef struct {
L
Liu Jicong 已提交
2295
  int tmp;  // TODO: to avoid compile error
C
Cary Xu 已提交
2296 2297
} SVCreateTSmaRsp, SVDropTSmaRsp;

2298
#if 0
C
Cary Xu 已提交
2299 2300 2301 2302
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);
2303
#endif
C
Cary Xu 已提交
2304

2305 2306 2307 2308
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 已提交
2309

C
Cary Xu 已提交
2310
typedef struct {
2311 2312
  int32_t number;
  STSma*  tSma;
C
Cary Xu 已提交
2313 2314
} STSmaWrapper;

C
Cary Xu 已提交
2315
static FORCE_INLINE void tdDestroyTSma(STSma* pSma) {
C
Cary Xu 已提交
2316
  if (pSma) {
wafwerar's avatar
wafwerar 已提交
2317 2318
    taosMemoryFreeClear(pSma->expr);
    taosMemoryFreeClear(pSma->tagsFilter);
C
Cary Xu 已提交
2319 2320 2321
  }
}

C
Cary Xu 已提交
2322
static FORCE_INLINE void tdDestroyTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
C
Cary Xu 已提交
2323 2324
  if (pSW) {
    if (pSW->tSma) {
C
Cary Xu 已提交
2325 2326 2327 2328
      if (deepCopy) {
        for (uint32_t i = 0; i < pSW->number; ++i) {
          tdDestroyTSma(pSW->tSma + i);
        }
C
Cary Xu 已提交
2329
      }
wafwerar's avatar
wafwerar 已提交
2330
      taosMemoryFreeClear(pSW->tSma);
C
Cary Xu 已提交
2331
    }
C
Cary Xu 已提交
2332 2333 2334
  }
}

C
Cary Xu 已提交
2335 2336 2337
static FORCE_INLINE void* tdFreeTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
  tdDestroyTSmaWrapper(pSW, deepCopy);
  taosMemoryFreeClear(pSW);
C
Cary Xu 已提交
2338
  return NULL;
C
Cary Xu 已提交
2339 2340
}

2341 2342
int32_t tEncodeSVCreateTSmaReq(SEncoder* pCoder, const SVCreateTSmaReq* pReq);
int32_t tDecodeSVCreateTSmaReq(SDecoder* pCoder, SVCreateTSmaReq* pReq);
C
Cary Xu 已提交
2343

2344 2345
int32_t tEncodeTSma(SEncoder* pCoder, const STSma* pSma);
int32_t tDecodeTSma(SDecoder* pCoder, STSma* pSma);
C
Cary Xu 已提交
2346

2347 2348 2349 2350
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 已提交
2351
  }
2352
  return 0;
C
Cary Xu 已提交
2353 2354
}

2355 2356 2357 2358
static int32_t tDecodeTSmaWrapper(SDecoder* pDecoder, STSmaWrapper* pReq) {
  if (tDecodeI32(pDecoder, &pReq->number) < 0) return -1;
  for (int32_t i = 0; i < pReq->number; ++i) {
    tDecodeTSma(pDecoder, pReq->tSma + i);
C
Cary Xu 已提交
2359
  }
2360
  return 0;
C
Cary Xu 已提交
2361
}
L
Liu Jicong 已提交
2362

dengyihao's avatar
dengyihao 已提交
2363
typedef struct {
dengyihao's avatar
dengyihao 已提交
2364
  int idx;
dengyihao's avatar
dengyihao 已提交
2365 2366 2367 2368 2369 2370
} 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 已提交
2371 2372 2373 2374 2375 2376 2377 2378
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 已提交
2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396
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);

L
Liu Jicong 已提交
2397 2398 2399 2400
typedef struct {
  int8_t  mqMsgType;
  int32_t code;
  int32_t epoch;
L
Liu Jicong 已提交
2401
  int64_t consumerId;
L
Liu Jicong 已提交
2402 2403
} SMqRspHead;

L
Liu Jicong 已提交
2404 2405 2406
typedef struct {
  SMsgHead head;
  char     subKey[TSDB_SUBSCRIBE_KEY_LEN];
2407
  int8_t   withTbName;
L
Liu Jicong 已提交
2408 2409 2410
  int32_t  epoch;
  uint64_t reqId;
  int64_t  consumerId;
2411
  int64_t  waitTime;
L
Liu Jicong 已提交
2412
  int64_t  currentOffset;
L
Liu Jicong 已提交
2413
} SMqPollReq;
L
Liu Jicong 已提交
2414

L
Liu Jicong 已提交
2415
typedef struct {
L
Liu Jicong 已提交
2416
  int32_t vgId;
L
Liu Jicong 已提交
2417
  int64_t offset;
L
Liu Jicong 已提交
2418 2419 2420
  SEpSet  epSet;
} SMqSubVgEp;

L
Liu Jicong 已提交
2421 2422 2423 2424 2425 2426 2427 2428 2429 2430 2431 2432 2433 2434 2435
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 已提交
2436
typedef struct {
L
Liu Jicong 已提交
2437 2438 2439 2440
  char           topic[TSDB_TOPIC_FNAME_LEN];
  int8_t         isSchemaAdaptive;
  SArray*        vgs;  // SArray<SMqSubVgEp>
  SSchemaWrapper schema;
L
Liu Jicong 已提交
2441 2442
} SMqSubTopicEp;

L
Liu Jicong 已提交
2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469 2470 2471 2472 2473 2474 2475 2476 2477 2478 2479
static FORCE_INLINE int32_t tEncodeSMqSubTopicEp(void** buf, const SMqSubTopicEp* pTopicEp) {
  int32_t tlen = 0;
  tlen += taosEncodeString(buf, pTopicEp->topic);
  tlen += taosEncodeFixedI8(buf, pTopicEp->isSchemaAdaptive);
  int32_t sz = taosArrayGetSize(pTopicEp->vgs);
  tlen += taosEncodeFixedI32(buf, sz);
  for (int32_t i = 0; i < sz; i++) {
    SMqSubVgEp* pVgEp = (SMqSubVgEp*)taosArrayGet(pTopicEp->vgs, i);
    tlen += tEncodeSMqSubVgEp(buf, pVgEp);
  }
  tlen += taosEncodeSSchemaWrapper(buf, &pTopicEp->schema);
  return tlen;
}

static FORCE_INLINE void* tDecodeSMqSubTopicEp(void* buf, SMqSubTopicEp* pTopicEp) {
  buf = taosDecodeStringTo(buf, pTopicEp->topic);
  buf = taosDecodeFixedI8(buf, &pTopicEp->isSchemaAdaptive);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
  pTopicEp->vgs = taosArrayInit(sz, sizeof(SMqSubVgEp));
  if (pTopicEp->vgs == NULL) {
    return NULL;
  }
  for (int32_t i = 0; i < sz; i++) {
    SMqSubVgEp vgEp;
    buf = tDecodeSMqSubVgEp(buf, &vgEp);
    taosArrayPush(pTopicEp->vgs, &vgEp);
  }
  buf = taosDecodeSSchemaWrapper(buf, &pTopicEp->schema);
  return buf;
}

static FORCE_INLINE void tDeleteSMqSubTopicEp(SMqSubTopicEp* pSubTopicEp) {
  // taosMemoryFree(pSubTopicEp->schema.pSchema);
  taosArrayDestroy(pSubTopicEp->vgs);
}

L
Liu Jicong 已提交
2480 2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512
typedef struct {
  SMqRspHead head;
  int64_t    reqOffset;
  int64_t    rspOffset;
  int32_t    skipLogNum;
  int32_t    blockNum;
  int8_t     withTbName;
  int8_t     withSchema;
  int8_t     withTag;
  SArray*    blockDataLen;    // SArray<int32_t>
  SArray*    blockData;       // SArray<SRetrieveTableRsp*>
  SArray*    blockTbName;     // SArray<char*>
  SArray*    blockSchema;     // SArray<SSchemaWrapper>
  SArray*    blockTags;       // SArray<kvrow>
  SArray*    blockTagSchema;  // SArray<kvrow>
} SMqDataBlkRsp;

static FORCE_INLINE int32_t tEncodeSMqDataBlkRsp(void** buf, const SMqDataBlkRsp* pRsp) {
  int32_t tlen = 0;
  tlen += taosEncodeFixedI64(buf, pRsp->reqOffset);
  tlen += taosEncodeFixedI64(buf, pRsp->rspOffset);
  tlen += taosEncodeFixedI32(buf, pRsp->skipLogNum);
  tlen += taosEncodeFixedI32(buf, pRsp->blockNum);
  if (pRsp->blockNum != 0) {
    tlen += taosEncodeFixedI8(buf, pRsp->withTbName);
    tlen += taosEncodeFixedI8(buf, pRsp->withSchema);
    tlen += taosEncodeFixedI8(buf, pRsp->withTag);

    for (int32_t i = 0; i < pRsp->blockNum; i++) {
      int32_t bLen = *(int32_t*)taosArrayGet(pRsp->blockDataLen, i);
      void*   data = taosArrayGetP(pRsp->blockData, i);
      tlen += taosEncodeFixedI32(buf, bLen);
      tlen += taosEncodeBinary(buf, data, bLen);
L
Liu Jicong 已提交
2513 2514 2515 2516
      if (pRsp->withSchema) {
        SSchemaWrapper* pSW = (SSchemaWrapper*)taosArrayGetP(pRsp->blockSchema, i);
        tlen += taosEncodeSSchemaWrapper(buf, pSW);
      }
L
Liu Jicong 已提交
2517 2518 2519 2520
      if (pRsp->withTbName) {
        char* tbName = (char*)taosArrayGetP(pRsp->blockTbName, i);
        tlen += taosEncodeString(buf, tbName);
      }
L
Liu Jicong 已提交
2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531
    }
  }
  return tlen;
}

static FORCE_INLINE void* tDecodeSMqDataBlkRsp(const void* buf, SMqDataBlkRsp* pRsp) {
  buf = taosDecodeFixedI64(buf, &pRsp->reqOffset);
  buf = taosDecodeFixedI64(buf, &pRsp->rspOffset);
  buf = taosDecodeFixedI32(buf, &pRsp->skipLogNum);
  buf = taosDecodeFixedI32(buf, &pRsp->blockNum);
  if (pRsp->blockNum != 0) {
L
Liu Jicong 已提交
2532 2533
    pRsp->blockData = taosArrayInit(pRsp->blockNum, sizeof(void*));
    pRsp->blockDataLen = taosArrayInit(pRsp->blockNum, sizeof(int32_t));
L
Liu Jicong 已提交
2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544
    buf = taosDecodeFixedI8(buf, &pRsp->withTbName);
    buf = taosDecodeFixedI8(buf, &pRsp->withSchema);
    buf = taosDecodeFixedI8(buf, &pRsp->withTag);

    for (int32_t i = 0; i < pRsp->blockNum; i++) {
      int32_t bLen = 0;
      void*   data = NULL;
      buf = taosDecodeFixedI32(buf, &bLen);
      buf = taosDecodeBinary(buf, &data, bLen);
      taosArrayPush(pRsp->blockDataLen, &bLen);
      taosArrayPush(pRsp->blockData, &data);
L
Liu Jicong 已提交
2545
      if (pRsp->withSchema) {
L
Liu Jicong 已提交
2546
        pRsp->blockSchema = taosArrayInit(pRsp->blockNum, sizeof(void*));
L
Liu Jicong 已提交
2547 2548 2549
        SSchemaWrapper* pSW = (SSchemaWrapper*)taosMemoryMalloc(sizeof(SSchemaWrapper));
        buf = taosDecodeSSchemaWrapper(buf, pSW);
        taosArrayPush(pRsp->blockSchema, &pSW);
L
Liu Jicong 已提交
2550 2551
      } else {
        pRsp->blockSchema = NULL;
L
Liu Jicong 已提交
2552
      }
L
Liu Jicong 已提交
2553
      if (pRsp->withTbName) {
L
Liu Jicong 已提交
2554
        pRsp->blockTbName = taosArrayInit(pRsp->blockNum, sizeof(void*));
L
Liu Jicong 已提交
2555 2556 2557
        char* name = NULL;
        buf = taosDecodeString(buf, &name);
        taosArrayPush(pRsp->blockTbName, &name);
L
Liu Jicong 已提交
2558 2559
      } else {
        pRsp->blockTbName = NULL;
L
Liu Jicong 已提交
2560
      }
L
Liu Jicong 已提交
2561 2562 2563 2564 2565
    }
  }
  return (void*)buf;
}

L
Liu Jicong 已提交
2566
typedef struct {
L
Liu Jicong 已提交
2567
  SMqRspHead head;
L
Liu Jicong 已提交
2568 2569
  char       cgroup[TSDB_CGROUP_LEN];
  SArray*    topics;  // SArray<SMqSubTopicEp>
L
Liu Jicong 已提交
2570
} SMqAskEpRsp;
L
Liu Jicong 已提交
2571

L
Liu Jicong 已提交
2572
static FORCE_INLINE int32_t tEncodeSMqAskEpRsp(void** buf, const SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
2573
  int32_t tlen = 0;
L
Liu Jicong 已提交
2574
  // tlen += taosEncodeString(buf, pRsp->cgroup);
L
Liu Jicong 已提交
2575 2576 2577 2578 2579 2580 2581 2582 2583
  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);
    tlen += tEncodeSMqSubTopicEp(buf, pVgEp);
  }
  return tlen;
}

L
Liu Jicong 已提交
2584
static FORCE_INLINE void* tDecodeSMqAskEpRsp(void* buf, SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
2585
  // buf = taosDecodeStringTo(buf, pRsp->cgroup);
L
Liu Jicong 已提交
2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597 2598
  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;
    buf = tDecodeSMqSubTopicEp(buf, &topicEp);
    taosArrayPush(pRsp->topics, &topicEp);
  }
  return buf;
}
dengyihao's avatar
dengyihao 已提交
2599

L
Liu Jicong 已提交
2600 2601 2602 2603
static FORCE_INLINE void tDeleteSMqAskEpRsp(SMqAskEpRsp* pRsp) {
  taosArrayDestroyEx(pRsp->topics, (void (*)(void*))tDeleteSMqSubTopicEp);
}

H
Hongze Cheng 已提交
2604 2605
#define TD_AUTO_CREATE_TABLE 0x1
typedef struct {
H
Hongze Cheng 已提交
2606 2607 2608 2609 2610 2611
  int64_t       suid;
  int64_t       uid;
  int32_t       sver;
  uint32_t      nData;
  uint8_t*      pData;
  SVCreateTbReq cTbReq;
H
Hongze Cheng 已提交
2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622
} SVSubmitBlk;

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

H
Hongze Cheng 已提交
2623 2624
int32_t tEncodeSVSubmitReq(SEncoder* pCoder, const SVSubmitReq* pReq);
int32_t tDecodeSVSubmitReq(SDecoder* pCoder, SVSubmitReq* pReq);
H
Hongze Cheng 已提交
2625

L
Liu Jicong 已提交
2626 2627
#pragma pack(pop)

D
dapan1121 已提交
2628 2629 2630 2631 2632
#ifdef __cplusplus
}
#endif

#endif /*_TD_COMMON_TAOS_MSG_H_*/