tmsg.h 84.8 KB
Newer Older
D
dapan1121 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef _TD_COMMON_TAOS_MSG_H_
#define _TD_COMMON_TAOS_MSG_H_

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

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

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

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

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

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

#define TMSG_SEG_CODE(TYPE) (((TYPE)&0xff00) >> 8)
L
Liu Jicong 已提交
57
#define TMSG_SEG_SEQ(TYPE)  ((TYPE)&0xff)
dengyihao's avatar
dengyihao 已提交
58 59 60
#define TMSG_INFO(TYPE) \
  (((TYPE) >= 0 && (TYPE) < TDMT_MAX) ? tMsgInfo[tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE)] : 0)
#define TMSG_INDEX(TYPE) (tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE))
D
dapan1121 已提交
61

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

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

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

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

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

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

L
Liu Jicong 已提交
125 126
#define TSDB_FILL_NONE      0
#define TSDB_FILL_NULL      1
H
Hongze Cheng 已提交
127
#define TSDB_FILL_SET_VALUE 2
L
Liu Jicong 已提交
128 129 130 131 132 133 134 135
#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 已提交
136 137 138 139
#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
140 141
#define TSDB_ALTER_USER_ENABLE          0x9
#define TSDB_ALTER_USER_SYSINFO         0xA
S
Shengliang Guan 已提交
142

D
dapan1121 已提交
143 144
#define TSDB_ALTER_USER_PRIVILEGES 0x2

H
Hongze Cheng 已提交
145
#define TSDB_KILL_MSG_LEN 30
D
dapan1121 已提交
146

D
dapan1121 已提交
147 148
#define TSDB_TABLE_NUM_UNIT 100000

L
Liu Jicong 已提交
149
#define TSDB_VN_READ_ACCCESS  ((char)0x1)
H
Hongze Cheng 已提交
150
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
L
Liu Jicong 已提交
151
#define TSDB_VN_ALL_ACCCESS   (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
D
dapan1121 已提交
152

H
Hongze Cheng 已提交
153
#define TSDB_COL_NORMAL 0x0u  // the normal column of the table
L
Liu Jicong 已提交
154 155 156 157
#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 已提交
158

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

L
Liu Jicong 已提交
164 165
#define TD_SUPER_TABLE  TSDB_SUPER_TABLE
#define TD_CHILD_TABLE  TSDB_CHILD_TABLE
S
Shengliang Guan 已提交
166 167
#define TD_NORMAL_TABLE TSDB_NORMAL_TABLE

S
Shengliang Guan 已提交
168
typedef struct {
S
Shengliang Guan 已提交
169
  int32_t vgId;
D
dapan1121 已提交
170 171
  char*   dbFName;
  char*   tbName;
D
dapan1121 已提交
172
} SBuildTableInput;
D
dapan1121 已提交
173

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

S
Shengliang Guan 已提交
181 182 183
typedef struct SField {
  char    name[TSDB_COL_NAME_LEN];
  uint8_t type;
184
  int8_t  flags;
185
  int32_t bytes;
S
Shengliang Guan 已提交
186 187
} SField;

S
Shengliang Guan 已提交
188
typedef struct SRetention {
C
Cary Xu 已提交
189 190
  int64_t freq;
  int64_t keep;
S
sma  
Shengliang Guan 已提交
191 192
  int8_t  freqUnit;
  int8_t  keepUnit;
S
Shengliang Guan 已提交
193 194
} SRetention;

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

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

S
Shengliang Guan 已提交
205
typedef struct {
D
dapan1121 已提交
206
  int32_t contLen;
L
Liu Jicong 已提交
207
  int32_t vgId;
D
dapan1121 已提交
208 209 210 211
} SMsgHead;

// Submit message for one table
typedef struct SSubmitBlk {
212
  int64_t uid;        // table unique id
L
Liu Jicong 已提交
213
  int64_t suid;       // stable id
214 215 216 217
  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 已提交
218
  int16_t padding;    // TODO just for padding here
219
  char    data[];
D
dapan1121 已提交
220 221 222
} SSubmitBlk;

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

H
Hongze Cheng 已提交
231 232 233
typedef struct {
  int32_t totalLen;
  int32_t len;
234
  STSRow* row;
H
Hongze Cheng 已提交
235 236 237
} SSubmitBlkIter;

typedef struct {
C
Cary Xu 已提交
238 239 240
  int32_t totalLen;
  int32_t len;
  // head of SSubmitBlk
C
Cary Xu 已提交
241 242 243 244 245 246
  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 已提交
247
  // head of SSubmitBlk
C
Cary Xu 已提交
248
  int32_t     numOfBlocks;
C
Cary Xu 已提交
249
  const void* pMsg;
H
Hongze Cheng 已提交
250
} SSubmitMsgIter;
C
Cary Xu 已提交
251

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

D
dapan1121 已提交
259
typedef struct {
H
Hongze Cheng 已提交
260
  int32_t code;
H
Hongze Cheng 已提交
261 262
  int8_t  hashMeta;
  int64_t uid;
D
dapan 已提交
263
  char*   tblFName;
H
Hongze Cheng 已提交
264 265
  int32_t numOfRows;
  int32_t affectedRows;
H
Hongze Cheng 已提交
266
  int64_t sver;
H
Hongze Cheng 已提交
267
} SSubmitBlkRsp;
D
dapan1121 已提交
268 269

typedef struct {
H
Hongze Cheng 已提交
270 271 272 273 274 275 276
  int32_t numOfRows;
  int32_t affectedRows;
  int32_t nBlocks;
  union {
    SArray*        pArray;
    SSubmitBlkRsp* pBlocks;
  };
S
Shengliang Guan 已提交
277
} SSubmitRsp;
D
dapan1121 已提交
278

H
Hongze Cheng 已提交
279 280
int32_t tEncodeSSubmitRsp(SEncoder* pEncoder, const SSubmitRsp* pRsp);
int32_t tDecodeSSubmitRsp(SDecoder* pDecoder, SSubmitRsp* pRsp);
H
Hongze Cheng 已提交
281
void    tFreeSSubmitRsp(SSubmitRsp* pRsp);
282

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

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

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

dengyihao's avatar
dengyihao 已提交
300
#define SSCHMEA_TYPE(s)  ((s)->type)
C
Cary Xu 已提交
301
#define SSCHMEA_FLAGS(s) ((s)->flags)
C
Cary Xu 已提交
302 303
#define SSCHMEA_COLID(s) ((s)->colId)
#define SSCHMEA_BYTES(s) ((s)->bytes)
dengyihao's avatar
dengyihao 已提交
304
#define SSCHMEA_NAME(s)  ((s)->name)
C
Cary Xu 已提交
305

H
Hongze Cheng 已提交
306 307
typedef struct {
  int32_t  nCols;
308
  int32_t  version;
H
Hongze Cheng 已提交
309 310 311
  SSchema* pSchema;
} SSchemaWrapper;

L
Liu Jicong 已提交
312 313 314 315
static FORCE_INLINE SSchemaWrapper* tCloneSSchemaWrapper(const SSchemaWrapper* pSchemaWrapper) {
  SSchemaWrapper* pSW = (SSchemaWrapper*)taosMemoryMalloc(sizeof(SSchemaWrapper));
  if (pSW == NULL) return pSW;
  pSW->nCols = pSchemaWrapper->nCols;
316
  pSW->version = pSchemaWrapper->version;
L
Liu Jicong 已提交
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 366 367 368 369 370
  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);
371
  tlen += taosEncodeVariantI32(buf, pSW->version);
L
Liu Jicong 已提交
372 373 374 375 376 377 378 379
  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);
380
  buf = taosDecodeVariantI32(buf, &pSW->version);
L
Liu Jicong 已提交
381 382 383 384 385 386 387 388 389 390 391 392 393
  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;
394
  if (tEncodeI32v(pEncoder, pSW->version) < 0) return -1;
L
Liu Jicong 已提交
395 396 397 398 399 400 401 402 403
  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;
404
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
L
Liu Jicong 已提交
405 406 407 408 409 410 411 412 413 414

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

  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 已提交
428 429
STSchema* tdGetSTSChemaFromSSChema(SSchema** pSchema, int32_t nCols);

D
dapan1121 已提交
430
typedef struct {
S
Shengliang Guan 已提交
431 432
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  igExists;
X
Xiaoyu Wang 已提交
433 434 435 436
  int64_t delay1;
  int64_t delay2;
  int64_t watermark1;
  int64_t watermark2;
S
sma  
Shengliang Guan 已提交
437
  int32_t ttl;
S
Shengliang Guan 已提交
438
  int32_t numOfColumns;
S
Shengliang Guan 已提交
439
  int32_t numOfTags;
S
Shengliang Guan 已提交
440
  int32_t numOfFuncs;
S
sma  
Shengliang Guan 已提交
441
  int32_t commentLen;
442 443
  int32_t ast1Len;
  int32_t ast2Len;
S
sma  
Shengliang Guan 已提交
444 445
  SArray* pColumns;  // array of SField
  SArray* pTags;     // array of SField
S
Shengliang Guan 已提交
446 447
  SArray* pFuncs;
  char*   pComment;
448 449
  char*   pAst1;
  char*   pAst2;
S
Shengliang Guan 已提交
450
} SMCreateStbReq;
D
dapan1121 已提交
451

S
Shengliang Guan 已提交
452 453
int32_t tSerializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
int32_t tDeserializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
454
void    tFreeSMCreateStbReq(SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
455

D
dapan1121 已提交
456 457 458
typedef struct {
  char   name[TSDB_TABLE_FNAME_LEN];
  int8_t igNotExists;
S
Shengliang Guan 已提交
459
} SMDropStbReq;
S
Shengliang Guan 已提交
460

S
Shengliang Guan 已提交
461 462
int32_t tSerializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
int32_t tDeserializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
S
Shengliang Guan 已提交
463

S
Shengliang Guan 已提交
464 465 466
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
467 468
  int32_t tagVer;
  int32_t colVer;
S
Shengliang Guan 已提交
469 470
  int32_t numOfFields;
  SArray* pFields;
X
Xiaoyu Wang 已提交
471 472 473
  int32_t ttl;
  int32_t commentLen;
  char*   comment;
S
Shengliang Guan 已提交
474
} SMAlterStbReq;
D
dapan1121 已提交
475

S
Shengliang Guan 已提交
476 477 478
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 已提交
479 480

typedef struct SEpSet {
481 482 483
  int8_t inUse;
  int8_t numOfEps;
  SEp    eps[TSDB_MAX_REPLICA];
D
dapan1121 已提交
484 485
} SEpSet;

H
Hongze Cheng 已提交
486 487
int32_t tEncodeSEpSet(SEncoder* pEncoder, const SEpSet* pEp);
int32_t tDecodeSEpSet(SDecoder* pDecoder, SEpSet* pEp);
S
Shengliang Guan 已提交
488
int32_t taosEncodeSEpSet(void** buf, const SEpSet* pEp);
489
void*   taosDecodeSEpSet(const void* buf, SEpSet* pEp);
L
Liu Jicong 已提交
490

491 492
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 已提交
493

D
dapan1121 已提交
494
typedef struct {
L
Liu Jicong 已提交
495
  int8_t  connType;
D
dapan1121 已提交
496
  int32_t pid;
S
Shengliang Guan 已提交
497 498
  char    app[TSDB_APP_NAME_LEN];
  char    db[TSDB_DB_NAME_LEN];
dengyihao's avatar
dengyihao 已提交
499 500
  char    user[TSDB_USER_LEN];
  char    passwd[TSDB_PASSWORD_LEN];
501
  int64_t startTime;
S
Shengliang Guan 已提交
502
} SConnectReq;
L
Liu Jicong 已提交
503

S
Shengliang Guan 已提交
504 505
int32_t tSerializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
int32_t tDeserializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
506

L
Liu Jicong 已提交
507
typedef struct {
508 509
  int32_t  acctId;
  int64_t  clusterId;
D
dapan1121 已提交
510
  uint32_t connId;
D
dapan 已提交
511
  int32_t  dnodeNum;
512 513 514
  int8_t   superUser;
  int8_t   connType;
  SEpSet   epSet;
D
dapan1121 已提交
515 516
  char     sVer[TSDB_VERSION_LEN];
  char     sDetailVer[128];
L
Liu Jicong 已提交
517
} SConnectRsp;
L
Liu Jicong 已提交
518

S
Shengliang Guan 已提交
519 520 521
int32_t tSerializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);
int32_t tDeserializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);

L
Liu Jicong 已提交
522 523 524 525 526 527 528 529
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
530
  int64_t maxStorage;
L
Liu Jicong 已提交
531
} SCreateAcctReq, SAlterAcctReq;
L
Liu Jicong 已提交
532

S
Shengliang Guan 已提交
533 534
int32_t tSerializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
int32_t tDeserializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
S
Shengliang Guan 已提交
535

L
Liu Jicong 已提交
536 537 538
typedef struct {
  char user[TSDB_USER_LEN];
} SDropUserReq, SDropAcctReq;
D
dapan1121 已提交
539

S
Shengliang Guan 已提交
540 541
int32_t tSerializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
int32_t tDeserializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
S
Shengliang Guan 已提交
542

D
dapan1121 已提交
543
typedef struct {
S
Shengliang Guan 已提交
544 545
  int8_t createType;
  int8_t superUser;  // denote if it is a super user or not
546 547
  int8_t sysInfo;
  int8_t enable;
S
Shengliang Guan 已提交
548
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
549
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
550 551
} SCreateUserReq;

S
Shengliang Guan 已提交
552 553
int32_t tSerializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
int32_t tDeserializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
S
Shengliang Guan 已提交
554 555 556

typedef struct {
  int8_t alterType;
S
Shengliang Guan 已提交
557
  int8_t superUser;
558 559
  int8_t sysInfo;
  int8_t enable;
S
Shengliang Guan 已提交
560
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
561
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
562 563 564
  char   dbname[TSDB_DB_FNAME_LEN];
} SAlterUserReq;

S
Shengliang Guan 已提交
565 566
int32_t tSerializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
int32_t tDeserializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
D
dapan1121 已提交
567

S
Shengliang Guan 已提交
568 569 570 571
typedef struct {
  char user[TSDB_USER_LEN];
} SGetUserAuthReq;

S
Shengliang Guan 已提交
572 573
int32_t tSerializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
int32_t tDeserializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
S
Shengliang Guan 已提交
574 575 576

typedef struct {
  char      user[TSDB_USER_LEN];
D
dapan 已提交
577
  int32_t   version;
S
Shengliang Guan 已提交
578
  int8_t    superAuth;
579 580 581
  int8_t    sysInfo;
  int8_t    enable;
  int8_t    reserve;
D
dapan 已提交
582
  SHashObj* createdDbs;
S
Shengliang Guan 已提交
583 584 585 586
  SHashObj* readDbs;
  SHashObj* writeDbs;
} SGetUserAuthRsp;

S
Shengliang Guan 已提交
587 588
int32_t tSerializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
int32_t tDeserializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
589
void    tFreeSGetUserAuthRsp(SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
590

S
Shengliang Guan 已提交
591
typedef struct {
D
dapan1121 已提交
592 593
  int16_t lowerRelOptr;
  int16_t upperRelOptr;
S
Shengliang Guan 已提交
594
  int16_t filterstr;  // denote if current column is char(binary/nchar)
D
dapan1121 已提交
595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611

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

S
Shengliang Guan 已提交
612
typedef struct {
S
Shengliang Guan 已提交
613 614 615
  int16_t numOfFilters;
  union {
    int64_t            placeholder;
H
Hongze Cheng 已提交
616
    SColumnFilterInfo* filterInfo;
D
dapan1121 已提交
617 618 619
  };
} SColumnFilterList;
/*
L
Liu Jicong 已提交
620
 * for client side struct, only column id, type, bytes are necessary
D
dapan1121 已提交
621 622
 * But for data in vnode side, we need all the following information.
 */
S
Shengliang Guan 已提交
623
typedef struct {
H
Haojun Liao 已提交
624
  union {
625 626
    col_id_t colId;
    int16_t  slotId;
H
Haojun Liao 已提交
627
  };
628
  bool output;  // TODO remove it later
H
Haojun Liao 已提交
629

L
Liu Jicong 已提交
630 631 632 633
  int16_t type;
  int32_t bytes;
  uint8_t precision;
  uint8_t scale;
D
dapan1121 已提交
634 635 636 637 638 639 640 641
} SColumnInfo;

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

typedef struct {
S
Shengliang Guan 已提交
642 643 644 645
  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 已提交
646 647
} STsBufInfo;

S
Shengliang Guan 已提交
648
typedef struct {
S
Shengliang Guan 已提交
649
  int32_t tz;  // query client timezone
D
dapan1121 已提交
650 651
  char    intervalUnit;
  char    slidingUnit;
652
  char    offsetUnit;
H
Haojun Liao 已提交
653
  int8_t  precision;
D
dapan1121 已提交
654 655 656 657 658 659
  int64_t interval;
  int64_t sliding;
  int64_t offset;
} SInterval;

typedef struct {
S
Shengliang Guan 已提交
660
  int32_t code;
D
dapan1121 已提交
661 662 663
  char    tbFName[TSDB_TABLE_FNAME_LEN];
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
664 665
} SQueryTableRsp;

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

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

D
dapan1121 已提交
670 671 672 673 674 675
typedef struct {
  SMsgHead header;
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
} STableCfgReq;

D
dapan1121 已提交
676 677 678 679 680 681 682 683 684 685 686 687
typedef struct {
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     stbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
  int32_t  numOfTags;
  int32_t  numOfColumns;
  int8_t   tableType;
  int64_t  delay1;
  int64_t  delay2;
  int64_t  watermark1;
  int64_t  watermark2;
  int32_t  ttl;
D
dapan1121 已提交
688 689 690
  SArray*  pFuncs;
  int32_t  commentLen;
  char*    pComment;
D
dapan1121 已提交
691
  SSchema* pSchemas;
D
dapan1121 已提交
692 693
  int32_t  tagsLen;
  char*    pTags;
D
dapan1121 已提交
694 695
} STableCfg;

D
dapan1121 已提交
696 697
typedef STableCfg STableCfgRsp;

L
Liu Jicong 已提交
698 699
int32_t tSerializeSTableCfgReq(void* buf, int32_t bufLen, STableCfgReq* pReq);
int32_t tDeserializeSTableCfgReq(void* buf, int32_t bufLen, STableCfgReq* pReq);
D
dapan1121 已提交
700

L
Liu Jicong 已提交
701 702 703
int32_t tSerializeSTableCfgRsp(void* buf, int32_t bufLen, STableCfgRsp* pRsp);
int32_t tDeserializeSTableCfgRsp(void* buf, int32_t bufLen, STableCfgRsp* pRsp);
void    tFreeSTableCfgRsp(STableCfgRsp* pRsp);
D
dapan1121 已提交
704

D
dapan1121 已提交
705
typedef struct {
706
  char    db[TSDB_DB_FNAME_LEN];
707
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
708 709 710 711
  int32_t numOfStables;  // single_stable
  int32_t buffer;        // MB
  int32_t pageSize;
  int32_t pages;
712
  int32_t lastRowMem;
S
Shengliang Guan 已提交
713 714 715 716
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
S
Shengliang Guan 已提交
717 718
  int32_t minRows;
  int32_t maxRows;
S
Shengliang Guan 已提交
719
  int32_t fsyncPeriod;
S
Shengliang Guan 已提交
720
  int8_t  walLevel;
S
Shengliang Guan 已提交
721 722 723
  int8_t  precision;  // time resolution
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
724
  int8_t  strict;
S
Shengliang Guan 已提交
725
  int8_t  cacheLastRow;
X
Xiaoyu Wang 已提交
726
  int8_t  schemaless;
S
Shengliang Guan 已提交
727
  int8_t  ignoreExist;
S
Shengliang Guan 已提交
728 729
  int32_t numOfRetensions;
  SArray* pRetensions;  // SRetention
S
Shengliang Guan 已提交
730
} SCreateDbReq;
S
Shengliang Guan 已提交
731

S
Shengliang Guan 已提交
732 733
int32_t tSerializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
int32_t tDeserializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
S
Shengliang Guan 已提交
734
void    tFreeSCreateDbReq(SCreateDbReq* pReq);
S
Shengliang Guan 已提交
735

S
Shengliang Guan 已提交
736
typedef struct {
737
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
738 739 740
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
741
  int32_t lastRowMem;
S
Shengliang Guan 已提交
742
  int32_t daysPerFile;
S
Shengliang Guan 已提交
743 744 745 746 747
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t fsyncPeriod;
  int8_t  walLevel;
S
Shengliang Guan 已提交
748
  int8_t  strict;
S
Shengliang Guan 已提交
749
  int8_t  cacheLastRow;
X
Xiaoyu Wang 已提交
750
  int8_t  replications;
S
Shengliang Guan 已提交
751
} SAlterDbReq;
S
Shengliang Guan 已提交
752

S
Shengliang Guan 已提交
753 754 755
int32_t tSerializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);
int32_t tDeserializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);

S
Shengliang Guan 已提交
756
typedef struct {
S
Shengliang Guan 已提交
757
  char   db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
758
  int8_t ignoreNotExists;
S
Shengliang Guan 已提交
759
} SDropDbReq;
S
Shengliang Guan 已提交
760

S
Shengliang Guan 已提交
761 762 763
int32_t tSerializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);
int32_t tDeserializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);

S
Shengliang Guan 已提交
764
typedef struct {
L
Liu Jicong 已提交
765 766
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
S
Shengliang Guan 已提交
767 768
} SDropDbRsp;

S
Shengliang Guan 已提交
769 770 771
int32_t tSerializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);
int32_t tDeserializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);

S
Shengliang Guan 已提交
772 773
typedef struct {
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
774
  int64_t dbId;
775
  int32_t vgVersion;
L
Liu Jicong 已提交
776
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
S
Shengliang Guan 已提交
777
} SUseDbReq;
S
Shengliang Guan 已提交
778

S
Shengliang Guan 已提交
779 780
int32_t tSerializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
int32_t tDeserializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
S
Shengliang Guan 已提交
781 782

typedef struct {
L
Liu Jicong 已提交
783 784 785 786 787 788
  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 已提交
789 790
} SUseDbRsp;

L
Liu Jicong 已提交
791
int32_t tSerializeSUseDbRsp(void* buf, int32_t bufLen, const SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
792
int32_t tDeserializeSUseDbRsp(void* buf, int32_t bufLen, SUseDbRsp* pRsp);
H
Hongze Cheng 已提交
793 794
int32_t tSerializeSUseDbRspImp(SEncoder* pEncoder, const SUseDbRsp* pRsp);
int32_t tDeserializeSUseDbRspImp(SDecoder* pDecoder, SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
795 796
void    tFreeSUsedbRsp(SUseDbRsp* pRsp);

D
dapan1121 已提交
797
typedef struct {
dengyihao's avatar
dengyihao 已提交
798
  char db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
799 800 801 802 803 804 805
} 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 已提交
806 807 808 809
  int32_t numOfStables;
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
D
dapan1121 已提交
810 811 812 813 814 815 816 817 818 819 820
  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 已提交
821
  int8_t  strict;
D
dapan1121 已提交
822
  int8_t  cacheLastRow;
823 824
  int32_t numOfRetensions;
  SArray* pRetensions;
wmmhello's avatar
wmmhello 已提交
825
  int8_t  schemaless;
D
dapan1121 已提交
826 827 828 829 830
} SDbCfgRsp;

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

D
dapan1121 已提交
831 832 833 834 835 836 837
typedef struct {
  int32_t rowNum;
} SQnodeListReq;

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

D
dapan1121 已提交
838 839 840 841 842 843 844
typedef struct {
  int32_t rowNum;
} SDnodeListReq;

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

D
dapan1121 已提交
845 846 847 848 849 850 851 852 853 854 855 856 857 858
typedef struct {
  int32_t useless;  // useless
} SServerVerReq;

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

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

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

D
dapan1121 已提交
859 860 861 862 863
typedef struct SQueryNodeAddr {
  int32_t nodeId;  // vgId or qnodeId
  SEpSet  epSet;
} SQueryNodeAddr;

D
dapan1121 已提交
864
typedef struct {
D
dapan1121 已提交
865 866 867 868
  SQueryNodeAddr addr;
  uint64_t       load;
} SQueryNodeLoad;

D
dapan1121 已提交
869
typedef struct {
D
dapan1121 已提交
870
  SArray* qnodeList;  // SArray<SQueryNodeLoad>
D
dapan1121 已提交
871 872 873 874 875 876
} 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 已提交
877 878 879 880 881 882 883 884
typedef struct {
  SArray* dnodeList;  // SArray<SEpSet>
} SDnodeListRsp;

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

S
Shengliang Guan 已提交
885 886 887 888 889 890 891
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 已提交
892

D
dapan 已提交
893 894 895 896 897 898 899 900
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 已提交
901
typedef struct {
S
Shengliang Guan 已提交
902
  char db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
903
} SCompactDbReq;
S
Shengliang Guan 已提交
904

S
Shengliang Guan 已提交
905 906
int32_t tSerializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
int32_t tDeserializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
D
dapan1121 已提交
907 908

typedef struct {
S
Shengliang Guan 已提交
909
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang 已提交
910
  int8_t  igExists;
S
Shengliang Guan 已提交
911 912
  int8_t  funcType;
  int8_t  scriptType;
S
Shengliang Guan 已提交
913
  int8_t  outputType;
S
Shengliang Guan 已提交
914
  int32_t outputLen;
S
Shengliang Guan 已提交
915
  int32_t bufSize;
916
  int32_t codeLen;
S
Shengliang 已提交
917
  int64_t signature;
918 919
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
920
} SCreateFuncReq;
D
dapan1121 已提交
921

S
Shengliang Guan 已提交
922 923
int32_t tSerializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
int32_t tDeserializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
924
void    tFreeSCreateFuncReq(SCreateFuncReq* pReq);
S
Shengliang Guan 已提交
925

D
dapan1121 已提交
926
typedef struct {
S
Shengliang 已提交
927 928
  char   name[TSDB_FUNC_NAME_LEN];
  int8_t igNotExists;
S
Shengliang Guan 已提交
929
} SDropFuncReq;
S
Shengliang Guan 已提交
930

S
Shengliang Guan 已提交
931 932 933
int32_t tSerializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);
int32_t tDeserializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);

S
Shengliang Guan 已提交
934 935
typedef struct {
  int32_t numOfFuncs;
D
dapan1121 已提交
936
  bool    ignoreCodeComment;
S
Shengliang Guan 已提交
937
  SArray* pFuncNames;
S
Shengliang Guan 已提交
938
} SRetrieveFuncReq;
D
dapan1121 已提交
939

S
Shengliang Guan 已提交
940 941
int32_t tSerializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
int32_t tDeserializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
942
void    tFreeSRetrieveFuncReq(SRetrieveFuncReq* pReq);
S
Shengliang Guan 已提交
943

D
dapan1121 已提交
944 945
typedef struct {
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang Guan 已提交
946 947 948 949
  int8_t  funcType;
  int8_t  scriptType;
  int8_t  outputType;
  int32_t outputLen;
D
dapan1121 已提交
950
  int32_t bufSize;
S
Shengliang 已提交
951
  int64_t signature;
S
Shengliang Guan 已提交
952 953
  int32_t commentSize;
  int32_t codeSize;
954 955
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
956
} SFuncInfo;
D
dapan1121 已提交
957 958

typedef struct {
S
Shengliang Guan 已提交
959
  int32_t numOfFuncs;
S
Shengliang Guan 已提交
960
  SArray* pFuncInfos;
S
Shengliang Guan 已提交
961
} SRetrieveFuncRsp;
D
dapan1121 已提交
962

S
Shengliang Guan 已提交
963 964
int32_t tSerializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
int32_t tDeserializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
L
Liu Jicong 已提交
965
void    tFreeSFuncInfo(SFuncInfo* pInfo);
966
void    tFreeSRetrieveFuncRsp(SRetrieveFuncRsp* pRsp);
S
Shengliang Guan 已提交
967

D
dapan1121 已提交
968
typedef struct {
S
Shengliang Guan 已提交
969
  int32_t statusInterval;
S
Shengliang Guan 已提交
970
  int64_t checkTime;                  // 1970-01-01 00:00:00.000
S
Shengliang Guan 已提交
971 972 973
  char    timezone[TD_TIMEZONE_LEN];  // tsTimezone
  char    locale[TD_LOCALE_LEN];      // tsLocale
  char    charset[TD_LOCALE_LEN];     // tsCharset
S
Shengliang Guan 已提交
974
} SClusterCfg;
D
dapan1121 已提交
975

976 977 978 979 980 981 982 983 984 985 986 987
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 已提交
988 989
typedef struct {
  int32_t vgId;
S
Shengliang Guan 已提交
990
  int32_t syncState;
S
Shengliang Guan 已提交
991 992
  int64_t numOfTables;
  int64_t numOfTimeSeries;
S
Shengliang Guan 已提交
993 994 995
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
S
Shengliang Guan 已提交
996 997 998 999 1000
  int64_t numOfSelectReqs;
  int64_t numOfInsertReqs;
  int64_t numOfInsertSuccessReqs;
  int64_t numOfBatchInsertReqs;
  int64_t numOfBatchInsertSuccessReqs;
S
Shengliang Guan 已提交
1001 1002
} SVnodeLoad;

S
Shengliang Guan 已提交
1003 1004 1005 1006
typedef struct {
  int32_t syncState;
} SMnodeLoad;

D
dapan1121 已提交
1007 1008 1009 1010 1011 1012 1013
typedef struct {
  int32_t dnodeId;
  int64_t numOfProcessedQuery;
  int64_t numOfProcessedCQuery;
  int64_t numOfProcessedFetch;
  int64_t numOfProcessedDrop;
  int64_t numOfProcessedHb;
D
dapan1121 已提交
1014
  int64_t numOfProcessedDelete;
D
dapan1121 已提交
1015 1016 1017 1018 1019 1020 1021
  int64_t cacheDataSize;
  int64_t numOfQueryInQueue;
  int64_t numOfFetchInQueue;
  int64_t timeInQueryQueue;
  int64_t timeInFetchQueue;
} SQnodeLoad;

S
Shengliang Guan 已提交
1022
typedef struct {
S
Shengliang Guan 已提交
1023 1024
  int32_t     sver;      // software version
  int64_t     dnodeVer;  // dnode table version in sdb
S
Shengliang Guan 已提交
1025
  int32_t     dnodeId;
1026
  int64_t     clusterId;
S
Shengliang Guan 已提交
1027 1028
  int64_t     rebootTime;
  int64_t     updateTime;
S
Shengliang Guan 已提交
1029
  float       numOfCores;
S
Shengliang Guan 已提交
1030
  int32_t     numOfSupportVnodes;
1031 1032
  int64_t     memTotal;
  int64_t     memAvail;
S
Shengliang Guan 已提交
1033
  char        dnodeEp[TSDB_EP_LEN];
1034
  SMnodeLoad  mload;
D
dapan1121 已提交
1035
  SQnodeLoad  qload;
S
Shengliang Guan 已提交
1036
  SClusterCfg clusterCfg;
S
Shengliang Guan 已提交
1037
  SArray*     pVloads;  // array of SVnodeLoad
S
Shengliang Guan 已提交
1038
} SStatusReq;
D
dapan1121 已提交
1039

S
Shengliang Guan 已提交
1040 1041
int32_t tSerializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
int32_t tDeserializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
S
Shengliang Guan 已提交
1042
void    tFreeSStatusReq(SStatusReq* pReq);
S
Shengliang Guan 已提交
1043

D
dapan1121 已提交
1044
typedef struct {
S
Shengliang Guan 已提交
1045
  int32_t dnodeId;
1046
  int64_t clusterId;
D
dapan1121 已提交
1047 1048 1049
} SDnodeCfg;

typedef struct {
1050 1051 1052
  int32_t id;
  int8_t  isMnode;
  SEp     ep;
D
dapan1121 已提交
1053 1054 1055
} SDnodeEp;

typedef struct {
S
Shengliang Guan 已提交
1056
  int64_t   dnodeVer;
S
Shengliang Guan 已提交
1057
  SDnodeCfg dnodeCfg;
S
Shengliang Guan 已提交
1058
  SArray*   pDnodeEps;  // Array of SDnodeEp
D
dapan1121 已提交
1059 1060
} SStatusRsp;

S
Shengliang Guan 已提交
1061 1062
int32_t tSerializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
int32_t tDeserializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
S
shm  
Shengliang Guan 已提交
1063
void    tFreeSStatusRsp(SStatusRsp* pRsp);
S
Shengliang Guan 已提交
1064 1065

typedef struct {
S
Shengliang Guan 已提交
1066 1067 1068 1069 1070
  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 已提交
1071

D
dapan1121 已提交
1072
typedef struct {
S
Shengliang Guan 已提交
1073 1074 1075
  int32_t  id;
  uint16_t port;                 // node sync Port
  char     fqdn[TSDB_FQDN_LEN];  // node FQDN
S
Shengliang Guan 已提交
1076 1077 1078
} SReplica;

typedef struct {
S
Shengliang Guan 已提交
1079
  int32_t  vgId;
1080
  char     db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1081
  int64_t  dbUid;
1082
  int32_t  vgVersion;
L
Liu Jicong 已提交
1083
  int32_t  numOfStables;
S
Shengliang Guan 已提交
1084 1085 1086
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
1087
  int32_t  lastRowMem;
S
Shengliang Guan 已提交
1088 1089 1090 1091
  int32_t  daysPerFile;
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
Shengliang Guan 已提交
1092 1093
  int32_t  minRows;
  int32_t  maxRows;
S
Shengliang Guan 已提交
1094
  int32_t  fsyncPeriod;
D
dapan1121 已提交
1095 1096
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1097
  int8_t   hashMethod;
S
Shengliang Guan 已提交
1098
  int8_t   walLevel;
S
Shengliang Guan 已提交
1099 1100
  int8_t   precision;
  int8_t   compression;
S
Shengliang Guan 已提交
1101
  int8_t   strict;
S
Shengliang Guan 已提交
1102
  int8_t   cacheLastRow;
1103 1104
  int8_t   isTsma;
  int8_t   standby;
S
Shengliang Guan 已提交
1105
  int8_t   replica;
S
Shengliang Guan 已提交
1106 1107
  int8_t   selfIndex;
  SReplica replicas[TSDB_MAX_REPLICA];
S
sma  
Shengliang Guan 已提交
1108 1109
  int32_t  numOfRetensions;
  SArray*  pRetensions;  // SRetention
1110
  void*    pTsma;
S
Shengliang Guan 已提交
1111
} SCreateVnodeReq;
D
dapan1121 已提交
1112

S
Shengliang Guan 已提交
1113 1114
int32_t tSerializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
int32_t tDeserializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
S
sma  
Shengliang Guan 已提交
1115
int32_t tFreeSCreateVnodeReq(SCreateVnodeReq* pReq);
S
Shengliang Guan 已提交
1116

S
Shengliang Guan 已提交
1117
typedef struct {
L
Liu Jicong 已提交
1118 1119 1120 1121
  int32_t vgId;
  int32_t dnodeId;
  int64_t dbUid;
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1122
} SDropVnodeReq;
S
Shengliang Guan 已提交
1123

S
Shengliang Guan 已提交
1124 1125
int32_t tSerializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
int32_t tDeserializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
S
Shengliang Guan 已提交
1126

S
Shengliang Guan 已提交
1127 1128 1129 1130 1131 1132 1133 1134 1135 1136
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 已提交
1137 1138 1139
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
1140
  int32_t  lastRowMem;
S
Shengliang Guan 已提交
1141
  int32_t  daysPerFile;
S
Shengliang Guan 已提交
1142 1143 1144
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
Shengliang Guan 已提交
1145
  int32_t  fsyncPeriod;
S
Shengliang Guan 已提交
1146 1147 1148 1149
  int8_t   walLevel;
  int8_t   strict;
  int8_t   cacheLastRow;
  int8_t   selfIndex;
1150
  int8_t   replica;
S
Shengliang Guan 已提交
1151 1152 1153 1154 1155 1156
  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 已提交
1157
typedef struct {
D
dapan1121 已提交
1158
  SMsgHead header;
D
dapan1121 已提交
1159 1160
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
S
Shengliang Guan 已提交
1161
} STableInfoReq;
D
dapan1121 已提交
1162

S
Shengliang Guan 已提交
1163 1164 1165
int32_t tSerializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);
int32_t tDeserializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);

D
dapan1121 已提交
1166
typedef struct {
S
Shengliang Guan 已提交
1167
  int8_t  metaClone;  // create local clone of the cached table meta
D
dapan1121 已提交
1168 1169 1170 1171
  int32_t numOfVgroups;
  int32_t numOfTables;
  int32_t numOfUdfs;
  char    tableNames[];
S
Shengliang Guan 已提交
1172
} SMultiTableInfoReq;
D
dapan1121 已提交
1173

H
Haojun Liao 已提交
1174
// todo refactor
D
dapan1121 已提交
1175
typedef struct SVgroupInfo {
1176 1177 1178
  int32_t  vgId;
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1179
  SEpSet   epSet;
L
Liu Jicong 已提交
1180 1181 1182 1183
  union {
    int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
    int32_t taskId;      // used in stream
  };
D
dapan1121 已提交
1184 1185
} SVgroupInfo;

D
dapan1121 已提交
1186
typedef struct {
H
Haojun Liao 已提交
1187 1188
  int32_t     numOfVgroups;
  SVgroupInfo vgroups[];
S
Shengliang Guan 已提交
1189
} SVgroupsInfo;
D
dapan1121 已提交
1190

S
Shengliang Guan 已提交
1191
typedef struct {
D
dapan1121 已提交
1192 1193 1194
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     stbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1195
  int64_t  dbId;
S
Shengliang Guan 已提交
1196 1197 1198 1199 1200 1201
  int32_t  numOfTags;
  int32_t  numOfColumns;
  int8_t   precision;
  int8_t   tableType;
  int32_t  sversion;
  int32_t  tversion;
L
Liu Jicong 已提交
1202 1203
  uint64_t suid;
  uint64_t tuid;
S
Shengliang Guan 已提交
1204
  int32_t  vgId;
S
Shengliang Guan 已提交
1205
  SSchema* pSchemas;
S
Shengliang Guan 已提交
1206
} STableMetaRsp;
D
dapan1121 已提交
1207

C
Cary Xu 已提交
1208
typedef struct {
D
dapan1121 已提交
1209 1210 1211
  STableMetaRsp* pMeta;
} SMAlterStbRsp;

C
Cary Xu 已提交
1212 1213 1214
int32_t tEncodeSMAlterStbRsp(SEncoder* pEncoder, const SMAlterStbRsp* pRsp);
int32_t tDecodeSMAlterStbRsp(SDecoder* pDecoder, SMAlterStbRsp* pRsp);
void    tFreeSMAlterStbRsp(SMAlterStbRsp* pRsp);
D
dapan1121 已提交
1215

S
Shengliang Guan 已提交
1216 1217 1218
int32_t tSerializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
int32_t tDeserializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
void    tFreeSTableMetaRsp(STableMetaRsp* pRsp);
X
Xiaoyu Wang 已提交
1219
void    tFreeSTableIndexRsp(void* info);
S
Shengliang Guan 已提交
1220 1221

typedef struct {
X
Xiaoyu Wang 已提交
1222 1223
  SArray* pMetaRsp;   // Array of STableMetaRsp
  SArray* pIndexRsp;  // Array of STableIndexRsp;
D
dapan1121 已提交
1224
} SSTbHbRsp;
S
Shengliang Guan 已提交
1225

D
dapan1121 已提交
1226 1227 1228
int32_t tSerializeSSTbHbRsp(void* buf, int32_t bufLen, SSTbHbRsp* pRsp);
int32_t tDeserializeSSTbHbRsp(void* buf, int32_t bufLen, SSTbHbRsp* pRsp);
void    tFreeSSTbHbRsp(SSTbHbRsp* pRsp);
S
Shengliang Guan 已提交
1229

S
Shengliang Guan 已提交
1230
typedef struct {
S
Shengliang Guan 已提交
1231 1232 1233 1234 1235 1236 1237 1238
  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 已提交
1239 1240 1241 1242 1243
} SMultiTableMeta;

typedef struct {
  int32_t dataLen;
  char    name[TSDB_TABLE_FNAME_LEN];
H
Hongze Cheng 已提交
1244
  char*   data;
D
dapan1121 已提交
1245 1246
} STagData;

X
Xiaoyu Wang 已提交
1247 1248 1249 1250 1251 1252 1253
typedef struct {
  int32_t useless;  // useless
} SShowVariablesReq;

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

D
dapan1121 已提交
1254
typedef struct {
1255 1256
  char name[TSDB_CONFIG_OPTION_LEN + 1];
  char value[TSDB_CONFIG_VALUE_LEN + 1];
D
dapan1121 已提交
1257 1258 1259
} SVariablesInfo;

typedef struct {
1260
  SArray* variables;  // SArray<SVariablesInfo>
D
dapan1121 已提交
1261 1262 1263 1264 1265 1266 1267
} SShowVariablesRsp;

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

void tFreeSShowVariablesRsp(SShowVariablesRsp* pRsp);

D
dapan1121 已提交
1268 1269 1270 1271 1272 1273
/*
 * sql: show tables like '%a_%'
 * payload is the query condition, e.g., '%a_%'
 * payloadLen is the length of payload
 */
typedef struct {
L
Liu Jicong 已提交
1274
  int32_t type;
1275
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1276 1277
  int32_t payloadLen;
  char*   payload;
S
Shengliang Guan 已提交
1278
} SShowReq;
D
dapan1121 已提交
1279

S
Shengliang Guan 已提交
1280 1281 1282 1283
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 已提交
1284
typedef struct {
1285
  int64_t       showId;
S
Shengliang Guan 已提交
1286
  STableMetaRsp tableMeta;
S
Shengliang Guan 已提交
1287
} SShowRsp, SVShowTablesRsp;
D
dapan1121 已提交
1288

S
Shengliang Guan 已提交
1289 1290 1291
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 已提交
1292

1293
typedef struct {
1294
  char    db[TSDB_DB_FNAME_LEN];
H
Haojun Liao 已提交
1295
  char    tb[TSDB_TABLE_NAME_LEN];
1296
  char    user[TSDB_USER_LEN];
1297 1298 1299
  int64_t showId;
} SRetrieveTableReq;

1300 1301 1302 1303 1304 1305
typedef struct SSysTableSchema {
  int8_t   type;
  col_id_t colId;
  int32_t  bytes;
} SSysTableSchema;

1306 1307 1308 1309 1310 1311 1312 1313
int32_t tSerializeSRetrieveTableReq(void* buf, int32_t bufLen, SRetrieveTableReq* pReq);
int32_t tDeserializeSRetrieveTableReq(void* buf, int32_t bufLen, SRetrieveTableReq* pReq);

typedef struct {
  int64_t useconds;
  int8_t  completed;  // all results are returned to client
  int8_t  precision;
  int8_t  compressed;
L
Liu Jicong 已提交
1314
  int8_t  streamBlockType;
1315 1316
  int32_t compLen;
  int32_t numOfRows;
1317
  int32_t numOfCols;
1318 1319
  int64_t skey;
  int64_t ekey;
1320 1321 1322
  char    data[];
} SRetrieveTableRsp;

H
Haojun Liao 已提交
1323
typedef struct {
L
Liu Jicong 已提交
1324 1325 1326 1327 1328 1329 1330 1331
  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 已提交
1332 1333
} SRetrieveMetaTableRsp;

D
dapan1121 已提交
1334
typedef struct SExplainExecInfo {
1335 1336
  double   startupCost;
  double   totalCost;
D
dapan1121 已提交
1337
  uint64_t numOfRows;
1338
  uint32_t verboseLen;
dengyihao's avatar
dengyihao 已提交
1339
  void*    verboseInfo;
D
dapan1121 已提交
1340 1341
} SExplainExecInfo;

D
dapan1121 已提交
1342
typedef struct {
D
dapan1121 已提交
1343
  int32_t           numOfPlans;
dengyihao's avatar
dengyihao 已提交
1344
  SExplainExecInfo* subplanInfo;
D
dapan1121 已提交
1345 1346
} SExplainRsp;

1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358
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 已提交
1359 1360
int32_t tSerializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
int32_t tDeserializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
D
dapan1121 已提交
1361

D
dapan1121 已提交
1362
typedef struct {
S
Shengliang Guan 已提交
1363
  char    fqdn[TSDB_FQDN_LEN];  // end point, hostname:port
1364
  int32_t port;
S
Shengliang Guan 已提交
1365
} SCreateDnodeReq;
S
Shengliang Guan 已提交
1366

S
Shengliang Guan 已提交
1367 1368 1369
int32_t tSerializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);
int32_t tDeserializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);

S
Shengliang Guan 已提交
1370 1371
typedef struct {
  int32_t dnodeId;
1372 1373
  char    fqdn[TSDB_FQDN_LEN];
  int32_t port;
S
Shengliang Guan 已提交
1374
} SDropDnodeReq;
S
Shengliang Guan 已提交
1375

S
Shengliang Guan 已提交
1376 1377 1378
int32_t tSerializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);
int32_t tDeserializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);

S
Shengliang Guan 已提交
1379 1380
typedef struct {
  int32_t dnodeId;
1381
  char    config[TSDB_DNODE_CONFIG_LEN];
S
Shengliang Guan 已提交
1382
  char    value[TSDB_DNODE_VALUE_LEN];
S
Shengliang Guan 已提交
1383
} SMCfgDnodeReq;
D
dapan1121 已提交
1384

S
Shengliang Guan 已提交
1385 1386 1387
int32_t tSerializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);
int32_t tDeserializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);

S
Shengliang Guan 已提交
1388 1389 1390 1391 1392 1393 1394 1395
typedef struct {
  char config[TSDB_DNODE_CONFIG_LEN];
  char value[TSDB_DNODE_VALUE_LEN];
} SDCfgDnodeReq;

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

S
Shengliang Guan 已提交
1396 1397
typedef struct {
  int32_t dnodeId;
dengyihao's avatar
dengyihao 已提交
1398 1399 1400
} SMCreateMnodeReq, SMDropMnodeReq, SDDropMnodeReq, SMCreateQnodeReq, SMDropQnodeReq, SDCreateQnodeReq, SDDropQnodeReq,
    SMCreateSnodeReq, SMDropSnodeReq, SDCreateSnodeReq, SDDropSnodeReq, SMCreateBnodeReq, SMDropBnodeReq,
    SDCreateBnodeReq, SDDropBnodeReq;
S
Shengliang Guan 已提交
1401

1402 1403
int32_t tSerializeSCreateDropMQSBNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
int32_t tDeserializeSCreateDropMQSBNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
S
Shengliang Guan 已提交
1404

D
dapan1121 已提交
1405
typedef struct {
S
Shengliang Guan 已提交
1406
  int8_t   replica;
S
Shengliang Guan 已提交
1407
  SReplica replicas[TSDB_MAX_REPLICA];
S
Shengliang Guan 已提交
1408
} SDCreateMnodeReq, SDAlterMnodeReq;
D
dapan1121 已提交
1409

S
Shengliang Guan 已提交
1410 1411 1412
int32_t tSerializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);
int32_t tDeserializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);

1413 1414 1415 1416 1417 1418 1419 1420
typedef struct {
  int32_t dnodeId;
  int8_t  standby;
} SSetStandbyReq;

int32_t tSerializeSSetStandbyReq(void* buf, int32_t bufLen, SSetStandbyReq* pReq);
int32_t tDeserializeSSetStandbyReq(void* buf, int32_t bufLen, SSetStandbyReq* pReq);

S
Shengliang Guan 已提交
1421
typedef struct {
X
Xiaoyu Wang 已提交
1422
  char queryStrId[TSDB_QUERY_ID_LEN];
S
Shengliang Guan 已提交
1423
} SKillQueryReq;
S
Shengliang Guan 已提交
1424

S
Shengliang Guan 已提交
1425 1426 1427
int32_t tSerializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);
int32_t tDeserializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);

S
Shengliang Guan 已提交
1428
typedef struct {
D
dapan1121 已提交
1429
  uint32_t connId;
S
Shengliang Guan 已提交
1430
} SKillConnReq;
D
dapan1121 已提交
1431

S
Shengliang Guan 已提交
1432 1433 1434
int32_t tSerializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);
int32_t tDeserializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);

S
Shengliang Guan 已提交
1435 1436 1437 1438 1439 1440 1441
typedef struct {
  int32_t transId;
} SKillTransReq;

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

X
Xiaoyu Wang 已提交
1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466
typedef struct {
  int32_t useless;  // useless
} SBalanceVgroupReq;

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

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

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

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

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

1467 1468 1469 1470 1471 1472 1473
typedef struct {
  int32_t vgId;
} SSplitVgroupReq;

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

D
dapan1121 已提交
1474 1475 1476 1477
typedef struct {
  char user[TSDB_USER_LEN];
  char spi;
  char encrypt;
1478 1479
  char secret[TSDB_PASSWORD_LEN];
  char ckey[TSDB_PASSWORD_LEN];
S
Shengliang Guan 已提交
1480
} SAuthReq, SAuthRsp;
D
dapan1121 已提交
1481

S
Shengliang Guan 已提交
1482 1483 1484
int32_t tSerializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);
int32_t tDeserializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);

D
dapan1121 已提交
1485
typedef struct {
S
Shengliang Guan 已提交
1486
  int32_t statusCode;
S
Shengliang Guan 已提交
1487
  char    details[1024];
S
Shengliang Guan 已提交
1488 1489 1490 1491
} SServerStatusRsp;

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

1493 1494 1495 1496 1497 1498 1499
/**
 * 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 已提交
1500
typedef struct SSubQueryMsg {
D
dapan1121 已提交
1501
  SMsgHead header;
D
dapan1121 已提交
1502
  uint64_t sId;
H
Hongze Cheng 已提交
1503 1504
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1505
  int64_t  refId;
D
dapan1121 已提交
1506
  int32_t  execId;
D
dapan1121 已提交
1507
  int8_t   taskType;
D
dapan1121 已提交
1508
  int8_t   explain;
1509
  uint32_t sqlLen;  // the query sql,
1510
  uint32_t phyLen;
H
Hongze Cheng 已提交
1511
  char     msg[];
D
dapan1121 已提交
1512
} SSubQueryMsg;
D
dapan 已提交
1513

1514 1515 1516 1517 1518 1519 1520
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
} SSinkDataReq;

D
dapan1121 已提交
1521 1522 1523 1524 1525
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1526
  int32_t  execId;
D
dapan1121 已提交
1527 1528
} SQueryContinueReq;

S
Shengliang Guan 已提交
1529
typedef struct {
D
dapan1121 已提交
1530
  SMsgHead header;
D
dapan1121 已提交
1531
  uint64_t sId;
H
Hongze Cheng 已提交
1532 1533
  uint64_t queryId;
  uint64_t taskId;
S
Shengliang Guan 已提交
1534
} SResReadyReq;
D
dapan 已提交
1535

S
Shengliang Guan 已提交
1536
typedef struct {
D
dapan1121 已提交
1537
  int32_t code;
L
Liu Jicong 已提交
1538
  char    tbFName[TSDB_TABLE_FNAME_LEN];
1539 1540
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
1541 1542
} SResReadyRsp;

S
Shengliang Guan 已提交
1543
typedef struct {
D
dapan1121 已提交
1544
  SMsgHead header;
D
dapan1121 已提交
1545
  uint64_t sId;
H
Hongze Cheng 已提交
1546 1547
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1548
  int32_t  execId;
S
Shengliang Guan 已提交
1549
} SResFetchReq;
D
dapan 已提交
1550

S
Shengliang Guan 已提交
1551
typedef struct {
D
dapan1121 已提交
1552
  SMsgHead header;
D
dapan1121 已提交
1553
  uint64_t sId;
S
Shengliang Guan 已提交
1554
} SSchTasksStatusReq;
D
dapan1121 已提交
1555

S
Shengliang Guan 已提交
1556
typedef struct {
H
Hongze Cheng 已提交
1557 1558
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1559
  int64_t  refId;
D
dapan1121 已提交
1560
  int32_t  execId;
H
Hongze Cheng 已提交
1561
  int8_t   status;
D
dapan1121 已提交
1562 1563
} STaskStatus;

S
Shengliang Guan 已提交
1564
typedef struct {
L
Liu Jicong 已提交
1565 1566
  int64_t refId;
  SArray* taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1567 1568
} SSchedulerStatusRsp;

D
dapan1121 已提交
1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583
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 已提交
1584
  SArray*        taskAction;  // SArray<STaskAction>
D
dapan1121 已提交
1585 1586
} SSchedulerHbReq;

L
Liu Jicong 已提交
1587 1588 1589
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 已提交
1590 1591 1592

typedef struct {
  SQueryNodeEpId epId;
L
Liu Jicong 已提交
1593
  SArray*        taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1594 1595
} SSchedulerHbRsp;

L
Liu Jicong 已提交
1596 1597 1598
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 已提交
1599

S
Shengliang Guan 已提交
1600
typedef struct {
D
dapan1121 已提交
1601
  SMsgHead header;
D
dapan1121 已提交
1602
  uint64_t sId;
H
Hongze Cheng 已提交
1603 1604
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1605
  int64_t  refId;
D
dapan1121 已提交
1606
  int32_t  execId;
S
Shengliang Guan 已提交
1607
} STaskCancelReq;
D
dapan1121 已提交
1608

S
Shengliang Guan 已提交
1609
typedef struct {
D
dapan1121 已提交
1610 1611 1612
  int32_t code;
} STaskCancelRsp;

S
Shengliang Guan 已提交
1613
typedef struct {
D
dapan1121 已提交
1614
  SMsgHead header;
D
dapan1121 已提交
1615
  uint64_t sId;
H
Hongze Cheng 已提交
1616 1617
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1618
  int64_t  refId;
D
dapan1121 已提交
1619
  int32_t  execId;
S
Shengliang Guan 已提交
1620
} STaskDropReq;
D
dapan1121 已提交
1621

S
Shengliang Guan 已提交
1622
typedef struct {
D
dapan1121 已提交
1623 1624 1625
  int32_t code;
} STaskDropRsp;

1626 1627 1628
#define STREAM_TRIGGER_AT_ONCE      1
#define STREAM_TRIGGER_WINDOW_CLOSE 2
#define STREAM_TRIGGER_MAX_DELAY    3
X
Xiaoyu Wang 已提交
1629

L
Liu Jicong 已提交
1630
typedef struct {
L
Liu Jicong 已提交
1631
  char    name[TSDB_STREAM_FNAME_LEN];
L
Liu Jicong 已提交
1632 1633
  char    sourceDB[TSDB_DB_FNAME_LEN];
  char    targetStbFullName[TSDB_TABLE_FNAME_LEN];
1634 1635 1636 1637
  int8_t  igExists;
  char*   sql;
  char*   ast;
  int8_t  triggerType;
1638
  int64_t maxDelay;
X
Xiaoyu Wang 已提交
1639
  int64_t watermark;
1640
  int8_t  igExpired;
L
Liu Jicong 已提交
1641
} SCMCreateStreamReq;
L
Liu Jicong 已提交
1642

L
Liu Jicong 已提交
1643 1644 1645 1646 1647 1648 1649 1650
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 已提交
1651
typedef struct {
L
Liu Jicong 已提交
1652
  char    name[TSDB_STREAM_FNAME_LEN];
L
Liu Jicong 已提交
1653 1654 1655 1656 1657 1658 1659 1660 1661
  int64_t streamId;
  char*   sql;
  char*   executorMsg;
} SMVCreateStreamReq, SMSCreateStreamReq;

typedef struct {
  int64_t streamId;
} SMVCreateStreamRsp, SMSCreateStreamRsp;

L
Liu Jicong 已提交
1662 1663 1664 1665 1666 1667
enum {
  TOPIC_SUB_TYPE__DB = 1,
  TOPIC_SUB_TYPE__TABLE,
  TOPIC_SUB_TYPE__COLUMN,
};

L
Liu Jicong 已提交
1668
typedef struct {
L
Liu Jicong 已提交
1669 1670
  char   name[TSDB_TOPIC_FNAME_LEN];  // accout.topic
  int8_t igExists;
L
Liu Jicong 已提交
1671
  int8_t subType;
L
Liu Jicong 已提交
1672
  int8_t withMeta;
L
Liu Jicong 已提交
1673
  char*  sql;
L
Liu Jicong 已提交
1674
  char   subDbName[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1675 1676 1677 1678
  union {
    char* ast;
    char  subStbName[TSDB_TABLE_FNAME_LEN];
  };
L
Liu Jicong 已提交
1679 1680 1681 1682 1683
} 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 已提交
1684 1685 1686

typedef struct {
  int64_t topicId;
L
Liu Jicong 已提交
1687
} SCMCreateTopicRsp;
L
Liu Jicong 已提交
1688

L
Liu Jicong 已提交
1689 1690
int32_t tSerializeSCMCreateTopicRsp(void* buf, int32_t bufLen, const SCMCreateTopicRsp* pRsp);
int32_t tDeserializeSCMCreateTopicRsp(void* buf, int32_t bufLen, SCMCreateTopicRsp* pRsp);
L
Liu Jicong 已提交
1691

1692 1693
typedef struct {
  int64_t consumerId;
L
Liu Jicong 已提交
1694
} SMqConsumerLostMsg, SMqConsumerRecoverMsg;
1695

L
Liu Jicong 已提交
1696 1697
typedef struct {
  int64_t consumerId;
1698
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
1699
  char    clientId[256];
L
Liu Jicong 已提交
1700
  SArray* topicNames;  // SArray<char**>
L
Liu Jicong 已提交
1701 1702
} SCMSubscribeReq;

S
Shengliang Guan 已提交
1703 1704
static FORCE_INLINE int32_t tSerializeSCMSubscribeReq(void** buf, const SCMSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1705
  tlen += taosEncodeFixedI64(buf, pReq->consumerId);
1706
  tlen += taosEncodeString(buf, pReq->cgroup);
L
Liu Jicong 已提交
1707
  tlen += taosEncodeString(buf, pReq->clientId);
L
Liu Jicong 已提交
1708

L
Liu Jicong 已提交
1709 1710 1711 1712
  int32_t topicNum = taosArrayGetSize(pReq->topicNames);
  tlen += taosEncodeFixedI32(buf, topicNum);

  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
1713
    tlen += taosEncodeString(buf, (char*)taosArrayGetP(pReq->topicNames, i));
L
Liu Jicong 已提交
1714
  }
L
Liu Jicong 已提交
1715 1716 1717 1718 1719
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeReq(void* buf, SCMSubscribeReq* pReq) {
  buf = taosDecodeFixedI64(buf, &pReq->consumerId);
1720
  buf = taosDecodeStringTo(buf, pReq->cgroup);
L
Liu Jicong 已提交
1721
  buf = taosDecodeStringTo(buf, pReq->clientId);
L
Liu Jicong 已提交
1722 1723 1724 1725 1726 1727

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

  pReq->topicNames = taosArrayInit(topicNum, sizeof(void*));
  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
1728
    char* name;
L
Liu Jicong 已提交
1729 1730
    buf = taosDecodeString(buf, &name);
    taosArrayPush(pReq->topicNames, &name);
L
Liu Jicong 已提交
1731
  }
L
Liu Jicong 已提交
1732 1733 1734
  return buf;
}

L
Liu Jicong 已提交
1735
typedef struct SMqSubTopic {
L
Liu Jicong 已提交
1736
  int32_t vgId;
L
Liu Jicong 已提交
1737 1738 1739 1740 1741
  int64_t topicId;
  SEpSet  epSet;
} SMqSubTopic;

typedef struct {
L
Liu Jicong 已提交
1742
  int32_t     topicNum;
L
Liu Jicong 已提交
1743
  SMqSubTopic topics[];
L
Liu Jicong 已提交
1744 1745
} SCMSubscribeRsp;

S
Shengliang Guan 已提交
1746 1747
static FORCE_INLINE int32_t tSerializeSCMSubscribeRsp(void** buf, const SCMSubscribeRsp* pRsp) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1748
  tlen += taosEncodeFixedI32(buf, pRsp->topicNum);
S
Shengliang Guan 已提交
1749
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
1750 1751 1752 1753
    tlen += taosEncodeFixedI32(buf, pRsp->topics[i].vgId);
    tlen += taosEncodeFixedI64(buf, pRsp->topics[i].topicId);
    tlen += taosEncodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
1754 1755 1756 1757
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeRsp(void* buf, SCMSubscribeRsp* pRsp) {
L
Liu Jicong 已提交
1758
  buf = taosDecodeFixedI32(buf, &pRsp->topicNum);
S
Shengliang Guan 已提交
1759
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
1760 1761 1762 1763
    buf = taosDecodeFixedI32(buf, &pRsp->topics[i].vgId);
    buf = taosDecodeFixedI64(buf, &pRsp->topics[i].topicId);
    buf = taosDecodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
1764 1765 1766 1767 1768 1769 1770 1771
  return buf;
}

typedef struct {
  int64_t topicId;
  int64_t consumerId;
  int64_t consumerGroupId;
  int64_t offset;
L
Liu Jicong 已提交
1772 1773 1774
  char*   sql;
  char*   logicalPlan;
  char*   physicalPlan;
L
Liu Jicong 已提交
1775 1776
} SMVSubscribeReq;

S
Shengliang Guan 已提交
1777 1778
static FORCE_INLINE int32_t tSerializeSMVSubscribeReq(void** buf, SMVSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799
  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 已提交
1800
typedef struct {
1801 1802 1803 1804
  char    key[TSDB_SUBSCRIBE_KEY_LEN];
  SArray* lostConsumers;     // SArray<int64_t>
  SArray* removedConsumers;  // SArray<int64_t>
  SArray* newConsumers;      // SArray<int64_t>
L
Liu Jicong 已提交
1805
} SMqRebInfo;
L
Liu Jicong 已提交
1806

L
Liu Jicong 已提交
1807 1808 1809
static FORCE_INLINE SMqRebInfo* tNewSMqRebSubscribe(const char* key) {
  SMqRebInfo* pRebInfo = (SMqRebInfo*)taosMemoryCalloc(1, sizeof(SMqRebInfo));
  if (pRebInfo == NULL) {
L
Liu Jicong 已提交
1810
    return NULL;
L
Liu Jicong 已提交
1811
  }
L
Liu Jicong 已提交
1812 1813 1814
  strcpy(pRebInfo->key, key);
  pRebInfo->lostConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->lostConsumers == NULL) {
L
Liu Jicong 已提交
1815 1816
    goto _err;
  }
L
Liu Jicong 已提交
1817 1818
  pRebInfo->removedConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->removedConsumers == NULL) {
L
Liu Jicong 已提交
1819 1820
    goto _err;
  }
L
Liu Jicong 已提交
1821 1822
  pRebInfo->newConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->newConsumers == NULL) {
L
Liu Jicong 已提交
1823 1824
    goto _err;
  }
L
Liu Jicong 已提交
1825
  return pRebInfo;
L
Liu Jicong 已提交
1826
_err:
L
Liu Jicong 已提交
1827 1828 1829 1830
  taosArrayDestroy(pRebInfo->lostConsumers);
  taosArrayDestroy(pRebInfo->removedConsumers);
  taosArrayDestroy(pRebInfo->newConsumers);
  taosMemoryFreeClear(pRebInfo);
L
Liu Jicong 已提交
1831 1832 1833
  return NULL;
}

L
Liu Jicong 已提交
1834 1835
// 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 已提交
1836
typedef struct {
1837
  SHashObj* rebSubHash;  // SHashObj<key, SMqRebSubscribe>
L
Liu Jicong 已提交
1838 1839
} SMqDoRebalanceMsg;

L
Liu Jicong 已提交
1840
typedef struct {
L
Liu Jicong 已提交
1841
  int64_t status;
L
Liu Jicong 已提交
1842 1843
} SMVSubscribeRsp;

L
Liu Jicong 已提交
1844
typedef struct {
1845
  char   name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
1846
  int8_t igNotExists;
S
Shengliang Guan 已提交
1847 1848
} SMDropTopicReq;

S
Shengliang Guan 已提交
1849
int32_t tSerializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
S
Shengliang Guan 已提交
1850
int32_t tDeserializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
L
Liu Jicong 已提交
1851

1852 1853 1854 1855 1856 1857 1858 1859 1860
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 已提交
1861 1862 1863 1864
typedef struct {
  int8_t reserved;
} SMDropCgroupRsp;

L
Liu Jicong 已提交
1865 1866 1867 1868
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
  SSchema schema;
S
Shengliang Guan 已提交
1869
} SAlterTopicReq;
L
Liu Jicong 已提交
1870 1871 1872 1873

typedef struct {
  SMsgHead head;
  char     name[TSDB_TABLE_FNAME_LEN];
L
Liu Jicong 已提交
1874
  int64_t  tuid;
L
Liu Jicong 已提交
1875 1876 1877 1878 1879
  int32_t  sverson;
  int32_t  execLen;
  char*    executor;
  int32_t  sqlLen;
  char*    sql;
S
Shengliang Guan 已提交
1880
} SDCreateTopicReq;
L
Liu Jicong 已提交
1881 1882 1883 1884

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

C
Cary Xu 已提交
1888
typedef struct {
1889 1890 1891 1892
  int64_t maxdelay[2];
  int64_t watermark[2];
  int32_t qmsgLen[2];
  char*   qmsg[2];  // pAst:qmsg:SRetention => trigger aggr task1/2
C
Cary Xu 已提交
1893 1894
} SRSmaParam;

H
Hongze Cheng 已提交
1895 1896
int32_t tEncodeSRSmaParam(SEncoder* pCoder, const SRSmaParam* pRSmaParam);
int32_t tDecodeSRSmaParam(SDecoder* pCoder, SRSmaParam* pRSmaParam);
H
Hongze Cheng 已提交
1897

H
Hongze Cheng 已提交
1898
// TDMT_VND_CREATE_STB ==============
H
Hongze Cheng 已提交
1899
typedef struct SVCreateStbReq {
H
Hongze Cheng 已提交
1900
  char*          name;
H
Hongze Cheng 已提交
1901 1902
  tb_uid_t       suid;
  int8_t         rollup;
1903
  SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
1904
  SSchemaWrapper schemaTag;
C
Cary Xu 已提交
1905
  SRSmaParam     rsmaParam;
H
Hongze Cheng 已提交
1906 1907
} SVCreateStbReq;

H
Hongze Cheng 已提交
1908 1909
int tEncodeSVCreateStbReq(SEncoder* pCoder, const SVCreateStbReq* pReq);
int tDecodeSVCreateStbReq(SDecoder* pCoder, SVCreateStbReq* pReq);
H
Hongze Cheng 已提交
1910

H
Hongze Cheng 已提交
1911
// TDMT_VND_DROP_STB ==============
H
Hongze Cheng 已提交
1912
typedef struct SVDropStbReq {
H
Hongze Cheng 已提交
1913 1914
  char*    name;
  tb_uid_t suid;
H
Hongze Cheng 已提交
1915 1916
} SVDropStbReq;

H
Hongze Cheng 已提交
1917 1918
int32_t tEncodeSVDropStbReq(SEncoder* pCoder, const SVDropStbReq* pReq);
int32_t tDecodeSVDropStbReq(SDecoder* pCoder, SVDropStbReq* pReq);
H
Hongze Cheng 已提交
1919

H
Hongze Cheng 已提交
1920
// TDMT_VND_CREATE_TABLE ==============
H
Hongze Cheng 已提交
1921
#define TD_CREATE_IF_NOT_EXISTS 0x1
H
more  
Hongze Cheng 已提交
1922
typedef struct SVCreateTbReq {
H
Hongze Cheng 已提交
1923
  int32_t  flags;
H
Hongze Cheng 已提交
1924
  char*    name;
H
Hongze Cheng 已提交
1925 1926 1927
  tb_uid_t uid;
  int64_t  ctime;
  int32_t  ttl;
wmmhello's avatar
wmmhello 已提交
1928 1929
  int32_t  commentLen;
  char*    comment;
H
Hongze Cheng 已提交
1930
  int8_t   type;
C
Cary Xu 已提交
1931 1932
  union {
    struct {
H
Hongze Cheng 已提交
1933 1934
      tb_uid_t suid;
      uint8_t* pTag;
H
Hongze Cheng 已提交
1935
    } ctb;
H
more  
Hongze Cheng 已提交
1936
    struct {
1937
      SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
1938
    } ntb;
H
more  
Hongze Cheng 已提交
1939
  };
H
Hongze Cheng 已提交
1940
} SVCreateTbReq;
H
Hongze Cheng 已提交
1941

H
Hongze Cheng 已提交
1942 1943
int tEncodeSVCreateTbReq(SEncoder* pCoder, const SVCreateTbReq* pReq);
int tDecodeSVCreateTbReq(SDecoder* pCoder, SVCreateTbReq* pReq);
H
Hongze Cheng 已提交
1944

C
Cary Xu 已提交
1945 1946
static FORCE_INLINE void tdDestroySVCreateTbReq(SVCreateTbReq* req) {
  taosMemoryFreeClear(req->name);
wmmhello's avatar
wmmhello 已提交
1947
  taosMemoryFreeClear(req->comment);
C
Cary Xu 已提交
1948 1949 1950 1951 1952 1953 1954
  if (req->type == TSDB_CHILD_TABLE) {
    taosMemoryFreeClear(req->ctb.pTag);
  } else if (req->type == TSDB_NORMAL_TABLE) {
    taosMemoryFreeClear(req->ntb.schemaRow.pSchema);
  }
}

H
more  
Hongze Cheng 已提交
1955
typedef struct {
H
Hongze Cheng 已提交
1956 1957 1958 1959 1960
  int32_t nReqs;
  union {
    SVCreateTbReq* pReqs;
    SArray*        pArray;
  };
H
more  
Hongze Cheng 已提交
1961
} SVCreateTbBatchReq;
H
more  
Hongze Cheng 已提交
1962

H
Hongze Cheng 已提交
1963 1964
int tEncodeSVCreateTbBatchReq(SEncoder* pCoder, const SVCreateTbBatchReq* pReq);
int tDecodeSVCreateTbBatchReq(SDecoder* pCoder, SVCreateTbBatchReq* pReq);
H
more  
Hongze Cheng 已提交
1965

H
more  
Hongze Cheng 已提交
1966
typedef struct {
D
dapan1121 已提交
1967
  int32_t code;
S
Shengliang Guan 已提交
1968
} SVCreateTbRsp, SVUpdateTbRsp;
H
more  
Hongze Cheng 已提交
1969

H
Hongze Cheng 已提交
1970 1971
int tEncodeSVCreateTbRsp(SEncoder* pCoder, const SVCreateTbRsp* pRsp);
int tDecodeSVCreateTbRsp(SDecoder* pCoder, SVCreateTbRsp* pRsp);
H
Hongze Cheng 已提交
1972

S
Shengliang Guan 已提交
1973 1974
int32_t tSerializeSVCreateTbReq(void** buf, SVCreateTbReq* pReq);
void*   tDeserializeSVCreateTbReq(void* buf, SVCreateTbReq* pReq);
H
more  
Hongze Cheng 已提交
1975

H
more  
Hongze Cheng 已提交
1976
typedef struct {
H
Hongze Cheng 已提交
1977 1978 1979 1980 1981
  int32_t nRsps;
  union {
    SVCreateTbRsp* pRsps;
    SArray*        pArray;
  };
S
Shengliang Guan 已提交
1982
} SVCreateTbBatchRsp;
H
more  
Hongze Cheng 已提交
1983

H
Hongze Cheng 已提交
1984 1985
int tEncodeSVCreateTbBatchRsp(SEncoder* pCoder, const SVCreateTbBatchRsp* pRsp);
int tDecodeSVCreateTbBatchRsp(SDecoder* pCoder, SVCreateTbBatchRsp* pRsp);
H
Hongze Cheng 已提交
1986

L
Liu Jicong 已提交
1987 1988
int32_t tSerializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
int32_t tDeserializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
1989

H
Hongze Cheng 已提交
1990
// TDMT_VND_DROP_TABLE =================
S
Shengliang Guan 已提交
1991
typedef struct {
H
Hongze Cheng 已提交
1992 1993
  char*  name;
  int8_t igNotExists;
S
Shengliang Guan 已提交
1994 1995 1996
} SVDropTbReq;

typedef struct {
H
Hongze Cheng 已提交
1997
  int32_t code;
S
Shengliang Guan 已提交
1998 1999
} SVDropTbRsp;

H
Hongze Cheng 已提交
2000 2001 2002 2003 2004 2005 2006 2007
typedef struct {
  int32_t nReqs;
  union {
    SVDropTbReq* pReqs;
    SArray*      pArray;
  };
} SVDropTbBatchReq;

H
Hongze Cheng 已提交
2008 2009
int32_t tEncodeSVDropTbBatchReq(SEncoder* pCoder, const SVDropTbBatchReq* pReq);
int32_t tDecodeSVDropTbBatchReq(SDecoder* pCoder, SVDropTbBatchReq* pReq);
H
Hongze Cheng 已提交
2010 2011 2012 2013 2014 2015 2016 2017 2018

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

H
Hongze Cheng 已提交
2019 2020
int32_t tEncodeSVDropTbBatchRsp(SEncoder* pCoder, const SVDropTbBatchRsp* pRsp);
int32_t tDecodeSVDropTbBatchRsp(SDecoder* pCoder, SVDropTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
2021

H
Hongze Cheng 已提交
2022 2023
// TDMT_VND_ALTER_TABLE =====================
typedef struct {
H
Hongze Cheng 已提交
2024 2025 2026
  char*  tbName;
  int8_t action;
  char*  colName;
H
Hongze Cheng 已提交
2027
  // TSDB_ALTER_TABLE_ADD_COLUMN
H
Hongze Cheng 已提交
2028 2029 2030
  int8_t  type;
  int8_t  flags;
  int32_t bytes;
H
Hongze Cheng 已提交
2031 2032
  // TSDB_ALTER_TABLE_DROP_COLUMN
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES
H
Hongze Cheng 已提交
2033
  int32_t colModBytes;
H
Hongze Cheng 已提交
2034
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME
H
Hongze Cheng 已提交
2035
  char* colNewName;
H
Hongze Cheng 已提交
2036
  // TSDB_ALTER_TABLE_UPDATE_TAG_VAL
H
Hongze Cheng 已提交
2037 2038 2039 2040
  char*    tagName;
  int8_t   isNull;
  uint32_t nTagVal;
  uint8_t* pTagVal;
H
Hongze Cheng 已提交
2041
  // TSDB_ALTER_TABLE_UPDATE_OPTIONS
H
Hongze Cheng 已提交
2042 2043
  int8_t  updateTTL;
  int32_t newTTL;
wmmhello's avatar
wmmhello 已提交
2044
  int32_t newCommentLen;
H
Hongze Cheng 已提交
2045
  char*   newComment;
H
Hongze Cheng 已提交
2046 2047 2048 2049 2050 2051
} SVAlterTbReq;

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

typedef struct {
D
dapan1121 已提交
2052 2053
  int32_t        code;
  STableMetaRsp* pMeta;
H
Hongze Cheng 已提交
2054 2055 2056 2057 2058 2059
} SVAlterTbRsp;

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

S
Shengliang Guan 已提交
2060 2061 2062 2063 2064 2065 2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078
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 已提交
2079 2080 2081
  SMsgHead head;
} SVShowTablesReq;

S
Shengliang Guan 已提交
2082
typedef struct {
H
Hongze Cheng 已提交
2083
  SMsgHead head;
H
Haojun Liao 已提交
2084
  int32_t  id;
H
Hongze Cheng 已提交
2085 2086
} SVShowTablesFetchReq;

S
Shengliang Guan 已提交
2087
typedef struct {
H
Hongze Cheng 已提交
2088 2089 2090 2091 2092 2093 2094 2095 2096
  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 已提交
2097
typedef struct {
L
Liu Jicong 已提交
2098 2099
  int64_t consumerId;
  int32_t epoch;
L
Liu Jicong 已提交
2100
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2101
} SMqAskEpReq;
L
Liu Jicong 已提交
2102 2103

typedef struct {
D
dapan1121 已提交
2104
  int32_t key;
L
Liu Jicong 已提交
2105 2106 2107 2108 2109
  int32_t valueLen;
  void*   value;
} SKv;

typedef struct {
D
dapan1121 已提交
2110
  int64_t tscRid;
D
dapan1121 已提交
2111
  int8_t  connType;
L
Liu Jicong 已提交
2112 2113 2114
} SClientHbKey;

typedef struct {
D
dapan1121 已提交
2115
  int64_t tid;
2116
  char    status[TSDB_JOB_STATUS_LEN];
D
dapan1121 已提交
2117 2118 2119 2120 2121 2122
} SQuerySubDesc;

typedef struct {
  char     sql[TSDB_SHOW_SQL_LEN];
  uint64_t queryId;
  int64_t  useconds;
L
Liu Jicong 已提交
2123
  int64_t  stime;  // timestamp precision ms
D
dapan1121 已提交
2124
  int64_t  reqRid;
2125
  bool     stableQuery;
D
dapan1121 已提交
2126 2127
  char     fqdn[TSDB_FQDN_LEN];
  int32_t  subPlanNum;
2128
  SArray*  subDesc;  // SArray<SQuerySubDesc>
D
dapan1121 已提交
2129 2130 2131
} SQueryDesc;

typedef struct {
2132 2133
  uint32_t connId;
  SArray*  queryDesc;  // SArray<SQueryDesc>
D
dapan1121 已提交
2134 2135 2136 2137 2138 2139 2140 2141 2142 2143
} SQueryHbReqBasic;

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

D
dapan1121 已提交
2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167
typedef struct SAppClusterSummary {
  uint64_t numOfInsertsReq;
  uint64_t numOfInsertRows;
  uint64_t insertElapsedTime;
  uint64_t insertBytes;  // submit to tsdb since launched.

  uint64_t fetchBytes;
  uint64_t queryElapsedTime;
  uint64_t numOfSlowQueries;
  uint64_t totalRequests;
  uint64_t currentRequests;  // the number of SRequestObj
} SAppClusterSummary;

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

D
dapan1121 已提交
2168 2169
typedef struct {
  SClientHbKey      connKey;
D
dapan1121 已提交
2170
  int64_t           clusterId;
D
dapan1121 已提交
2171
  SAppHbReq         app;
D
dapan1121 已提交
2172 2173
  SQueryHbReqBasic* query;
  SHashObj*         info;  // hash<Skv.key, Skv>
L
Liu Jicong 已提交
2174 2175 2176 2177 2178 2179 2180 2181
} SClientHbReq;

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

typedef struct {
D
dapan1121 已提交
2182 2183 2184 2185
  SClientHbKey      connKey;
  int32_t           status;
  SQueryHbRspBasic* query;
  SArray*           info;  // Array<Skv>
L
Liu Jicong 已提交
2186 2187 2188 2189 2190 2191 2192 2193
} SClientHbRsp;

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

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

2196 2197
static FORCE_INLINE void tFreeReqKvHash(SHashObj* info) {
  void* pIter = taosHashIterate(info, NULL);
D
dapan1121 已提交
2198 2199
  while (pIter != NULL) {
    SKv* kv = (SKv*)pIter;
wafwerar's avatar
wafwerar 已提交
2200
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2201 2202 2203 2204
    pIter = taosHashIterate(info, pIter);
  }
}

D
dapan1121 已提交
2205 2206 2207 2208 2209 2210 2211 2212
static FORCE_INLINE void tFreeClientHbQueryDesc(void* pDesc) {
  SQueryDesc* desc = (SQueryDesc*)pDesc;
  if (desc->subDesc) {
    taosArrayDestroy(desc->subDesc);
    desc->subDesc = NULL;
  }
}

2213
static FORCE_INLINE void tFreeClientHbReq(void* pReq) {
L
Liu Jicong 已提交
2214
  SClientHbReq* req = (SClientHbReq*)pReq;
D
dapan1121 已提交
2215 2216 2217 2218 2219 2220
  if (req->query) {
    if (req->query->queryDesc) {
      taosArrayDestroyEx(req->query->queryDesc, tFreeClientHbQueryDesc);
    }
    taosMemoryFreeClear(req->query);
  }
2221

D
dapan1121 已提交
2222 2223 2224
  if (req->info) {
    tFreeReqKvHash(req->info);
    taosHashCleanup(req->info);
D
dapan1121 已提交
2225
    req->info = NULL;
D
dapan1121 已提交
2226
  }
L
Liu Jicong 已提交
2227 2228
}

S
Shengliang Guan 已提交
2229 2230
int32_t tSerializeSClientHbBatchReq(void* buf, int32_t bufLen, const SClientHbBatchReq* pReq);
int32_t tDeserializeSClientHbBatchReq(void* buf, int32_t bufLen, SClientHbBatchReq* pReq);
L
Liu Jicong 已提交
2231

D
dapan1121 已提交
2232
static FORCE_INLINE void tFreeClientHbBatchReq(void* pReq) {
2233
  SClientHbBatchReq* req = (SClientHbBatchReq*)pReq;
D
dapan1121 已提交
2234
  taosArrayDestroyEx(req->reqs, tFreeClientHbReq);
wafwerar's avatar
wafwerar 已提交
2235
  taosMemoryFree(pReq);
L
Liu Jicong 已提交
2236 2237
}

2238 2239
static FORCE_INLINE void tFreeClientKv(void* pKv) {
  SKv* kv = (SKv*)pKv;
D
dapan1121 已提交
2240
  if (kv) {
wafwerar's avatar
wafwerar 已提交
2241
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2242 2243 2244
  }
}

2245
static FORCE_INLINE void tFreeClientHbRsp(void* pRsp) {
D
dapan1121 已提交
2246
  SClientHbRsp* rsp = (SClientHbRsp*)pRsp;
D
dapan1121 已提交
2247 2248 2249 2250
  if (rsp->query) {
    taosArrayDestroy(rsp->query->pQnodeList);
    taosMemoryFreeClear(rsp->query);
  }
D
dapan1121 已提交
2251 2252 2253 2254
  if (rsp->info) taosArrayDestroyEx(rsp->info, tFreeClientKv);
}

static FORCE_INLINE void tFreeClientHbBatchRsp(void* pRsp) {
2255
  SClientHbBatchRsp* rsp = (SClientHbBatchRsp*)pRsp;
D
dapan1121 已提交
2256 2257 2258
  taosArrayDestroyEx(rsp->rsps, tFreeClientHbRsp);
}

S
Shengliang Guan 已提交
2259 2260
int32_t tSerializeSClientHbBatchRsp(void* buf, int32_t bufLen, const SClientHbBatchRsp* pBatchRsp);
int32_t tDeserializeSClientHbBatchRsp(void* buf, int32_t bufLen, SClientHbBatchRsp* pBatchRsp);
H
Hongze Cheng 已提交
2261
void    tFreeSClientHbBatchRsp(SClientHbBatchRsp* pBatchRsp);
L
Liu Jicong 已提交
2262

H
Hongze Cheng 已提交
2263
static FORCE_INLINE int32_t tEncodeSKv(SEncoder* pEncoder, const SKv* pKv) {
S
Shengliang Guan 已提交
2264 2265
  if (tEncodeI32(pEncoder, pKv->key) < 0) return -1;
  if (tEncodeI32(pEncoder, pKv->valueLen) < 0) return -1;
H
Hongze Cheng 已提交
2266
  if (tEncodeBinary(pEncoder, (uint8_t*)pKv->value, pKv->valueLen) < 0) return -1;
S
Shengliang Guan 已提交
2267
  return 0;
L
Liu Jicong 已提交
2268 2269
}

H
Hongze Cheng 已提交
2270
static FORCE_INLINE int32_t tDecodeSKv(SDecoder* pDecoder, SKv* pKv) {
S
Shengliang Guan 已提交
2271 2272
  if (tDecodeI32(pDecoder, &pKv->key) < 0) return -1;
  if (tDecodeI32(pDecoder, &pKv->valueLen) < 0) return -1;
wafwerar's avatar
wafwerar 已提交
2273
  pKv->value = taosMemoryMalloc(pKv->valueLen + 1);
S
Shengliang Guan 已提交
2274 2275 2276
  if (pKv->value == NULL) return -1;
  if (tDecodeCStrTo(pDecoder, (char*)pKv->value) < 0) return -1;
  return 0;
L
Liu Jicong 已提交
2277 2278
}

H
Hongze Cheng 已提交
2279
static FORCE_INLINE int32_t tEncodeSClientHbKey(SEncoder* pEncoder, const SClientHbKey* pKey) {
D
dapan1121 已提交
2280
  if (tEncodeI64(pEncoder, pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2281
  if (tEncodeI8(pEncoder, pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2282
  return 0;
L
Liu Jicong 已提交
2283 2284
}

H
Hongze Cheng 已提交
2285
static FORCE_INLINE int32_t tDecodeSClientHbKey(SDecoder* pDecoder, SClientHbKey* pKey) {
D
dapan1121 已提交
2286
  if (tDecodeI64(pDecoder, &pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2287
  if (tDecodeI8(pDecoder, &pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2288
  return 0;
L
Liu Jicong 已提交
2289 2290 2291 2292 2293 2294
}

typedef struct SMqHbVgInfo {
  int32_t vgId;
} SMqHbVgInfo;

S
Shengliang Guan 已提交
2295 2296
static FORCE_INLINE int32_t taosEncodeSMqVgInfo(void** buf, const SMqHbVgInfo* pVgInfo) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309
  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 已提交
2310
  SArray* pVgInfo;  // SArray<SMqHbVgInfo>
L
Liu Jicong 已提交
2311 2312
} SMqHbTopicInfo;

S
Shengliang Guan 已提交
2313 2314
static FORCE_INLINE int32_t taosEncodeSMqHbTopicInfoMsg(void** buf, const SMqHbTopicInfo* pTopicInfo) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342
  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 {
2343 2344 2345 2346
  int32_t status;  // ask hb endpoint
  int32_t epoch;
  int64_t consumerId;
  SArray* pTopics;  // SArray<SMqHbTopicInfo>
L
Liu Jicong 已提交
2347 2348
} SMqHbMsg;

S
Shengliang Guan 已提交
2349 2350
static FORCE_INLINE int32_t taosEncodeSMqMsg(void** buf, const SMqHbMsg* pMsg) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
2351 2352 2353 2354 2355
  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 已提交
2356
  for (int32_t i = 0; i < sz; i++) {
L
Liu Jicong 已提交
2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369
    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 已提交
2370
  for (int32_t i = 0; i < sz; i++) {
L
Liu Jicong 已提交
2371 2372 2373 2374 2375 2376 2377
    SMqHbTopicInfo topicInfo;
    buf = taosDecodeSMqHbTopicInfoMsg(buf, &topicInfo);
    taosArrayPush(pMsg->pTopics, &topicInfo);
  }
  return buf;
}

L
Liu Jicong 已提交
2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389
typedef struct {
  SMsgHead head;
  int64_t  leftForVer;
  int32_t  vgId;
  int64_t  consumerId;
  char     subKey[TSDB_SUBSCRIBE_KEY_LEN];
} SMqVDeleteReq;

typedef struct {
  int8_t reserved;
} SMqVDeleteRsp;

L
Liu Jicong 已提交
2390
typedef struct {
L
Liu Jicong 已提交
2391 2392
  char   name[TSDB_STREAM_FNAME_LEN];
  int8_t igNotExists;
L
Liu Jicong 已提交
2393
} SMDropStreamReq;
L
Liu Jicong 已提交
2394

X
Xiaoyu Wang 已提交
2395 2396 2397
int32_t tSerializeSMDropStreamReq(void* buf, int32_t bufLen, const SMDropStreamReq* pReq);
int32_t tDeserializeSMDropStreamReq(void* buf, int32_t bufLen, SMDropStreamReq* pReq);

L
Liu Jicong 已提交
2398 2399
typedef struct {
  int8_t reserved;
L
Liu Jicong 已提交
2400
} SMDropStreamRsp;
L
Liu Jicong 已提交
2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411

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

typedef struct {
  int8_t reserved;
} SVDropStreamTaskRsp;

2412 2413 2414 2415 2416 2417
typedef struct {
  int64_t leftForVer;
  int32_t vgId;
  int64_t oldConsumerId;
  int64_t newConsumerId;
  char    subKey[TSDB_SUBSCRIBE_KEY_LEN];
L
Liu Jicong 已提交
2418
  int8_t  subType;
L
Liu Jicong 已提交
2419
  int8_t  withMeta;
L
Liu Jicong 已提交
2420 2421
  char*   qmsg;
  int64_t suid;
2422 2423 2424 2425 2426 2427 2428 2429 2430
} 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 已提交
2431
  tlen += taosEncodeFixedI8(buf, pReq->subType);
L
Liu Jicong 已提交
2432
  tlen += taosEncodeFixedI8(buf, pReq->withMeta);
L
Liu Jicong 已提交
2433
  if (pReq->subType == TOPIC_SUB_TYPE__COLUMN) {
L
Liu Jicong 已提交
2434
    tlen += taosEncodeString(buf, pReq->qmsg);
L
Liu Jicong 已提交
2435 2436
  } else if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    tlen += taosEncodeFixedI64(buf, pReq->suid);
L
Liu Jicong 已提交
2437
  }
2438 2439 2440 2441 2442 2443 2444 2445 2446
  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 已提交
2447
  buf = taosDecodeFixedI8(buf, &pReq->subType);
L
Liu Jicong 已提交
2448
  buf = taosDecodeFixedI8(buf, &pReq->withMeta);
L
Liu Jicong 已提交
2449
  if (pReq->subType == TOPIC_SUB_TYPE__COLUMN) {
L
Liu Jicong 已提交
2450
    buf = taosDecodeString(buf, &pReq->qmsg);
L
Liu Jicong 已提交
2451 2452
  } else if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    buf = taosDecodeFixedI64(buf, &pReq->suid);
L
Liu Jicong 已提交
2453
  }
2454 2455 2456
  return (void*)buf;
}

L
Liu Jicong 已提交
2457 2458 2459 2460
typedef struct {
  int32_t vgId;
  int64_t offset;
  char    topicName[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2461
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2462 2463 2464 2465 2466
} SMqOffset;

typedef struct {
  int32_t    num;
  SMqOffset* offsets;
L
Liu Jicong 已提交
2467
} SMqCMCommitOffsetReq;
L
Liu Jicong 已提交
2468 2469 2470

typedef struct {
  int32_t reserved;
L
Liu Jicong 已提交
2471
} SMqCMCommitOffsetRsp;
L
Liu Jicong 已提交
2472

H
Hongze Cheng 已提交
2473 2474 2475 2476
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 已提交
2477

2478 2479
// tqOffset
enum {
L
Liu Jicong 已提交
2480 2481 2482 2483 2484 2485
  TMQ_OFFSET__RESET_NONE = -3,
  TMQ_OFFSET__RESET_EARLIEAST = -2,
  TMQ_OFFSET__RESET_LATEST = -1,
  TMQ_OFFSET__LOG = 1,
  TMQ_OFFSET__SNAPSHOT_DATA = 2,
  TMQ_OFFSET__SNAPSHOT_META = 3,
2486 2487 2488 2489 2490
};

typedef struct {
  int8_t type;
  union {
L
Liu Jicong 已提交
2491
    // snapshot data
2492 2493 2494 2495
    struct {
      int64_t uid;
      int64_t ts;
    };
L
Liu Jicong 已提交
2496
    // log
2497 2498 2499 2500
    struct {
      int64_t version;
    };
  };
L
Liu Jicong 已提交
2501 2502 2503 2504 2505 2506 2507 2508 2509 2510
} STqOffsetVal;

int32_t tEncodeSTqOffsetVal(SEncoder* pEncoder, const STqOffsetVal* pOffsetVal);
int32_t tDecodeSTqOffsetVal(SDecoder* pDecoder, STqOffsetVal* pOffsetVal);
int32_t tFormatOffset(char* buf, int32_t maxLen, const STqOffsetVal* pVal);
bool    tOffsetEqual(const STqOffsetVal* pLeft, const STqOffsetVal* pRight);

typedef struct {
  STqOffsetVal val;
  char         subKey[TSDB_SUBSCRIBE_KEY_LEN];
2511 2512 2513 2514 2515
} STqOffset;

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

S
Shengliang Guan 已提交
2516 2517 2518 2519 2520 2521 2522
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 已提交
2523
  int32_t dstVgId;  // for stream
S
Shengliang Guan 已提交
2524 2525 2526
  int64_t interval;
  int64_t offset;
  int64_t sliding;
2527 2528
  int64_t maxDelay;
  int64_t watermark;
S
sma  
Shengliang Guan 已提交
2529 2530 2531 2532
  int32_t exprLen;        // strlen + 1
  int32_t tagsFilterLen;  // strlen + 1
  int32_t sqlLen;         // strlen + 1
  int32_t astLen;         // strlen + 1
L
Liu Jicong 已提交
2533
  char*   expr;
S
Shengliang Guan 已提交
2534
  char*   tagsFilter;
S
sma  
Shengliang Guan 已提交
2535 2536
  char*   sql;
  char*   ast;
S
Shengliang Guan 已提交
2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550
} 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);

2551 2552 2553 2554 2555
typedef struct {
  int32_t vgId;
  SEpSet  epSet;
} SVgEpSet;

C
Cary Xu 已提交
2556
typedef struct {
C
Cary Xu 已提交
2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576
  int8_t         version;       // for compatibility(default 0)
  int8_t         intervalUnit;  // MACRO: TIME_UNIT_XXX
  int8_t         slidingUnit;   // MACRO: TIME_UNIT_XXX
  int8_t         timezoneInt;   // sma data expired if timezone changes.
  int32_t        dstVgId;
  char           indexName[TSDB_INDEX_NAME_LEN];
  int32_t        exprLen;
  int32_t        tagsFilterLen;
  int64_t        indexUid;
  tb_uid_t       tableUid;  // super/child/common table uid
  tb_uid_t       dstTbUid;  // for dstVgroup
  int64_t        interval;
  int64_t        offset;  // use unit by precision of DB
  int64_t        sliding;
  char*          dstTbName;  // for dstVgroup
  char*          expr;       // sma expression
  char*          tagsFilter;
  SSchemaWrapper schemaRow;  // for dstVgroup
  SSchemaWrapper schemaTag;  // for dstVgroup
} STSma;                     // Time-range-wise SMA
C
Cary Xu 已提交
2577

2578
typedef STSma SVCreateTSmaReq;
C
Cary Xu 已提交
2579 2580

typedef struct {
C
Cary Xu 已提交
2581 2582 2583
  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 已提交
2584 2585 2586
} STSmaMsg;

typedef struct {
C
Cary Xu 已提交
2587
  int64_t indexUid;
C
Cary Xu 已提交
2588
  char    indexName[TSDB_INDEX_NAME_LEN];
C
Cary Xu 已提交
2589
} SVDropTSmaReq;
2590

C
Cary Xu 已提交
2591
typedef struct {
L
Liu Jicong 已提交
2592
  int tmp;  // TODO: to avoid compile error
C
Cary Xu 已提交
2593 2594
} SVCreateTSmaRsp, SVDropTSmaRsp;

2595
#if 0
C
Cary Xu 已提交
2596 2597 2598 2599
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);
2600
#endif
C
Cary Xu 已提交
2601

2602 2603 2604 2605
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 已提交
2606

C
Cary Xu 已提交
2607
typedef struct {
2608 2609
  int32_t number;
  STSma*  tSma;
C
Cary Xu 已提交
2610 2611
} STSmaWrapper;

C
Cary Xu 已提交
2612
static FORCE_INLINE void tDestroyTSma(STSma* pSma) {
C
Cary Xu 已提交
2613
  if (pSma) {
C
Cary Xu 已提交
2614
    taosMemoryFreeClear(pSma->dstTbName);
wafwerar's avatar
wafwerar 已提交
2615 2616
    taosMemoryFreeClear(pSma->expr);
    taosMemoryFreeClear(pSma->tagsFilter);
C
Cary Xu 已提交
2617 2618 2619
  }
}

C
Cary Xu 已提交
2620
static FORCE_INLINE void tDestroyTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
C
Cary Xu 已提交
2621 2622
  if (pSW) {
    if (pSW->tSma) {
C
Cary Xu 已提交
2623 2624
      if (deepCopy) {
        for (uint32_t i = 0; i < pSW->number; ++i) {
C
Cary Xu 已提交
2625
          tDestroyTSma(pSW->tSma + i);
C
Cary Xu 已提交
2626
        }
C
Cary Xu 已提交
2627
      }
wafwerar's avatar
wafwerar 已提交
2628
      taosMemoryFreeClear(pSW->tSma);
C
Cary Xu 已提交
2629
    }
C
Cary Xu 已提交
2630 2631 2632
  }
}

C
Cary Xu 已提交
2633 2634
static FORCE_INLINE void* tFreeTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
  tDestroyTSmaWrapper(pSW, deepCopy);
C
Cary Xu 已提交
2635
  taosMemoryFreeClear(pSW);
C
Cary Xu 已提交
2636
  return NULL;
C
Cary Xu 已提交
2637 2638
}

2639 2640
int32_t tEncodeSVCreateTSmaReq(SEncoder* pCoder, const SVCreateTSmaReq* pReq);
int32_t tDecodeSVCreateTSmaReq(SDecoder* pCoder, SVCreateTSmaReq* pReq);
C
Cary Xu 已提交
2641

2642
int32_t tEncodeTSma(SEncoder* pCoder, const STSma* pSma);
C
Cary Xu 已提交
2643
int32_t tDecodeTSma(SDecoder* pCoder, STSma* pSma, bool deepCopy);
C
Cary Xu 已提交
2644

2645 2646 2647 2648
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 已提交
2649
  }
2650
  return 0;
C
Cary Xu 已提交
2651 2652
}

C
Cary Xu 已提交
2653
static int32_t tDecodeTSmaWrapper(SDecoder* pDecoder, STSmaWrapper* pReq, bool deepCopy) {
2654 2655
  if (tDecodeI32(pDecoder, &pReq->number) < 0) return -1;
  for (int32_t i = 0; i < pReq->number; ++i) {
C
Cary Xu 已提交
2656
    tDecodeTSma(pDecoder, pReq->tSma + i, deepCopy);
C
Cary Xu 已提交
2657
  }
2658
  return 0;
C
Cary Xu 已提交
2659
}
L
Liu Jicong 已提交
2660

dengyihao's avatar
dengyihao 已提交
2661
typedef struct {
dengyihao's avatar
dengyihao 已提交
2662
  int idx;
dengyihao's avatar
dengyihao 已提交
2663 2664 2665 2666 2667 2668
} 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 已提交
2669 2670 2671 2672 2673 2674 2675 2676
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 已提交
2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694
typedef struct {
  char indexFName[TSDB_INDEX_FNAME_LEN];
} SUserIndexReq;

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

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

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

D
dapan1121 已提交
2695 2696 2697 2698 2699 2700 2701 2702
typedef struct {
  char tbFName[TSDB_TABLE_FNAME_LEN];
} STableIndexReq;

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

typedef struct {
2703 2704 2705 2706 2707 2708
  int8_t  intervalUnit;
  int8_t  slidingUnit;
  int64_t interval;
  int64_t offset;
  int64_t sliding;
  int64_t dstTbUid;
X
Xiaoyu Wang 已提交
2709
  int32_t dstVgId;
2710 2711
  SEpSet  epSet;
  char*   expr;
D
dapan1121 已提交
2712 2713 2714
} STableIndexInfo;

typedef struct {
D
dapan1121 已提交
2715 2716
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
2717 2718 2719
  uint64_t suid;
  int32_t  version;
  SArray*  pIndex;
D
dapan1121 已提交
2720 2721 2722 2723
} STableIndexRsp;

int32_t tSerializeSTableIndexRsp(void* buf, int32_t bufLen, const STableIndexRsp* pRsp);
int32_t tDeserializeSTableIndexRsp(void* buf, int32_t bufLen, STableIndexRsp* pRsp);
C
Cary Xu 已提交
2724 2725

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

L
Liu Jicong 已提交
2727 2728 2729 2730
typedef struct {
  int8_t  mqMsgType;
  int32_t code;
  int32_t epoch;
L
Liu Jicong 已提交
2731
  int64_t consumerId;
L
Liu Jicong 已提交
2732 2733
} SMqRspHead;

L
Liu Jicong 已提交
2734 2735 2736
typedef struct {
  SMsgHead head;
  char     subKey[TSDB_SUBSCRIBE_KEY_LEN];
2737
  int8_t   withTbName;
L
Liu Jicong 已提交
2738
  int8_t   useSnapshot;
L
Liu Jicong 已提交
2739 2740 2741
  int32_t  epoch;
  uint64_t reqId;
  int64_t  consumerId;
2742
  int64_t  timeout;
L
Liu Jicong 已提交
2743 2744
  // int64_t      currentOffset;
  STqOffsetVal reqOffset;
L
Liu Jicong 已提交
2745
} SMqPollReq;
L
Liu Jicong 已提交
2746

L
Liu Jicong 已提交
2747
typedef struct {
L
Liu Jicong 已提交
2748
  int32_t vgId;
L
Liu Jicong 已提交
2749
  int64_t offset;
L
Liu Jicong 已提交
2750 2751 2752
  SEpSet  epSet;
} SMqSubVgEp;

L
Liu Jicong 已提交
2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767
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 已提交
2768
typedef struct {
L
Liu Jicong 已提交
2769
  char           topic[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2770
  char           db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
2771 2772
  SArray*        vgs;  // SArray<SMqSubVgEp>
  SSchemaWrapper schema;
L
Liu Jicong 已提交
2773 2774
} SMqSubTopicEp;

L
Liu Jicong 已提交
2775 2776 2777
static FORCE_INLINE int32_t tEncodeSMqSubTopicEp(void** buf, const SMqSubTopicEp* pTopicEp) {
  int32_t tlen = 0;
  tlen += taosEncodeString(buf, pTopicEp->topic);
L
Liu Jicong 已提交
2778
  tlen += taosEncodeString(buf, pTopicEp->db);
L
Liu Jicong 已提交
2779 2780 2781 2782 2783 2784 2785 2786 2787 2788 2789 2790
  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);
L
Liu Jicong 已提交
2791
  buf = taosDecodeStringTo(buf, pTopicEp->db);
L
Liu Jicong 已提交
2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811
  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 已提交
2812
typedef struct {
L
Liu Jicong 已提交
2813 2814 2815 2816 2817 2818 2819 2820
  SMqRspHead   head;
  int64_t      reqOffset;
  int64_t      rspOffset;
  STqOffsetVal reqOffsetNew;
  STqOffsetVal rspOffsetNew;
  int16_t      resMsgType;
  int32_t      metaRspLen;
  void*        metaRsp;
L
Liu Jicong 已提交
2821 2822 2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841
} SMqMetaRsp;

static FORCE_INLINE int32_t tEncodeSMqMetaRsp(void** buf, const SMqMetaRsp* pRsp) {
  int32_t tlen = 0;
  tlen += taosEncodeFixedI64(buf, pRsp->reqOffset);
  tlen += taosEncodeFixedI64(buf, pRsp->rspOffset);
  tlen += taosEncodeFixedI16(buf, pRsp->resMsgType);
  tlen += taosEncodeFixedI32(buf, pRsp->metaRspLen);
  tlen += taosEncodeBinary(buf, pRsp->metaRsp, pRsp->metaRspLen);
  return tlen;
}

static FORCE_INLINE void* tDecodeSMqMetaRsp(const void* buf, SMqMetaRsp* pRsp) {
  buf = taosDecodeFixedI64(buf, &pRsp->reqOffset);
  buf = taosDecodeFixedI64(buf, &pRsp->rspOffset);
  buf = taosDecodeFixedI16(buf, &pRsp->resMsgType);
  buf = taosDecodeFixedI32(buf, &pRsp->metaRspLen);
  buf = taosDecodeBinary(buf, &pRsp->metaRsp, pRsp->metaRspLen);
  return (void*)buf;
}

L
Liu Jicong 已提交
2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853 2854 2855 2856 2857 2858 2859
typedef struct {
  SMqRspHead   head;
  STqOffsetVal reqOffset;
  STqOffsetVal rspOffset;
  int32_t      skipLogNum;
  int32_t      blockNum;
  int8_t       withTbName;
  int8_t       withSchema;
  SArray*      blockDataLen;
  SArray*      blockData;
  SArray*      blockTbName;
  SArray*      blockSchema;
} SMqDataRsp;

int32_t tEncodeSMqDataRsp(SEncoder* pEncoder, const SMqDataRsp* pRsp);
int32_t tDecodeSMqDataRsp(SDecoder* pDecoder, SMqDataRsp* pRsp);

#if 0
L
Liu Jicong 已提交
2860 2861 2862 2863 2864 2865 2866 2867
typedef struct {
  SMqRspHead head;
  int64_t    reqOffset;
  int64_t    rspOffset;
  int32_t    skipLogNum;
  int32_t    blockNum;
  int8_t     withTbName;
  int8_t     withSchema;
L
Liu Jicong 已提交
2868 2869 2870 2871
  SArray*    blockDataLen;  // SArray<int32_t>
  SArray*    blockData;     // SArray<SRetrieveTableRsp*>
  SArray*    blockTbName;   // SArray<char*>
  SArray*    blockSchema;   // SArray<SSchemaWrapper>
L
Liu Jicong 已提交
2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888
} 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);

    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 已提交
2889 2890 2891 2892
      if (pRsp->withSchema) {
        SSchemaWrapper* pSW = (SSchemaWrapper*)taosArrayGetP(pRsp->blockSchema, i);
        tlen += taosEncodeSSchemaWrapper(buf, pSW);
      }
L
Liu Jicong 已提交
2893 2894 2895 2896
      if (pRsp->withTbName) {
        char* tbName = (char*)taosArrayGetP(pRsp->blockTbName, i);
        tlen += taosEncodeString(buf, tbName);
      }
L
Liu Jicong 已提交
2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907
    }
  }
  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 已提交
2908 2909
    pRsp->blockData = taosArrayInit(pRsp->blockNum, sizeof(void*));
    pRsp->blockDataLen = taosArrayInit(pRsp->blockNum, sizeof(int32_t));
L
Liu Jicong 已提交
2910 2911
    buf = taosDecodeFixedI8(buf, &pRsp->withTbName);
    buf = taosDecodeFixedI8(buf, &pRsp->withSchema);
L
Liu Jicong 已提交
2912 2913 2914 2915 2916 2917
    if (pRsp->withTbName) {
      pRsp->blockTbName = taosArrayInit(pRsp->blockNum, sizeof(void*));
    }
    if (pRsp->withSchema) {
      pRsp->blockSchema = taosArrayInit(pRsp->blockNum, sizeof(void*));
    }
L
Liu Jicong 已提交
2918 2919 2920 2921 2922 2923 2924 2925

    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 已提交
2926 2927 2928 2929 2930
      if (pRsp->withSchema) {
        SSchemaWrapper* pSW = (SSchemaWrapper*)taosMemoryMalloc(sizeof(SSchemaWrapper));
        buf = taosDecodeSSchemaWrapper(buf, pSW);
        taosArrayPush(pRsp->blockSchema, &pSW);
      }
L
Liu Jicong 已提交
2931 2932 2933 2934 2935
      if (pRsp->withTbName) {
        char* name = NULL;
        buf = taosDecodeString(buf, &name);
        taosArrayPush(pRsp->blockTbName, &name);
      }
L
Liu Jicong 已提交
2936 2937 2938 2939
    }
  }
  return (void*)buf;
}
L
Liu Jicong 已提交
2940
#endif
L
Liu Jicong 已提交
2941

L
Liu Jicong 已提交
2942
typedef struct {
L
Liu Jicong 已提交
2943
  SMqRspHead head;
L
Liu Jicong 已提交
2944 2945
  char       cgroup[TSDB_CGROUP_LEN];
  SArray*    topics;  // SArray<SMqSubTopicEp>
L
Liu Jicong 已提交
2946
} SMqAskEpRsp;
L
Liu Jicong 已提交
2947

L
Liu Jicong 已提交
2948
static FORCE_INLINE int32_t tEncodeSMqAskEpRsp(void** buf, const SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
2949
  int32_t tlen = 0;
L
Liu Jicong 已提交
2950
  // tlen += taosEncodeString(buf, pRsp->cgroup);
L
Liu Jicong 已提交
2951 2952 2953 2954 2955 2956 2957 2958 2959
  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 已提交
2960
static FORCE_INLINE void* tDecodeSMqAskEpRsp(void* buf, SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
2961
  // buf = taosDecodeStringTo(buf, pRsp->cgroup);
L
Liu Jicong 已提交
2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974
  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 已提交
2975

L
Liu Jicong 已提交
2976 2977 2978 2979
static FORCE_INLINE void tDeleteSMqAskEpRsp(SMqAskEpRsp* pRsp) {
  taosArrayDestroyEx(pRsp->topics, (void (*)(void*))tDeleteSMqSubTopicEp);
}

H
Hongze Cheng 已提交
2980 2981
#define TD_AUTO_CREATE_TABLE 0x1
typedef struct {
H
Hongze Cheng 已提交
2982 2983 2984 2985 2986 2987
  int64_t       suid;
  int64_t       uid;
  int32_t       sver;
  uint32_t      nData;
  uint8_t*      pData;
  SVCreateTbReq cTbReq;
H
Hongze Cheng 已提交
2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998
} SVSubmitBlk;

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

H
Hongze Cheng 已提交
2999 3000
int32_t tEncodeSVSubmitReq(SEncoder* pCoder, const SVSubmitReq* pReq);
int32_t tDecodeSVSubmitReq(SDecoder* pCoder, SVSubmitReq* pReq);
H
Hongze Cheng 已提交
3001

H
more  
Hongze Cheng 已提交
3002
typedef struct {
D
dapan1121 已提交
3003 3004 3005 3006 3007 3008 3009 3010
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
  uint32_t sqlLen;
  uint32_t phyLen;
  char*    sql;
  char*    msg;
H
more  
Hongze Cheng 已提交
3011 3012
} SVDeleteReq;

C
Cary Xu 已提交
3013 3014
int32_t tSerializeSVDeleteReq(void* buf, int32_t bufLen, SVDeleteReq* pReq);
int32_t tDeserializeSVDeleteReq(void* buf, int32_t bufLen, SVDeleteReq* pReq);
C
Cary Xu 已提交
3015

H
more  
Hongze Cheng 已提交
3016
typedef struct {
C
Cary Xu 已提交
3017
  int64_t affectedRows;
H
more  
Hongze Cheng 已提交
3018 3019
} SVDeleteRsp;

C
Cary Xu 已提交
3020 3021 3022
int32_t tEncodeSVDeleteRsp(SEncoder* pCoder, const SVDeleteRsp* pReq);
int32_t tDecodeSVDeleteRsp(SDecoder* pCoder, SVDeleteRsp* pReq);

L
Liu Jicong 已提交
3023 3024
#pragma pack(pop)

D
dapan1121 已提交
3025 3026 3027 3028 3029
#ifdef __cplusplus
}
#endif

#endif /*_TD_COMMON_TAOS_MSG_H_*/