tmsg.h 87.6 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)
X
Xiaoyu Wang 已提交
58 59 60 61 62
#define TMSG_INFO(TYPE)                                                                                      \
  ((TYPE) >= 0 && ((TYPE) < TDMT_DND_MAX_MSG || (TYPE) < TDMT_MND_MAX_MSG || (TYPE) < TDMT_VND_MAX_MSG ||    \
                   (TYPE) < TDMT_SCH_MAX_MSG || (TYPE) < TDMT_STREAM_MAX_MSG || (TYPE) < TDMT_MON_MAX_MSG || \
                   (TYPE) < TDMT_SYNC_MAX_MSG))                                                              \
      ? tMsgInfo[tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE)]                                         \
dengyihao's avatar
dengyihao 已提交
63
      : 0
dengyihao's avatar
dengyihao 已提交
64
#define TMSG_INDEX(TYPE) (tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE))
D
dapan1121 已提交
65

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

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

78 79 80 81 82 83
enum {
  CONN_TYPE__QUERY = 1,
  CONN_TYPE__TMQ,
  CONN_TYPE__UDFD,
  CONN_TYPE__MAX,
};
L
Liu Jicong 已提交
84

D
dapan1121 已提交
85
enum {
D
dapan 已提交
86 87
  HEARTBEAT_KEY_USER_AUTHINFO = 1,
  HEARTBEAT_KEY_DBINFO,
D
dapan1121 已提交
88
  HEARTBEAT_KEY_STBINFO,
89
  HEARTBEAT_KEY_TMQ,
D
dapan1121 已提交
90 91
};

S
Shengliang Guan 已提交
92 93
typedef enum _mgmt_table {
  TSDB_MGMT_TABLE_START,
D
dapan1121 已提交
94 95
  TSDB_MGMT_TABLE_DNODE,
  TSDB_MGMT_TABLE_MNODE,
96
  TSDB_MGMT_TABLE_MODULE,
S
Shengliang Guan 已提交
97 98 99
  TSDB_MGMT_TABLE_QNODE,
  TSDB_MGMT_TABLE_SNODE,
  TSDB_MGMT_TABLE_BNODE,
100 101 102 103
  TSDB_MGMT_TABLE_CLUSTER,
  TSDB_MGMT_TABLE_DB,
  TSDB_MGMT_TABLE_FUNC,
  TSDB_MGMT_TABLE_INDEX,
S
Shengliang Guan 已提交
104
  TSDB_MGMT_TABLE_STB,
D
dapan1121 已提交
105
  TSDB_MGMT_TABLE_STREAMS,
106
  TSDB_MGMT_TABLE_TABLE,
107
  TSDB_MGMT_TABLE_TAG,
108
  TSDB_MGMT_TABLE_USER,
D
dapan1121 已提交
109
  TSDB_MGMT_TABLE_GRANTS,
110 111 112
  TSDB_MGMT_TABLE_VGROUP,
  TSDB_MGMT_TABLE_TOPICS,
  TSDB_MGMT_TABLE_CONSUMERS,
L
Liu Jicong 已提交
113
  TSDB_MGMT_TABLE_SUBSCRIPTIONS,
114 115 116 117 118
  TSDB_MGMT_TABLE_TRANS,
  TSDB_MGMT_TABLE_SMAS,
  TSDB_MGMT_TABLE_CONFIGS,
  TSDB_MGMT_TABLE_CONNS,
  TSDB_MGMT_TABLE_QUERIES,
D
dapan1121 已提交
119
  TSDB_MGMT_TABLE_VNODES,
D
dapan1121 已提交
120
  TSDB_MGMT_TABLE_APPS,
D
dapan1121 已提交
121
  TSDB_MGMT_TABLE_MAX,
S
Shengliang Guan 已提交
122
} EShowType;
D
dapan1121 已提交
123

124 125 126 127
#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 已提交
128 129
#define TSDB_ALTER_TABLE_ADD_COLUMN          5
#define TSDB_ALTER_TABLE_DROP_COLUMN         6
S
Shengliang Guan 已提交
130
#define TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES 7
L
Liu Jicong 已提交
131
#define TSDB_ALTER_TABLE_UPDATE_TAG_BYTES    8
132 133
#define TSDB_ALTER_TABLE_UPDATE_OPTIONS      9
#define TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME  10
D
dapan1121 已提交
134

L
Liu Jicong 已提交
135 136
#define TSDB_FILL_NONE      0
#define TSDB_FILL_NULL      1
H
Hongze Cheng 已提交
137
#define TSDB_FILL_SET_VALUE 2
L
Liu Jicong 已提交
138 139 140 141 142 143 144 145
#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 已提交
146 147 148 149
#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
150 151
#define TSDB_ALTER_USER_ENABLE          0x9
#define TSDB_ALTER_USER_SYSINFO         0xA
S
Shengliang Guan 已提交
152

D
dapan1121 已提交
153 154
#define TSDB_ALTER_USER_PRIVILEGES 0x2

H
Hongze Cheng 已提交
155
#define TSDB_KILL_MSG_LEN 30
D
dapan1121 已提交
156

D
dapan1121 已提交
157 158
#define TSDB_TABLE_NUM_UNIT 100000

L
Liu Jicong 已提交
159
#define TSDB_VN_READ_ACCCESS  ((char)0x1)
H
Hongze Cheng 已提交
160
#define TSDB_VN_WRITE_ACCCESS ((char)0x2)
L
Liu Jicong 已提交
161
#define TSDB_VN_ALL_ACCCESS   (TSDB_VN_READ_ACCCESS | TSDB_VN_WRITE_ACCCESS)
D
dapan1121 已提交
162

H
Hongze Cheng 已提交
163
#define TSDB_COL_NORMAL 0x0u  // the normal column of the table
L
Liu Jicong 已提交
164 165 166 167
#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 已提交
168

L
Liu Jicong 已提交
169
#define TSDB_COL_IS_TAG(f)        (((f & (~(TSDB_COL_NULL))) & TSDB_COL_TAG) != 0)
H
Hongze Cheng 已提交
170
#define TSDB_COL_IS_NORMAL_COL(f) ((f & (~(TSDB_COL_NULL))) == TSDB_COL_NORMAL)
L
Liu Jicong 已提交
171 172
#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 已提交
173

L
Liu Jicong 已提交
174 175
#define TD_SUPER_TABLE  TSDB_SUPER_TABLE
#define TD_CHILD_TABLE  TSDB_CHILD_TABLE
S
Shengliang Guan 已提交
176 177
#define TD_NORMAL_TABLE TSDB_NORMAL_TABLE

178 179 180
#define TD_REQ_FROM_APP  0
#define TD_REQ_FROM_TAOX 1

S
Shengliang Guan 已提交
181
typedef struct {
S
Shengliang Guan 已提交
182
  int32_t vgId;
D
dapan1121 已提交
183 184
  char*   dbFName;
  char*   tbName;
D
dapan1121 已提交
185
} SBuildTableInput;
D
dapan1121 已提交
186

S
Shengliang Guan 已提交
187
typedef struct {
D
dapan1121 已提交
188
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
189
  int64_t dbId;
190
  int32_t vgVersion;
L
Liu Jicong 已提交
191
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
D
dapan1121 已提交
192 193
} SBuildUseDBInput;

S
Shengliang Guan 已提交
194 195 196
typedef struct SField {
  char    name[TSDB_COL_NAME_LEN];
  uint8_t type;
197
  int8_t  flags;
198
  int32_t bytes;
S
Shengliang Guan 已提交
199 200
} SField;

S
Shengliang Guan 已提交
201
typedef struct SRetention {
C
Cary Xu 已提交
202 203
  int64_t freq;
  int64_t keep;
S
sma  
Shengliang Guan 已提交
204 205
  int8_t  freqUnit;
  int8_t  keepUnit;
S
Shengliang Guan 已提交
206 207
} SRetention;

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

D
dapan1121 已提交
210 211 212
#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 已提交
213
typedef struct SEp {
D
dapan1121 已提交
214
  char     fqdn[TSDB_FQDN_LEN];
D
dapan1121 已提交
215
  uint16_t port;
H
Haojun Liao 已提交
216
} SEp;
D
dapan1121 已提交
217

S
Shengliang Guan 已提交
218
typedef struct {
D
dapan1121 已提交
219
  int32_t contLen;
L
Liu Jicong 已提交
220
  int32_t vgId;
D
dapan1121 已提交
221 222 223 224
} SMsgHead;

// Submit message for one table
typedef struct SSubmitBlk {
225
  int64_t uid;        // table unique id
L
Liu Jicong 已提交
226
  int64_t suid;       // stable id
227 228 229
  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
230
  int32_t numOfRows;  // total number of rows in current submit block
231
  char    data[];
D
dapan1121 已提交
232 233 234
} SSubmitBlk;

// Submit message for this TSDB
S
Shengliang Guan 已提交
235
typedef struct {
S
Shengliang Guan 已提交
236
  SMsgHead header;
H
Hongze Cheng 已提交
237
  int64_t  version;
S
Shengliang Guan 已提交
238 239 240
  int32_t  length;
  int32_t  numOfBlocks;
  char     blocks[];
S
Shengliang Guan 已提交
241
} SSubmitReq;
D
dapan1121 已提交
242

H
Hongze Cheng 已提交
243 244 245
typedef struct {
  int32_t totalLen;
  int32_t len;
246
  STSRow* row;
H
Hongze Cheng 已提交
247 248 249
} SSubmitBlkIter;

typedef struct {
C
Cary Xu 已提交
250 251 252
  int32_t totalLen;
  int32_t len;
  // head of SSubmitBlk
C
Cary Xu 已提交
253 254 255 256 257
  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
258
  int32_t numOfRows;  // total number of rows in current submit block
C
Cary Xu 已提交
259
  // head of SSubmitBlk
C
Cary Xu 已提交
260
  int32_t     numOfBlocks;
C
Cary Xu 已提交
261
  const void* pMsg;
H
Hongze Cheng 已提交
262
} SSubmitMsgIter;
C
Cary Xu 已提交
263

L
Liu Jicong 已提交
264
int32_t tInitSubmitMsgIter(const SSubmitReq* pMsg, SSubmitMsgIter* pIter);
S
Shengliang Guan 已提交
265
int32_t tGetSubmitMsgNext(SSubmitMsgIter* pIter, SSubmitBlk** pPBlock);
C
Cary Xu 已提交
266
int32_t tInitSubmitBlkIter(SSubmitMsgIter* pMsgIter, SSubmitBlk* pBlock, SSubmitBlkIter* pIter);
C
Cary Xu 已提交
267
STSRow* tGetSubmitBlkNext(SSubmitBlkIter* pIter);
L
Liu Jicong 已提交
268
// for debug
H
Hongze Cheng 已提交
269
int32_t tPrintFixedSchemaSubmitReq(SSubmitReq* pReq, STSchema* pSchema);
H
Hongze Cheng 已提交
270

271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296
struct SSchema {
  int8_t   type;
  int8_t   flags;
  col_id_t colId;
  int32_t  bytes;
  char     name[TSDB_COL_NAME_LEN];
};

typedef struct {
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     stbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
  int64_t  dbId;
  int32_t  numOfTags;
  int32_t  numOfColumns;
  int8_t   precision;
  int8_t   tableType;
  int32_t  sversion;
  int32_t  tversion;
  uint64_t suid;
  uint64_t tuid;
  int32_t  vgId;
  int8_t   sysInfo;
  SSchema* pSchemas;
} STableMetaRsp;

D
dapan1121 已提交
297
typedef struct {
L
Liu Jicong 已提交
298 299 300 301 302 303 304 305
  int32_t        code;
  int8_t         hashMeta;
  int64_t        uid;
  char*          tblFName;
  int32_t        numOfRows;
  int32_t        affectedRows;
  int64_t        sver;
  STableMetaRsp* pMeta;
H
Hongze Cheng 已提交
306
} SSubmitBlkRsp;
D
dapan1121 已提交
307 308

typedef struct {
H
Hongze Cheng 已提交
309 310 311 312 313 314 315
  int32_t numOfRows;
  int32_t affectedRows;
  int32_t nBlocks;
  union {
    SArray*        pArray;
    SSubmitBlkRsp* pBlocks;
  };
S
Shengliang Guan 已提交
316
} SSubmitRsp;
D
dapan1121 已提交
317

H
Hongze Cheng 已提交
318 319
int32_t tEncodeSSubmitRsp(SEncoder* pEncoder, const SSubmitRsp* pRsp);
int32_t tDecodeSSubmitRsp(SDecoder* pDecoder, SSubmitRsp* pRsp);
L
Liu Jicong 已提交
320
void    tFreeSSubmitBlkRsp(void* param);
H
Hongze Cheng 已提交
321
void    tFreeSSubmitRsp(SSubmitRsp* pRsp);
322

323 324 325 326 327
#define COL_SMA_ON     ((int8_t)0x1)
#define COL_IDX_ON     ((int8_t)0x2)
#define COL_SET_NULL   ((int8_t)0x10)
#define COL_SET_VAL    ((int8_t)0x20)
#define COL_IS_SYSINFO ((int8_t)0x40)
D
dapan1121 已提交
328

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

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

dengyihao's avatar
dengyihao 已提交
334
#define SSCHMEA_TYPE(s)  ((s)->type)
C
Cary Xu 已提交
335
#define SSCHMEA_FLAGS(s) ((s)->flags)
C
Cary Xu 已提交
336 337
#define SSCHMEA_COLID(s) ((s)->colId)
#define SSCHMEA_BYTES(s) ((s)->bytes)
dengyihao's avatar
dengyihao 已提交
338
#define SSCHMEA_NAME(s)  ((s)->name)
C
Cary Xu 已提交
339

H
Hongze Cheng 已提交
340 341
typedef struct {
  int32_t  nCols;
342
  int32_t  version;
H
Hongze Cheng 已提交
343 344 345
  SSchema* pSchema;
} SSchemaWrapper;

L
Liu Jicong 已提交
346 347 348 349
static FORCE_INLINE SSchemaWrapper* tCloneSSchemaWrapper(const SSchemaWrapper* pSchemaWrapper) {
  SSchemaWrapper* pSW = (SSchemaWrapper*)taosMemoryMalloc(sizeof(SSchemaWrapper));
  if (pSW == NULL) return pSW;
  pSW->nCols = pSchemaWrapper->nCols;
350
  pSW->version = pSchemaWrapper->version;
L
Liu Jicong 已提交
351 352 353 354 355 356 357 358 359 360
  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) {
361 362 363 364
  if (pSchemaWrapper) {
    taosMemoryFree(pSchemaWrapper->pSchema);
    taosMemoryFree(pSchemaWrapper);
  }
L
Liu Jicong 已提交
365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406
}

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);
407
  tlen += taosEncodeVariantI32(buf, pSW->version);
L
Liu Jicong 已提交
408 409 410 411 412 413 414 415
  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);
416
  buf = taosDecodeVariantI32(buf, &pSW->version);
L
Liu Jicong 已提交
417 418 419 420 421 422 423 424 425 426 427 428 429
  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;
430
  if (tEncodeI32v(pEncoder, pSW->version) < 0) return -1;
L
Liu Jicong 已提交
431 432 433 434 435 436 437 438 439
  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;
440
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
L
Liu Jicong 已提交
441 442 443 444 445 446 447 448 449 450

  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 已提交
451 452
static FORCE_INLINE int32_t tDecodeSSchemaWrapperEx(SDecoder* pDecoder, SSchemaWrapper* pSW) {
  if (tDecodeI32v(pDecoder, &pSW->nCols) < 0) return -1;
453
  if (tDecodeI32v(pDecoder, &pSW->version) < 0) return -1;
C
Cary Xu 已提交
454 455 456 457 458 459 460 461 462 463

  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 已提交
464
STSchema* tdGetSTSChemaFromSSChema(SSchema* pSchema, int32_t nCols, int32_t sver);
C
Cary Xu 已提交
465

D
dapan1121 已提交
466
typedef struct {
467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490
  char     name[TSDB_TABLE_FNAME_LEN];
  int8_t   igExists;
  int8_t   source;  // 1-taosX or 0-taosClient
  int8_t   reserved[6];
  tb_uid_t suid;
  int64_t  delay1;
  int64_t  delay2;
  int64_t  watermark1;
  int64_t  watermark2;
  int32_t  ttl;
  int32_t  colVer;
  int32_t  tagVer;
  int32_t  numOfColumns;
  int32_t  numOfTags;
  int32_t  numOfFuncs;
  int32_t  commentLen;
  int32_t  ast1Len;
  int32_t  ast2Len;
  SArray*  pColumns;  // array of SField
  SArray*  pTags;     // array of SField
  SArray*  pFuncs;
  char*    pComment;
  char*    pAst1;
  char*    pAst2;
S
Shengliang Guan 已提交
491
} SMCreateStbReq;
D
dapan1121 已提交
492

S
Shengliang Guan 已提交
493 494
int32_t tSerializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
int32_t tDeserializeSMCreateStbReq(void* buf, int32_t bufLen, SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
495
void    tFreeSMCreateStbReq(SMCreateStbReq* pReq);
S
Shengliang Guan 已提交
496

497 498 499 500 501 502 503 504
typedef struct {
  STableMetaRsp* pMeta;
} SMCreateStbRsp;

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

D
dapan1121 已提交
505
typedef struct {
506 507 508 509 510
  char     name[TSDB_TABLE_FNAME_LEN];
  int8_t   igNotExists;
  int8_t   source;  // 1-taosX or 0-taosClient
  int8_t   reserved[6];
  tb_uid_t suid;
S
Shengliang Guan 已提交
511
} SMDropStbReq;
S
Shengliang Guan 已提交
512

S
Shengliang Guan 已提交
513 514
int32_t tSerializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
int32_t tDeserializeSMDropStbReq(void* buf, int32_t bufLen, SMDropStbReq* pReq);
S
Shengliang Guan 已提交
515

S
Shengliang Guan 已提交
516 517 518
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
S
Shengliang Guan 已提交
519 520
  int32_t numOfFields;
  SArray* pFields;
X
Xiaoyu Wang 已提交
521 522 523
  int32_t ttl;
  int32_t commentLen;
  char*   comment;
S
Shengliang Guan 已提交
524
} SMAlterStbReq;
D
dapan1121 已提交
525

S
Shengliang Guan 已提交
526 527 528
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 已提交
529 530

typedef struct SEpSet {
531 532 533
  int8_t inUse;
  int8_t numOfEps;
  SEp    eps[TSDB_MAX_REPLICA];
D
dapan1121 已提交
534 535
} SEpSet;

H
Hongze Cheng 已提交
536 537
int32_t tEncodeSEpSet(SEncoder* pEncoder, const SEpSet* pEp);
int32_t tDecodeSEpSet(SDecoder* pDecoder, SEpSet* pEp);
S
Shengliang Guan 已提交
538
int32_t taosEncodeSEpSet(void** buf, const SEpSet* pEp);
539
void*   taosDecodeSEpSet(const void* buf, SEpSet* pEp);
L
Liu Jicong 已提交
540

541 542
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 已提交
543

D
dapan1121 已提交
544
typedef struct {
L
Liu Jicong 已提交
545
  int8_t  connType;
D
dapan1121 已提交
546
  int32_t pid;
S
Shengliang Guan 已提交
547 548
  char    app[TSDB_APP_NAME_LEN];
  char    db[TSDB_DB_NAME_LEN];
dengyihao's avatar
dengyihao 已提交
549 550
  char    user[TSDB_USER_LEN];
  char    passwd[TSDB_PASSWORD_LEN];
551
  int64_t startTime;
S
Shengliang Guan 已提交
552
} SConnectReq;
L
Liu Jicong 已提交
553

S
Shengliang Guan 已提交
554 555
int32_t tSerializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
int32_t tDeserializeSConnectReq(void* buf, int32_t bufLen, SConnectReq* pReq);
556

L
Liu Jicong 已提交
557
typedef struct {
558 559
  int32_t  acctId;
  int64_t  clusterId;
D
dapan1121 已提交
560
  uint32_t connId;
D
dapan 已提交
561
  int32_t  dnodeNum;
562
  int8_t   superUser;
563
  int8_t   sysInfo;
564 565
  int8_t   connType;
  SEpSet   epSet;
dengyihao's avatar
dengyihao 已提交
566
  int32_t  svrTimestamp;
D
dapan1121 已提交
567 568
  char     sVer[TSDB_VERSION_LEN];
  char     sDetailVer[128];
L
Liu Jicong 已提交
569
} SConnectRsp;
L
Liu Jicong 已提交
570

S
Shengliang Guan 已提交
571 572 573
int32_t tSerializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);
int32_t tDeserializeSConnectRsp(void* buf, int32_t bufLen, SConnectRsp* pRsp);

L
Liu Jicong 已提交
574 575 576 577 578 579 580 581
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
582
  int64_t maxStorage;
L
Liu Jicong 已提交
583
} SCreateAcctReq, SAlterAcctReq;
L
Liu Jicong 已提交
584

S
Shengliang Guan 已提交
585 586
int32_t tSerializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
int32_t tDeserializeSCreateAcctReq(void* buf, int32_t bufLen, SCreateAcctReq* pReq);
S
Shengliang Guan 已提交
587

L
Liu Jicong 已提交
588 589 590
typedef struct {
  char user[TSDB_USER_LEN];
} SDropUserReq, SDropAcctReq;
D
dapan1121 已提交
591

S
Shengliang Guan 已提交
592 593
int32_t tSerializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
int32_t tDeserializeSDropUserReq(void* buf, int32_t bufLen, SDropUserReq* pReq);
S
Shengliang Guan 已提交
594

D
dapan1121 已提交
595
typedef struct {
S
Shengliang Guan 已提交
596 597
  int8_t createType;
  int8_t superUser;  // denote if it is a super user or not
598 599
  int8_t sysInfo;
  int8_t enable;
S
Shengliang Guan 已提交
600
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
601
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
602 603
} SCreateUserReq;

S
Shengliang Guan 已提交
604 605
int32_t tSerializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
int32_t tDeserializeSCreateUserReq(void* buf, int32_t bufLen, SCreateUserReq* pReq);
S
Shengliang Guan 已提交
606 607 608

typedef struct {
  int8_t alterType;
S
Shengliang Guan 已提交
609
  int8_t superUser;
610 611
  int8_t sysInfo;
  int8_t enable;
S
Shengliang Guan 已提交
612
  char   user[TSDB_USER_LEN];
S
Shengliang Guan 已提交
613
  char   pass[TSDB_USET_PASSWORD_LEN];
S
Shengliang Guan 已提交
614 615 616
  char   dbname[TSDB_DB_FNAME_LEN];
} SAlterUserReq;

S
Shengliang Guan 已提交
617 618
int32_t tSerializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
int32_t tDeserializeSAlterUserReq(void* buf, int32_t bufLen, SAlterUserReq* pReq);
D
dapan1121 已提交
619

S
Shengliang Guan 已提交
620 621 622 623
typedef struct {
  char user[TSDB_USER_LEN];
} SGetUserAuthReq;

S
Shengliang Guan 已提交
624 625
int32_t tSerializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
int32_t tDeserializeSGetUserAuthReq(void* buf, int32_t bufLen, SGetUserAuthReq* pReq);
S
Shengliang Guan 已提交
626 627 628

typedef struct {
  char      user[TSDB_USER_LEN];
D
dapan 已提交
629
  int32_t   version;
S
Shengliang Guan 已提交
630
  int8_t    superAuth;
631 632 633
  int8_t    sysInfo;
  int8_t    enable;
  int8_t    reserve;
D
dapan 已提交
634
  SHashObj* createdDbs;
S
Shengliang Guan 已提交
635 636 637 638
  SHashObj* readDbs;
  SHashObj* writeDbs;
} SGetUserAuthRsp;

S
Shengliang Guan 已提交
639 640
int32_t tSerializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
int32_t tDeserializeSGetUserAuthRsp(void* buf, int32_t bufLen, SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
641
void    tFreeSGetUserAuthRsp(SGetUserAuthRsp* pRsp);
S
Shengliang Guan 已提交
642

S
Shengliang Guan 已提交
643
typedef struct {
D
dapan1121 已提交
644 645
  int16_t lowerRelOptr;
  int16_t upperRelOptr;
S
Shengliang Guan 已提交
646
  int16_t filterstr;  // denote if current column is char(binary/nchar)
D
dapan1121 已提交
647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663

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

S
Shengliang Guan 已提交
664
typedef struct {
S
Shengliang Guan 已提交
665 666 667
  int16_t numOfFilters;
  union {
    int64_t            placeholder;
H
Hongze Cheng 已提交
668
    SColumnFilterInfo* filterInfo;
D
dapan1121 已提交
669 670 671
  };
} SColumnFilterList;
/*
L
Liu Jicong 已提交
672
 * for client side struct, only column id, type, bytes are necessary
D
dapan1121 已提交
673 674
 * But for data in vnode side, we need all the following information.
 */
S
Shengliang Guan 已提交
675
typedef struct {
H
Haojun Liao 已提交
676
  union {
677 678
    col_id_t colId;
    int16_t  slotId;
H
Haojun Liao 已提交
679
  };
680
  bool output;  // TODO remove it later
H
Haojun Liao 已提交
681

682
  int8_t  type;
L
Liu Jicong 已提交
683 684 685
  int32_t bytes;
  uint8_t precision;
  uint8_t scale;
D
dapan1121 已提交
686 687 688 689 690 691 692 693
} SColumnInfo;

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

typedef struct {
S
Shengliang Guan 已提交
694 695 696 697
  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 已提交
698 699
} STsBufInfo;

S
Shengliang Guan 已提交
700
typedef struct {
S
Shengliang Guan 已提交
701
  int32_t tz;  // query client timezone
D
dapan1121 已提交
702 703
  char    intervalUnit;
  char    slidingUnit;
704
  char    offsetUnit;
H
Haojun Liao 已提交
705
  int8_t  precision;
D
dapan1121 已提交
706 707 708 709 710 711
  int64_t interval;
  int64_t sliding;
  int64_t offset;
} SInterval;

typedef struct {
S
Shengliang Guan 已提交
712
  int32_t code;
D
dapan1121 已提交
713 714 715
  char    tbFName[TSDB_TABLE_FNAME_LEN];
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
716
  int64_t affectedRows;
D
dapan1121 已提交
717 718
} SQueryTableRsp;

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

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

D
dapan1121 已提交
723 724 725 726 727 728
typedef struct {
  SMsgHead header;
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
} STableCfgReq;

D
dapan1121 已提交
729 730 731 732 733 734 735 736 737 738 739 740
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 已提交
741 742 743
  SArray*  pFuncs;
  int32_t  commentLen;
  char*    pComment;
D
dapan1121 已提交
744
  SSchema* pSchemas;
D
dapan1121 已提交
745 746
  int32_t  tagsLen;
  char*    pTags;
D
dapan1121 已提交
747 748
} STableCfg;

D
dapan1121 已提交
749 750
typedef STableCfg STableCfgRsp;

L
Liu Jicong 已提交
751 752
int32_t tSerializeSTableCfgReq(void* buf, int32_t bufLen, STableCfgReq* pReq);
int32_t tDeserializeSTableCfgReq(void* buf, int32_t bufLen, STableCfgReq* pReq);
D
dapan1121 已提交
753

L
Liu Jicong 已提交
754 755 756
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 已提交
757

D
dapan1121 已提交
758
typedef struct {
759
  char    db[TSDB_DB_FNAME_LEN];
760
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
761 762 763 764
  int32_t numOfStables;  // single_stable
  int32_t buffer;        // MB
  int32_t pageSize;
  int32_t pages;
765
  int32_t cacheLastSize;
S
Shengliang Guan 已提交
766 767 768 769
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
S
Shengliang Guan 已提交
770 771
  int32_t minRows;
  int32_t maxRows;
772
  int32_t walFsyncPeriod;
S
Shengliang Guan 已提交
773
  int8_t  walLevel;
S
Shengliang Guan 已提交
774 775 776
  int8_t  precision;  // time resolution
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
777
  int8_t  strict;
778
  int8_t  cacheLast;
X
Xiaoyu Wang 已提交
779
  int8_t  schemaless;
S
Shengliang Guan 已提交
780
  int8_t  ignoreExist;
S
Shengliang Guan 已提交
781 782
  int32_t numOfRetensions;
  SArray* pRetensions;  // SRetention
X
Xiaoyu Wang 已提交
783
  int32_t walRetentionPeriod;
784
  int64_t walRetentionSize;
X
Xiaoyu Wang 已提交
785
  int32_t walRollPeriod;
786
  int64_t walSegmentSize;
787
  int32_t sstTrigger;
788 789
  int16_t hashPrefix;
  int16_t hashSuffix;
790
  int32_t tsdbPageSize;
S
Shengliang Guan 已提交
791
} SCreateDbReq;
S
Shengliang Guan 已提交
792

S
Shengliang Guan 已提交
793 794
int32_t tSerializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
int32_t tDeserializeSCreateDbReq(void* buf, int32_t bufLen, SCreateDbReq* pReq);
S
Shengliang Guan 已提交
795
void    tFreeSCreateDbReq(SCreateDbReq* pReq);
S
Shengliang Guan 已提交
796

S
Shengliang Guan 已提交
797
typedef struct {
798
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
799 800 801
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
802
  int32_t cacheLastSize;
S
Shengliang Guan 已提交
803
  int32_t daysPerFile;
S
Shengliang Guan 已提交
804 805 806
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
807
  int32_t walFsyncPeriod;
S
Shengliang Guan 已提交
808
  int8_t  walLevel;
S
Shengliang Guan 已提交
809
  int8_t  strict;
810
  int8_t  cacheLast;
X
Xiaoyu Wang 已提交
811
  int8_t  replications;
812
  int32_t sstTrigger;
S
Shengliang Guan 已提交
813
} SAlterDbReq;
S
Shengliang Guan 已提交
814

S
Shengliang Guan 已提交
815 816 817
int32_t tSerializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);
int32_t tDeserializeSAlterDbReq(void* buf, int32_t bufLen, SAlterDbReq* pReq);

S
Shengliang Guan 已提交
818
typedef struct {
S
Shengliang Guan 已提交
819
  char   db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
820
  int8_t ignoreNotExists;
S
Shengliang Guan 已提交
821
} SDropDbReq;
S
Shengliang Guan 已提交
822

S
Shengliang Guan 已提交
823 824 825
int32_t tSerializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);
int32_t tDeserializeSDropDbReq(void* buf, int32_t bufLen, SDropDbReq* pReq);

S
Shengliang Guan 已提交
826
typedef struct {
L
Liu Jicong 已提交
827 828
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
S
Shengliang Guan 已提交
829 830
} SDropDbRsp;

S
Shengliang Guan 已提交
831 832 833
int32_t tSerializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);
int32_t tDeserializeSDropDbRsp(void* buf, int32_t bufLen, SDropDbRsp* pRsp);

S
Shengliang Guan 已提交
834 835
typedef struct {
  char    db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
836
  int64_t dbId;
837
  int32_t vgVersion;
L
Liu Jicong 已提交
838
  int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
S
Shengliang Guan 已提交
839
} SUseDbReq;
S
Shengliang Guan 已提交
840

S
Shengliang Guan 已提交
841 842
int32_t tSerializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
int32_t tDeserializeSUseDbReq(void* buf, int32_t bufLen, SUseDbReq* pReq);
S
Shengliang Guan 已提交
843 844

typedef struct {
L
Liu Jicong 已提交
845 846 847 848
  char    db[TSDB_DB_FNAME_LEN];
  int64_t uid;
  int32_t vgVersion;
  int32_t vgNum;
849 850
  int16_t hashPrefix;
  int16_t hashSuffix;
L
Liu Jicong 已提交
851 852
  int8_t  hashMethod;
  SArray* pVgroupInfos;  // Array of SVgroupInfo
S
Shengliang Guan 已提交
853 854
} SUseDbRsp;

L
Liu Jicong 已提交
855
int32_t tSerializeSUseDbRsp(void* buf, int32_t bufLen, const SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
856
int32_t tDeserializeSUseDbRsp(void* buf, int32_t bufLen, SUseDbRsp* pRsp);
H
Hongze Cheng 已提交
857 858
int32_t tSerializeSUseDbRspImp(SEncoder* pEncoder, const SUseDbRsp* pRsp);
int32_t tDeserializeSUseDbRspImp(SDecoder* pDecoder, SUseDbRsp* pRsp);
S
Shengliang Guan 已提交
859 860
void    tFreeSUsedbRsp(SUseDbRsp* pRsp);

D
dapan1121 已提交
861
typedef struct {
dengyihao's avatar
dengyihao 已提交
862
  char db[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
863 864 865 866 867
} SDbCfgReq;

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

X
Xiaoyu Wang 已提交
868 869 870 871 872 873 874
typedef struct {
  char db[TSDB_DB_FNAME_LEN];
} STrimDbReq;

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

S
Shengliang Guan 已提交
875 876 877 878 879 880 881 882 883 884 885 886 887 888
typedef struct {
  int32_t timestamp;
} SVTrimDbReq;

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

typedef struct {
  int32_t timestamp;
} SVDropTtlTableReq;

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

D
dapan1121 已提交
889 890
typedef struct {
  int32_t numOfVgroups;
S
Shengliang Guan 已提交
891 892 893 894
  int32_t numOfStables;
  int32_t buffer;
  int32_t pageSize;
  int32_t pages;
D
dapan1121 已提交
895 896 897 898 899 900
  int32_t daysPerFile;
  int32_t daysToKeep0;
  int32_t daysToKeep1;
  int32_t daysToKeep2;
  int32_t minRows;
  int32_t maxRows;
901
  int32_t walFsyncPeriod;
D
dapan1121 已提交
902 903 904 905
  int8_t  walLevel;
  int8_t  precision;
  int8_t  compression;
  int8_t  replications;
S
Shengliang Guan 已提交
906
  int8_t  strict;
907
  int8_t  cacheLast;
908 909
  int32_t numOfRetensions;
  SArray* pRetensions;
wmmhello's avatar
wmmhello 已提交
910
  int8_t  schemaless;
D
dapan1121 已提交
911 912 913 914 915
} SDbCfgRsp;

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

D
dapan1121 已提交
916 917 918 919 920 921 922
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 已提交
923 924 925 926 927 928 929
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 已提交
930 931 932 933 934 935 936 937 938 939 940 941 942 943
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 已提交
944 945 946 947 948
typedef struct SQueryNodeAddr {
  int32_t nodeId;  // vgId or qnodeId
  SEpSet  epSet;
} SQueryNodeAddr;

D
dapan1121 已提交
949
typedef struct {
D
dapan1121 已提交
950 951 952 953
  SQueryNodeAddr addr;
  uint64_t       load;
} SQueryNodeLoad;

D
dapan1121 已提交
954
typedef struct {
D
dapan1121 已提交
955
  SArray* qnodeList;  // SArray<SQueryNodeLoad>
D
dapan1121 已提交
956 957 958 959 960 961
} 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 已提交
962 963 964 965 966 967 968 969
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 已提交
970 971 972 973 974 975 976
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 已提交
977

D
dapan 已提交
978 979 980 981 982 983 984 985
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 已提交
986
typedef struct {
S
Shengliang Guan 已提交
987
  char db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
988
} SCompactDbReq;
S
Shengliang Guan 已提交
989

S
Shengliang Guan 已提交
990 991
int32_t tSerializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
int32_t tDeserializeSCompactDbReq(void* buf, int32_t bufLen, SCompactDbReq* pReq);
D
dapan1121 已提交
992 993

typedef struct {
S
Shengliang Guan 已提交
994
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang 已提交
995
  int8_t  igExists;
S
Shengliang Guan 已提交
996 997
  int8_t  funcType;
  int8_t  scriptType;
S
Shengliang Guan 已提交
998
  int8_t  outputType;
S
Shengliang Guan 已提交
999
  int32_t outputLen;
S
Shengliang Guan 已提交
1000
  int32_t bufSize;
1001
  int32_t codeLen;
S
Shengliang 已提交
1002
  int64_t signature;
1003 1004
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
1005
} SCreateFuncReq;
D
dapan1121 已提交
1006

S
Shengliang Guan 已提交
1007 1008
int32_t tSerializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
int32_t tDeserializeSCreateFuncReq(void* buf, int32_t bufLen, SCreateFuncReq* pReq);
1009
void    tFreeSCreateFuncReq(SCreateFuncReq* pReq);
S
Shengliang Guan 已提交
1010

D
dapan1121 已提交
1011
typedef struct {
S
Shengliang 已提交
1012 1013
  char   name[TSDB_FUNC_NAME_LEN];
  int8_t igNotExists;
S
Shengliang Guan 已提交
1014
} SDropFuncReq;
S
Shengliang Guan 已提交
1015

S
Shengliang Guan 已提交
1016 1017 1018
int32_t tSerializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);
int32_t tDeserializeSDropFuncReq(void* buf, int32_t bufLen, SDropFuncReq* pReq);

S
Shengliang Guan 已提交
1019 1020
typedef struct {
  int32_t numOfFuncs;
D
dapan1121 已提交
1021
  bool    ignoreCodeComment;
S
Shengliang Guan 已提交
1022
  SArray* pFuncNames;
S
Shengliang Guan 已提交
1023
} SRetrieveFuncReq;
D
dapan1121 已提交
1024

S
Shengliang Guan 已提交
1025 1026
int32_t tSerializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
int32_t tDeserializeSRetrieveFuncReq(void* buf, int32_t bufLen, SRetrieveFuncReq* pReq);
1027
void    tFreeSRetrieveFuncReq(SRetrieveFuncReq* pReq);
S
Shengliang Guan 已提交
1028

D
dapan1121 已提交
1029 1030
typedef struct {
  char    name[TSDB_FUNC_NAME_LEN];
S
Shengliang Guan 已提交
1031 1032 1033 1034
  int8_t  funcType;
  int8_t  scriptType;
  int8_t  outputType;
  int32_t outputLen;
D
dapan1121 已提交
1035
  int32_t bufSize;
S
Shengliang 已提交
1036
  int64_t signature;
S
Shengliang Guan 已提交
1037 1038
  int32_t commentSize;
  int32_t codeSize;
1039 1040
  char*   pComment;
  char*   pCode;
S
Shengliang Guan 已提交
1041
} SFuncInfo;
D
dapan1121 已提交
1042 1043

typedef struct {
S
Shengliang Guan 已提交
1044
  int32_t numOfFuncs;
S
Shengliang Guan 已提交
1045
  SArray* pFuncInfos;
S
Shengliang Guan 已提交
1046
} SRetrieveFuncRsp;
D
dapan1121 已提交
1047

S
Shengliang Guan 已提交
1048 1049
int32_t tSerializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
int32_t tDeserializeSRetrieveFuncRsp(void* buf, int32_t bufLen, SRetrieveFuncRsp* pRsp);
L
Liu Jicong 已提交
1050
void    tFreeSFuncInfo(SFuncInfo* pInfo);
1051
void    tFreeSRetrieveFuncRsp(SRetrieveFuncRsp* pRsp);
S
Shengliang Guan 已提交
1052

D
dapan1121 已提交
1053
typedef struct {
S
Shengliang Guan 已提交
1054
  int32_t statusInterval;
S
Shengliang Guan 已提交
1055
  int64_t checkTime;                  // 1970-01-01 00:00:00.000
S
Shengliang Guan 已提交
1056 1057 1058
  char    timezone[TD_TIMEZONE_LEN];  // tsTimezone
  char    locale[TD_LOCALE_LEN];      // tsLocale
  char    charset[TD_LOCALE_LEN];     // tsCharset
S
Shengliang Guan 已提交
1059
} SClusterCfg;
D
dapan1121 已提交
1060

1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072
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 已提交
1073 1074
typedef struct {
  int32_t vgId;
S
Shengliang Guan 已提交
1075
  int32_t syncState;
1076
  int64_t cacheUsage;
S
Shengliang Guan 已提交
1077 1078
  int64_t numOfTables;
  int64_t numOfTimeSeries;
S
Shengliang Guan 已提交
1079 1080 1081
  int64_t totalStorage;
  int64_t compStorage;
  int64_t pointsWritten;
S
Shengliang Guan 已提交
1082 1083 1084 1085 1086
  int64_t numOfSelectReqs;
  int64_t numOfInsertReqs;
  int64_t numOfInsertSuccessReqs;
  int64_t numOfBatchInsertReqs;
  int64_t numOfBatchInsertSuccessReqs;
S
Shengliang Guan 已提交
1087 1088
} SVnodeLoad;

S
Shengliang Guan 已提交
1089 1090 1091 1092
typedef struct {
  int32_t syncState;
} SMnodeLoad;

D
dapan1121 已提交
1093 1094 1095 1096 1097 1098 1099
typedef struct {
  int32_t dnodeId;
  int64_t numOfProcessedQuery;
  int64_t numOfProcessedCQuery;
  int64_t numOfProcessedFetch;
  int64_t numOfProcessedDrop;
  int64_t numOfProcessedHb;
D
dapan1121 已提交
1100
  int64_t numOfProcessedDelete;
D
dapan1121 已提交
1101 1102 1103 1104 1105 1106 1107
  int64_t cacheDataSize;
  int64_t numOfQueryInQueue;
  int64_t numOfFetchInQueue;
  int64_t timeInQueryQueue;
  int64_t timeInFetchQueue;
} SQnodeLoad;

S
Shengliang Guan 已提交
1108
typedef struct {
S
Shengliang Guan 已提交
1109 1110
  int32_t     sver;      // software version
  int64_t     dnodeVer;  // dnode table version in sdb
S
Shengliang Guan 已提交
1111
  int32_t     dnodeId;
1112
  int64_t     clusterId;
S
Shengliang Guan 已提交
1113 1114
  int64_t     rebootTime;
  int64_t     updateTime;
S
Shengliang Guan 已提交
1115
  float       numOfCores;
S
Shengliang Guan 已提交
1116
  int32_t     numOfSupportVnodes;
1117 1118
  int64_t     memTotal;
  int64_t     memAvail;
S
Shengliang Guan 已提交
1119
  char        dnodeEp[TSDB_EP_LEN];
1120
  SMnodeLoad  mload;
D
dapan1121 已提交
1121
  SQnodeLoad  qload;
S
Shengliang Guan 已提交
1122
  SClusterCfg clusterCfg;
S
Shengliang Guan 已提交
1123
  SArray*     pVloads;  // array of SVnodeLoad
S
Shengliang Guan 已提交
1124
} SStatusReq;
D
dapan1121 已提交
1125

S
Shengliang Guan 已提交
1126 1127
int32_t tSerializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
int32_t tDeserializeSStatusReq(void* buf, int32_t bufLen, SStatusReq* pReq);
S
Shengliang Guan 已提交
1128
void    tFreeSStatusReq(SStatusReq* pReq);
S
Shengliang Guan 已提交
1129

D
dapan1121 已提交
1130
typedef struct {
S
Shengliang Guan 已提交
1131
  int32_t dnodeId;
1132
  int64_t clusterId;
D
dapan1121 已提交
1133 1134 1135
} SDnodeCfg;

typedef struct {
1136 1137 1138
  int32_t id;
  int8_t  isMnode;
  SEp     ep;
D
dapan1121 已提交
1139 1140 1141
} SDnodeEp;

typedef struct {
S
Shengliang Guan 已提交
1142
  int64_t   dnodeVer;
S
Shengliang Guan 已提交
1143
  SDnodeCfg dnodeCfg;
S
Shengliang Guan 已提交
1144
  SArray*   pDnodeEps;  // Array of SDnodeEp
D
dapan1121 已提交
1145 1146
} SStatusRsp;

S
Shengliang Guan 已提交
1147 1148
int32_t tSerializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
int32_t tDeserializeSStatusRsp(void* buf, int32_t bufLen, SStatusRsp* pRsp);
S
shm  
Shengliang Guan 已提交
1149
void    tFreeSStatusRsp(SStatusRsp* pRsp);
S
Shengliang Guan 已提交
1150 1151

typedef struct {
S
Shengliang Guan 已提交
1152 1153 1154 1155 1156
  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 已提交
1157

D
dapan1121 已提交
1158
typedef struct {
S
Shengliang Guan 已提交
1159 1160 1161
  int32_t  id;
  uint16_t port;                 // node sync Port
  char     fqdn[TSDB_FQDN_LEN];  // node FQDN
S
Shengliang Guan 已提交
1162 1163 1164
} SReplica;

typedef struct {
S
Shengliang Guan 已提交
1165
  int32_t  vgId;
1166
  char     db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1167
  int64_t  dbUid;
1168
  int32_t  vgVersion;
L
Liu Jicong 已提交
1169
  int32_t  numOfStables;
S
Shengliang Guan 已提交
1170 1171 1172
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
1173
  int32_t  cacheLastSize;
S
Shengliang Guan 已提交
1174 1175 1176 1177
  int32_t  daysPerFile;
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
S
Shengliang Guan 已提交
1178 1179
  int32_t  minRows;
  int32_t  maxRows;
1180
  int32_t  walFsyncPeriod;
D
dapan1121 已提交
1181 1182
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1183
  int8_t   hashMethod;
S
Shengliang Guan 已提交
1184
  int8_t   walLevel;
S
Shengliang Guan 已提交
1185 1186
  int8_t   precision;
  int8_t   compression;
S
Shengliang Guan 已提交
1187
  int8_t   strict;
1188
  int8_t   cacheLast;
1189 1190
  int8_t   isTsma;
  int8_t   standby;
S
Shengliang Guan 已提交
1191
  int8_t   replica;
S
Shengliang Guan 已提交
1192 1193
  int8_t   selfIndex;
  SReplica replicas[TSDB_MAX_REPLICA];
S
sma  
Shengliang Guan 已提交
1194 1195
  int32_t  numOfRetensions;
  SArray*  pRetensions;  // SRetention
1196
  void*    pTsma;
S
Shengliang Guan 已提交
1197
  int32_t  walRetentionPeriod;
L
Liu Jicong 已提交
1198
  int64_t  walRetentionSize;
S
Shengliang Guan 已提交
1199
  int32_t  walRollPeriod;
L
Liu Jicong 已提交
1200
  int64_t  walSegmentSize;
1201
  int16_t  sstTrigger;
1202 1203
  int16_t  hashPrefix;
  int16_t  hashSuffix;
1204
  int32_t  tsdbPageSize;
S
Shengliang Guan 已提交
1205
} SCreateVnodeReq;
D
dapan1121 已提交
1206

S
Shengliang Guan 已提交
1207 1208
int32_t tSerializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
int32_t tDeserializeSCreateVnodeReq(void* buf, int32_t bufLen, SCreateVnodeReq* pReq);
S
sma  
Shengliang Guan 已提交
1209
int32_t tFreeSCreateVnodeReq(SCreateVnodeReq* pReq);
S
Shengliang Guan 已提交
1210

S
Shengliang Guan 已提交
1211
typedef struct {
L
Liu Jicong 已提交
1212 1213 1214 1215
  int32_t vgId;
  int32_t dnodeId;
  int64_t dbUid;
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1216
} SDropVnodeReq;
S
Shengliang Guan 已提交
1217

S
Shengliang Guan 已提交
1218 1219
int32_t tSerializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
int32_t tDeserializeSDropVnodeReq(void* buf, int32_t bufLen, SDropVnodeReq* pReq);
S
Shengliang Guan 已提交
1220

S
Shengliang Guan 已提交
1221 1222 1223 1224 1225 1226 1227 1228 1229 1230
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 已提交
1231 1232 1233
  int32_t  buffer;
  int32_t  pageSize;
  int32_t  pages;
1234
  int32_t  cacheLastSize;
S
Shengliang Guan 已提交
1235
  int32_t  daysPerFile;
S
Shengliang Guan 已提交
1236 1237 1238
  int32_t  daysToKeep0;
  int32_t  daysToKeep1;
  int32_t  daysToKeep2;
1239
  int32_t  walFsyncPeriod;
S
Shengliang Guan 已提交
1240 1241
  int8_t   walLevel;
  int8_t   strict;
1242
  int8_t   cacheLast;
S
Shengliang Guan 已提交
1243
  int8_t   selfIndex;
1244
  int8_t   replica;
S
Shengliang Guan 已提交
1245 1246 1247 1248 1249 1250
  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 已提交
1251
typedef struct {
D
dapan1121 已提交
1252
  SMsgHead header;
D
dapan1121 已提交
1253 1254
  char     dbFName[TSDB_DB_FNAME_LEN];
  char     tbName[TSDB_TABLE_NAME_LEN];
S
Shengliang Guan 已提交
1255
} STableInfoReq;
D
dapan1121 已提交
1256

S
Shengliang Guan 已提交
1257 1258 1259
int32_t tSerializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);
int32_t tDeserializeSTableInfoReq(void* buf, int32_t bufLen, STableInfoReq* pReq);

D
dapan1121 已提交
1260
typedef struct {
S
Shengliang Guan 已提交
1261
  int8_t  metaClone;  // create local clone of the cached table meta
D
dapan1121 已提交
1262 1263 1264 1265
  int32_t numOfVgroups;
  int32_t numOfTables;
  int32_t numOfUdfs;
  char    tableNames[];
S
Shengliang Guan 已提交
1266
} SMultiTableInfoReq;
D
dapan1121 已提交
1267

H
Haojun Liao 已提交
1268
// todo refactor
D
dapan1121 已提交
1269
typedef struct SVgroupInfo {
1270 1271 1272
  int32_t  vgId;
  uint32_t hashBegin;
  uint32_t hashEnd;
L
Liu Jicong 已提交
1273
  SEpSet   epSet;
L
Liu Jicong 已提交
1274 1275 1276 1277
  union {
    int32_t numOfTable;  // unit is TSDB_TABLE_NUM_UNIT
    int32_t taskId;      // used in stream
  };
D
dapan1121 已提交
1278 1279
} SVgroupInfo;

D
dapan1121 已提交
1280
typedef struct {
H
Haojun Liao 已提交
1281 1282
  int32_t     numOfVgroups;
  SVgroupInfo vgroups[];
S
Shengliang Guan 已提交
1283
} SVgroupsInfo;
D
dapan1121 已提交
1284

C
Cary Xu 已提交
1285
typedef struct {
D
dapan1121 已提交
1286 1287 1288
  STableMetaRsp* pMeta;
} SMAlterStbRsp;

C
Cary Xu 已提交
1289 1290 1291
int32_t tEncodeSMAlterStbRsp(SEncoder* pEncoder, const SMAlterStbRsp* pRsp);
int32_t tDecodeSMAlterStbRsp(SDecoder* pDecoder, SMAlterStbRsp* pRsp);
void    tFreeSMAlterStbRsp(SMAlterStbRsp* pRsp);
D
dapan1121 已提交
1292

S
Shengliang Guan 已提交
1293 1294
int32_t tSerializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
int32_t tDeserializeSTableMetaRsp(void* buf, int32_t bufLen, STableMetaRsp* pRsp);
1295
void    tFreeSTableMetaRsp(void* pRsp);
X
Xiaoyu Wang 已提交
1296
void    tFreeSTableIndexRsp(void* info);
S
Shengliang Guan 已提交
1297 1298

typedef struct {
X
Xiaoyu Wang 已提交
1299 1300
  SArray* pMetaRsp;   // Array of STableMetaRsp
  SArray* pIndexRsp;  // Array of STableIndexRsp;
D
dapan1121 已提交
1301
} SSTbHbRsp;
S
Shengliang Guan 已提交
1302

D
dapan1121 已提交
1303 1304 1305
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 已提交
1306

S
Shengliang Guan 已提交
1307
typedef struct {
S
Shengliang Guan 已提交
1308 1309 1310 1311 1312 1313 1314 1315
  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 已提交
1316 1317 1318 1319 1320
} SMultiTableMeta;

typedef struct {
  int32_t dataLen;
  char    name[TSDB_TABLE_FNAME_LEN];
H
Hongze Cheng 已提交
1321
  char*   data;
D
dapan1121 已提交
1322 1323
} STagData;

X
Xiaoyu Wang 已提交
1324 1325 1326 1327 1328 1329 1330
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 已提交
1331
typedef struct {
1332 1333
  char name[TSDB_CONFIG_OPTION_LEN + 1];
  char value[TSDB_CONFIG_VALUE_LEN + 1];
D
dapan1121 已提交
1334 1335 1336
} SVariablesInfo;

typedef struct {
1337
  SArray* variables;  // SArray<SVariablesInfo>
D
dapan1121 已提交
1338 1339 1340 1341 1342 1343 1344
} 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 已提交
1345 1346 1347 1348 1349 1350
/*
 * sql: show tables like '%a_%'
 * payload is the query condition, e.g., '%a_%'
 * payloadLen is the length of payload
 */
typedef struct {
L
Liu Jicong 已提交
1351
  int32_t type;
1352
  char    db[TSDB_DB_FNAME_LEN];
S
Shengliang Guan 已提交
1353 1354
  int32_t payloadLen;
  char*   payload;
S
Shengliang Guan 已提交
1355
} SShowReq;
D
dapan1121 已提交
1356

S
Shengliang Guan 已提交
1357 1358 1359 1360
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 已提交
1361
typedef struct {
1362
  int64_t       showId;
S
Shengliang Guan 已提交
1363
  STableMetaRsp tableMeta;
S
Shengliang Guan 已提交
1364
} SShowRsp, SVShowTablesRsp;
D
dapan1121 已提交
1365

S
Shengliang Guan 已提交
1366 1367 1368
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 已提交
1369

1370
typedef struct {
1371
  char    db[TSDB_DB_FNAME_LEN];
H
Haojun Liao 已提交
1372
  char    tb[TSDB_TABLE_NAME_LEN];
1373
  char    user[TSDB_USER_LEN];
1374 1375 1376
  int64_t showId;
} SRetrieveTableReq;

1377 1378 1379 1380 1381 1382
typedef struct SSysTableSchema {
  int8_t   type;
  col_id_t colId;
  int32_t  bytes;
} SSysTableSchema;

1383 1384 1385 1386 1387 1388 1389 1390
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 已提交
1391
  int8_t  streamBlockType;
1392
  int32_t compLen;
1393
  int32_t numOfBlocks;
1394
  int32_t numOfRows;
1395
  int32_t numOfCols;
1396 1397
  int64_t skey;
  int64_t ekey;
1398 1399
  int64_t version;    // for stream
  TSKEY   watermark;  // for stream
1400 1401 1402
  char    data[];
} SRetrieveTableRsp;

H
Haojun Liao 已提交
1403
typedef struct {
L
Liu Jicong 已提交
1404 1405 1406 1407 1408 1409 1410 1411
  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 已提交
1412 1413
} SRetrieveMetaTableRsp;

D
dapan1121 已提交
1414
typedef struct SExplainExecInfo {
1415 1416
  double   startupCost;
  double   totalCost;
D
dapan1121 已提交
1417
  uint64_t numOfRows;
1418
  uint32_t verboseLen;
dengyihao's avatar
dengyihao 已提交
1419
  void*    verboseInfo;
D
dapan1121 已提交
1420 1421
} SExplainExecInfo;

D
dapan1121 已提交
1422
typedef struct {
D
dapan1121 已提交
1423
  int32_t           numOfPlans;
dengyihao's avatar
dengyihao 已提交
1424
  SExplainExecInfo* subplanInfo;
D
dapan1121 已提交
1425 1426
} SExplainRsp;

1427 1428 1429 1430 1431 1432 1433 1434
typedef struct {
  SExplainRsp rsp;
  uint64_t qId; 
  uint64_t tId; 
  int64_t rId; 
  int32_t eId;
} SExplainLocalRsp;

1435 1436 1437 1438 1439 1440 1441 1442 1443
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;
1444
  double   filterTime;
1445 1446
} STableScanAnalyzeInfo;

D
dapan1121 已提交
1447 1448
int32_t tSerializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
int32_t tDeserializeSExplainRsp(void* buf, int32_t bufLen, SExplainRsp* pRsp);
1449
void tFreeSExplainRsp(SExplainRsp *pRsp);
D
dapan1121 已提交
1450

D
dapan1121 已提交
1451
typedef struct {
S
Shengliang Guan 已提交
1452
  char    fqdn[TSDB_FQDN_LEN];  // end point, hostname:port
1453
  int32_t port;
S
Shengliang Guan 已提交
1454
} SCreateDnodeReq;
S
Shengliang Guan 已提交
1455

S
Shengliang Guan 已提交
1456 1457 1458
int32_t tSerializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);
int32_t tDeserializeSCreateDnodeReq(void* buf, int32_t bufLen, SCreateDnodeReq* pReq);

S
Shengliang Guan 已提交
1459 1460
typedef struct {
  int32_t dnodeId;
1461 1462
  char    fqdn[TSDB_FQDN_LEN];
  int32_t port;
S
Shengliang Guan 已提交
1463
} SDropDnodeReq;
S
Shengliang Guan 已提交
1464

S
Shengliang Guan 已提交
1465 1466 1467
int32_t tSerializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);
int32_t tDeserializeSDropDnodeReq(void* buf, int32_t bufLen, SDropDnodeReq* pReq);

S
Shengliang Guan 已提交
1468 1469
typedef struct {
  int32_t dnodeId;
1470
  char    config[TSDB_DNODE_CONFIG_LEN];
S
Shengliang Guan 已提交
1471
  char    value[TSDB_DNODE_VALUE_LEN];
S
Shengliang Guan 已提交
1472
} SMCfgDnodeReq;
D
dapan1121 已提交
1473

S
Shengliang Guan 已提交
1474 1475 1476
int32_t tSerializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);
int32_t tDeserializeSMCfgDnodeReq(void* buf, int32_t bufLen, SMCfgDnodeReq* pReq);

S
Shengliang Guan 已提交
1477 1478 1479 1480 1481 1482 1483 1484
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 已提交
1485 1486
typedef struct {
  int32_t dnodeId;
dengyihao's avatar
dengyihao 已提交
1487 1488 1489
} SMCreateMnodeReq, SMDropMnodeReq, SDDropMnodeReq, SMCreateQnodeReq, SMDropQnodeReq, SDCreateQnodeReq, SDDropQnodeReq,
    SMCreateSnodeReq, SMDropSnodeReq, SDCreateSnodeReq, SDDropSnodeReq, SMCreateBnodeReq, SMDropBnodeReq,
    SDCreateBnodeReq, SDDropBnodeReq;
S
Shengliang Guan 已提交
1490

1491 1492
int32_t tSerializeSCreateDropMQSBNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
int32_t tDeserializeSCreateDropMQSBNodeReq(void* buf, int32_t bufLen, SMCreateQnodeReq* pReq);
S
Shengliang Guan 已提交
1493

D
dapan1121 已提交
1494
typedef struct {
S
Shengliang Guan 已提交
1495
  int8_t   replica;
S
Shengliang Guan 已提交
1496
  SReplica replicas[TSDB_MAX_REPLICA];
S
Shengliang Guan 已提交
1497
} SDCreateMnodeReq, SDAlterMnodeReq;
D
dapan1121 已提交
1498

S
Shengliang Guan 已提交
1499 1500 1501
int32_t tSerializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);
int32_t tDeserializeSDCreateMnodeReq(void* buf, int32_t bufLen, SDCreateMnodeReq* pReq);

1502 1503 1504 1505 1506 1507 1508 1509
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 已提交
1510
typedef struct {
X
Xiaoyu Wang 已提交
1511
  char queryStrId[TSDB_QUERY_ID_LEN];
S
Shengliang Guan 已提交
1512
} SKillQueryReq;
S
Shengliang Guan 已提交
1513

S
Shengliang Guan 已提交
1514 1515 1516
int32_t tSerializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);
int32_t tDeserializeSKillQueryReq(void* buf, int32_t bufLen, SKillQueryReq* pReq);

S
Shengliang Guan 已提交
1517
typedef struct {
D
dapan1121 已提交
1518
  uint32_t connId;
S
Shengliang Guan 已提交
1519
} SKillConnReq;
D
dapan1121 已提交
1520

S
Shengliang Guan 已提交
1521 1522 1523
int32_t tSerializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);
int32_t tDeserializeSKillConnReq(void* buf, int32_t bufLen, SKillConnReq* pReq);

S
Shengliang Guan 已提交
1524 1525 1526 1527 1528 1529 1530
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 已提交
1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555
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);

1556 1557 1558 1559 1560 1561 1562
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 已提交
1563 1564 1565 1566
typedef struct {
  char user[TSDB_USER_LEN];
  char spi;
  char encrypt;
1567 1568
  char secret[TSDB_PASSWORD_LEN];
  char ckey[TSDB_PASSWORD_LEN];
S
Shengliang Guan 已提交
1569
} SAuthReq, SAuthRsp;
D
dapan1121 已提交
1570

S
Shengliang Guan 已提交
1571 1572 1573
int32_t tSerializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);
int32_t tDeserializeSAuthReq(void* buf, int32_t bufLen, SAuthReq* pReq);

D
dapan1121 已提交
1574
typedef struct {
S
Shengliang Guan 已提交
1575
  int32_t statusCode;
S
Shengliang Guan 已提交
1576
  char    details[1024];
S
Shengliang Guan 已提交
1577 1578 1579 1580
} SServerStatusRsp;

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

1582 1583 1584 1585 1586 1587 1588
/**
 * 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 已提交
1589
typedef struct SSubQueryMsg {
D
dapan1121 已提交
1590
  SMsgHead header;
D
dapan1121 已提交
1591
  uint64_t sId;
H
Hongze Cheng 已提交
1592 1593
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1594
  int64_t  refId;
D
dapan1121 已提交
1595
  int32_t  execId;
D
dapan1121 已提交
1596
  int8_t   taskType;
D
dapan1121 已提交
1597
  int8_t   explain;
D
dapan1121 已提交
1598
  int8_t   needFetch;
1599
  uint32_t sqlLen;  // the query sql,
1600
  uint32_t phyLen;
H
Hongze Cheng 已提交
1601
  char     msg[];
D
dapan1121 已提交
1602
} SSubQueryMsg;
D
dapan 已提交
1603

1604 1605 1606 1607 1608 1609 1610
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
} SSinkDataReq;

D
dapan1121 已提交
1611 1612 1613 1614 1615
typedef struct {
  SMsgHead header;
  uint64_t sId;
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1616
  int32_t  execId;
D
dapan1121 已提交
1617 1618
} SQueryContinueReq;

S
Shengliang Guan 已提交
1619
typedef struct {
D
dapan1121 已提交
1620
  SMsgHead header;
D
dapan1121 已提交
1621
  uint64_t sId;
H
Hongze Cheng 已提交
1622 1623
  uint64_t queryId;
  uint64_t taskId;
S
Shengliang Guan 已提交
1624
} SResReadyReq;
D
dapan 已提交
1625

S
Shengliang Guan 已提交
1626
typedef struct {
D
dapan1121 已提交
1627
  int32_t code;
L
Liu Jicong 已提交
1628
  char    tbFName[TSDB_TABLE_FNAME_LEN];
1629 1630
  int32_t sversion;
  int32_t tversion;
D
dapan1121 已提交
1631 1632
} SResReadyRsp;

S
Shengliang Guan 已提交
1633
typedef struct {
D
dapan1121 已提交
1634
  SMsgHead header;
D
dapan1121 已提交
1635
  uint64_t sId;
H
Hongze Cheng 已提交
1636 1637
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1638
  int32_t  execId;
S
Shengliang Guan 已提交
1639
} SResFetchReq;
D
dapan 已提交
1640

S
Shengliang Guan 已提交
1641
typedef struct {
D
dapan1121 已提交
1642
  SMsgHead header;
D
dapan1121 已提交
1643
  uint64_t sId;
S
Shengliang Guan 已提交
1644
} SSchTasksStatusReq;
D
dapan1121 已提交
1645

S
Shengliang Guan 已提交
1646
typedef struct {
H
Hongze Cheng 已提交
1647 1648
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1649
  int64_t  refId;
D
dapan1121 已提交
1650
  int32_t  execId;
H
Hongze Cheng 已提交
1651
  int8_t   status;
D
dapan1121 已提交
1652 1653
} STaskStatus;

S
Shengliang Guan 已提交
1654
typedef struct {
L
Liu Jicong 已提交
1655 1656
  int64_t refId;
  SArray* taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1657 1658
} SSchedulerStatusRsp;

D
dapan1121 已提交
1659 1660 1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673
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 已提交
1674
  SArray*        taskAction;  // SArray<STaskAction>
D
dapan1121 已提交
1675 1676
} SSchedulerHbReq;

L
Liu Jicong 已提交
1677 1678 1679
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 已提交
1680 1681 1682

typedef struct {
  SQueryNodeEpId epId;
L
Liu Jicong 已提交
1683
  SArray*        taskStatus;  // SArray<STaskStatus>
D
dapan1121 已提交
1684 1685
} SSchedulerHbRsp;

L
Liu Jicong 已提交
1686 1687 1688
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 已提交
1689

S
Shengliang Guan 已提交
1690
typedef struct {
D
dapan1121 已提交
1691
  SMsgHead header;
D
dapan1121 已提交
1692
  uint64_t sId;
H
Hongze Cheng 已提交
1693 1694
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1695
  int64_t  refId;
D
dapan1121 已提交
1696
  int32_t  execId;
S
Shengliang Guan 已提交
1697
} STaskCancelReq;
D
dapan1121 已提交
1698

S
Shengliang Guan 已提交
1699
typedef struct {
D
dapan1121 已提交
1700 1701 1702
  int32_t code;
} STaskCancelRsp;

S
Shengliang Guan 已提交
1703
typedef struct {
D
dapan1121 已提交
1704
  SMsgHead header;
D
dapan1121 已提交
1705
  uint64_t sId;
H
Hongze Cheng 已提交
1706 1707
  uint64_t queryId;
  uint64_t taskId;
D
dapan1121 已提交
1708
  int64_t  refId;
D
dapan1121 已提交
1709
  int32_t  execId;
S
Shengliang Guan 已提交
1710
} STaskDropReq;
D
dapan1121 已提交
1711

S
Shengliang Guan 已提交
1712
typedef struct {
D
dapan1121 已提交
1713 1714 1715
  int32_t code;
} STaskDropRsp;

X
Xiaoyu Wang 已提交
1716 1717 1718
#define STREAM_TRIGGER_AT_ONCE        1
#define STREAM_TRIGGER_WINDOW_CLOSE   2
#define STREAM_TRIGGER_MAX_DELAY      3
X
Xiaoyu Wang 已提交
1719
#define STREAM_DEFAULT_IGNORE_EXPIRED 0
X
Xiaoyu Wang 已提交
1720

L
Liu Jicong 已提交
1721
typedef struct {
L
Liu Jicong 已提交
1722
  char    name[TSDB_STREAM_FNAME_LEN];
L
Liu Jicong 已提交
1723 1724
  char    sourceDB[TSDB_DB_FNAME_LEN];
  char    targetStbFullName[TSDB_TABLE_FNAME_LEN];
1725 1726 1727 1728
  int8_t  igExists;
  char*   sql;
  char*   ast;
  int8_t  triggerType;
1729
  int64_t maxDelay;
X
Xiaoyu Wang 已提交
1730
  int64_t watermark;
1731
  int8_t  igExpired;
L
Liu Jicong 已提交
1732
} SCMCreateStreamReq;
L
Liu Jicong 已提交
1733

L
Liu Jicong 已提交
1734 1735 1736 1737 1738 1739 1740 1741
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 已提交
1742
typedef struct {
L
Liu Jicong 已提交
1743
  char    name[TSDB_STREAM_FNAME_LEN];
L
Liu Jicong 已提交
1744 1745 1746 1747 1748 1749 1750 1751 1752
  int64_t streamId;
  char*   sql;
  char*   executorMsg;
} SMVCreateStreamReq, SMSCreateStreamReq;

typedef struct {
  int64_t streamId;
} SMVCreateStreamRsp, SMSCreateStreamRsp;

L
Liu Jicong 已提交
1753 1754 1755 1756 1757 1758
enum {
  TOPIC_SUB_TYPE__DB = 1,
  TOPIC_SUB_TYPE__TABLE,
  TOPIC_SUB_TYPE__COLUMN,
};

L
Liu Jicong 已提交
1759
typedef struct {
L
Liu Jicong 已提交
1760 1761
  char   name[TSDB_TOPIC_FNAME_LEN];  // accout.topic
  int8_t igExists;
L
Liu Jicong 已提交
1762
  int8_t subType;
L
Liu Jicong 已提交
1763
  int8_t withMeta;
L
Liu Jicong 已提交
1764
  char*  sql;
L
Liu Jicong 已提交
1765
  char   subDbName[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
1766 1767 1768 1769
  union {
    char* ast;
    char  subStbName[TSDB_TABLE_FNAME_LEN];
  };
L
Liu Jicong 已提交
1770 1771 1772 1773 1774
} 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 已提交
1775 1776 1777

typedef struct {
  int64_t topicId;
L
Liu Jicong 已提交
1778
} SCMCreateTopicRsp;
L
Liu Jicong 已提交
1779

L
Liu Jicong 已提交
1780 1781
int32_t tSerializeSCMCreateTopicRsp(void* buf, int32_t bufLen, const SCMCreateTopicRsp* pRsp);
int32_t tDeserializeSCMCreateTopicRsp(void* buf, int32_t bufLen, SCMCreateTopicRsp* pRsp);
L
Liu Jicong 已提交
1782

1783 1784
typedef struct {
  int64_t consumerId;
L
Liu Jicong 已提交
1785
} SMqConsumerLostMsg, SMqConsumerRecoverMsg;
1786

L
Liu Jicong 已提交
1787 1788
typedef struct {
  int64_t consumerId;
1789
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
1790
  char    clientId[256];
L
Liu Jicong 已提交
1791
  SArray* topicNames;  // SArray<char**>
L
Liu Jicong 已提交
1792 1793
} SCMSubscribeReq;

S
Shengliang Guan 已提交
1794 1795
static FORCE_INLINE int32_t tSerializeSCMSubscribeReq(void** buf, const SCMSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1796
  tlen += taosEncodeFixedI64(buf, pReq->consumerId);
1797
  tlen += taosEncodeString(buf, pReq->cgroup);
L
Liu Jicong 已提交
1798
  tlen += taosEncodeString(buf, pReq->clientId);
L
Liu Jicong 已提交
1799

L
Liu Jicong 已提交
1800 1801 1802 1803
  int32_t topicNum = taosArrayGetSize(pReq->topicNames);
  tlen += taosEncodeFixedI32(buf, topicNum);

  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
1804
    tlen += taosEncodeString(buf, (char*)taosArrayGetP(pReq->topicNames, i));
L
Liu Jicong 已提交
1805
  }
L
Liu Jicong 已提交
1806 1807 1808 1809 1810
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeReq(void* buf, SCMSubscribeReq* pReq) {
  buf = taosDecodeFixedI64(buf, &pReq->consumerId);
1811
  buf = taosDecodeStringTo(buf, pReq->cgroup);
L
Liu Jicong 已提交
1812
  buf = taosDecodeStringTo(buf, pReq->clientId);
L
Liu Jicong 已提交
1813 1814 1815 1816 1817 1818

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

  pReq->topicNames = taosArrayInit(topicNum, sizeof(void*));
  for (int32_t i = 0; i < topicNum; i++) {
L
Liu Jicong 已提交
1819
    char* name;
L
Liu Jicong 已提交
1820 1821
    buf = taosDecodeString(buf, &name);
    taosArrayPush(pReq->topicNames, &name);
L
Liu Jicong 已提交
1822
  }
L
Liu Jicong 已提交
1823 1824 1825
  return buf;
}

L
Liu Jicong 已提交
1826
typedef struct SMqSubTopic {
L
Liu Jicong 已提交
1827
  int32_t vgId;
L
Liu Jicong 已提交
1828 1829 1830 1831 1832
  int64_t topicId;
  SEpSet  epSet;
} SMqSubTopic;

typedef struct {
L
Liu Jicong 已提交
1833
  int32_t     topicNum;
L
Liu Jicong 已提交
1834
  SMqSubTopic topics[];
L
Liu Jicong 已提交
1835 1836
} SCMSubscribeRsp;

S
Shengliang Guan 已提交
1837 1838
static FORCE_INLINE int32_t tSerializeSCMSubscribeRsp(void** buf, const SCMSubscribeRsp* pRsp) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1839
  tlen += taosEncodeFixedI32(buf, pRsp->topicNum);
S
Shengliang Guan 已提交
1840
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
1841 1842 1843 1844
    tlen += taosEncodeFixedI32(buf, pRsp->topics[i].vgId);
    tlen += taosEncodeFixedI64(buf, pRsp->topics[i].topicId);
    tlen += taosEncodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
1845 1846 1847 1848
  return tlen;
}

static FORCE_INLINE void* tDeserializeSCMSubscribeRsp(void* buf, SCMSubscribeRsp* pRsp) {
L
Liu Jicong 已提交
1849
  buf = taosDecodeFixedI32(buf, &pRsp->topicNum);
S
Shengliang Guan 已提交
1850
  for (int32_t i = 0; i < pRsp->topicNum; i++) {
L
Liu Jicong 已提交
1851 1852 1853 1854
    buf = taosDecodeFixedI32(buf, &pRsp->topics[i].vgId);
    buf = taosDecodeFixedI64(buf, &pRsp->topics[i].topicId);
    buf = taosDecodeSEpSet(buf, &pRsp->topics[i].epSet);
  }
L
Liu Jicong 已提交
1855 1856 1857 1858 1859 1860 1861 1862
  return buf;
}

typedef struct {
  int64_t topicId;
  int64_t consumerId;
  int64_t consumerGroupId;
  int64_t offset;
L
Liu Jicong 已提交
1863 1864 1865
  char*   sql;
  char*   logicalPlan;
  char*   physicalPlan;
L
Liu Jicong 已提交
1866 1867
} SMVSubscribeReq;

S
Shengliang Guan 已提交
1868 1869
static FORCE_INLINE int32_t tSerializeSMVSubscribeReq(void** buf, SMVSubscribeReq* pReq) {
  int32_t tlen = 0;
L
Liu Jicong 已提交
1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890
  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 已提交
1891
typedef struct {
1892 1893 1894 1895
  char    key[TSDB_SUBSCRIBE_KEY_LEN];
  SArray* lostConsumers;     // SArray<int64_t>
  SArray* removedConsumers;  // SArray<int64_t>
  SArray* newConsumers;      // SArray<int64_t>
L
Liu Jicong 已提交
1896
} SMqRebInfo;
L
Liu Jicong 已提交
1897

L
Liu Jicong 已提交
1898 1899 1900
static FORCE_INLINE SMqRebInfo* tNewSMqRebSubscribe(const char* key) {
  SMqRebInfo* pRebInfo = (SMqRebInfo*)taosMemoryCalloc(1, sizeof(SMqRebInfo));
  if (pRebInfo == NULL) {
L
Liu Jicong 已提交
1901
    return NULL;
L
Liu Jicong 已提交
1902
  }
L
Liu Jicong 已提交
1903 1904 1905
  strcpy(pRebInfo->key, key);
  pRebInfo->lostConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->lostConsumers == NULL) {
L
Liu Jicong 已提交
1906 1907
    goto _err;
  }
L
Liu Jicong 已提交
1908 1909
  pRebInfo->removedConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->removedConsumers == NULL) {
L
Liu Jicong 已提交
1910 1911
    goto _err;
  }
L
Liu Jicong 已提交
1912 1913
  pRebInfo->newConsumers = taosArrayInit(0, sizeof(int64_t));
  if (pRebInfo->newConsumers == NULL) {
L
Liu Jicong 已提交
1914 1915
    goto _err;
  }
L
Liu Jicong 已提交
1916
  return pRebInfo;
L
Liu Jicong 已提交
1917
_err:
L
Liu Jicong 已提交
1918 1919 1920 1921
  taosArrayDestroy(pRebInfo->lostConsumers);
  taosArrayDestroy(pRebInfo->removedConsumers);
  taosArrayDestroy(pRebInfo->newConsumers);
  taosMemoryFreeClear(pRebInfo);
L
Liu Jicong 已提交
1922 1923 1924
  return NULL;
}

L
Liu Jicong 已提交
1925 1926
// 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 已提交
1927
typedef struct {
1928
  SHashObj* rebSubHash;  // SHashObj<key, SMqRebSubscribe>
L
Liu Jicong 已提交
1929 1930
} SMqDoRebalanceMsg;

L
Liu Jicong 已提交
1931
typedef struct {
L
Liu Jicong 已提交
1932
  int64_t status;
L
Liu Jicong 已提交
1933 1934
} SMVSubscribeRsp;

L
Liu Jicong 已提交
1935
typedef struct {
1936
  char   name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
1937
  int8_t igNotExists;
S
Shengliang Guan 已提交
1938 1939
} SMDropTopicReq;

S
Shengliang Guan 已提交
1940
int32_t tSerializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
S
Shengliang Guan 已提交
1941
int32_t tDeserializeSMDropTopicReq(void* buf, int32_t bufLen, SMDropTopicReq* pReq);
L
Liu Jicong 已提交
1942

1943 1944 1945 1946 1947 1948 1949 1950 1951
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 已提交
1952 1953 1954 1955
typedef struct {
  int8_t reserved;
} SMDropCgroupRsp;

L
Liu Jicong 已提交
1956 1957 1958 1959
typedef struct {
  char    name[TSDB_TABLE_FNAME_LEN];
  int8_t  alterType;
  SSchema schema;
S
Shengliang Guan 已提交
1960
} SAlterTopicReq;
L
Liu Jicong 已提交
1961 1962 1963 1964

typedef struct {
  SMsgHead head;
  char     name[TSDB_TABLE_FNAME_LEN];
L
Liu Jicong 已提交
1965
  int64_t  tuid;
L
Liu Jicong 已提交
1966 1967 1968 1969 1970
  int32_t  sverson;
  int32_t  execLen;
  char*    executor;
  int32_t  sqlLen;
  char*    sql;
S
Shengliang Guan 已提交
1971
} SDCreateTopicReq;
L
Liu Jicong 已提交
1972 1973 1974 1975

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

C
Cary Xu 已提交
1979
typedef struct {
1980 1981 1982 1983
  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 已提交
1984 1985
} SRSmaParam;

H
Hongze Cheng 已提交
1986 1987
int32_t tEncodeSRSmaParam(SEncoder* pCoder, const SRSmaParam* pRSmaParam);
int32_t tDecodeSRSmaParam(SDecoder* pCoder, SRSmaParam* pRSmaParam);
H
Hongze Cheng 已提交
1988

H
Hongze Cheng 已提交
1989
// TDMT_VND_CREATE_STB ==============
H
Hongze Cheng 已提交
1990
typedef struct SVCreateStbReq {
H
Hongze Cheng 已提交
1991
  char*          name;
H
Hongze Cheng 已提交
1992 1993
  tb_uid_t       suid;
  int8_t         rollup;
1994
  SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
1995
  SSchemaWrapper schemaTag;
C
Cary Xu 已提交
1996
  SRSmaParam     rsmaParam;
wmmhello's avatar
wmmhello 已提交
1997 1998
  int32_t        alterOriDataLen;
  void*          alterOriData;
H
Hongze Cheng 已提交
1999 2000
} SVCreateStbReq;

H
Hongze Cheng 已提交
2001 2002
int tEncodeSVCreateStbReq(SEncoder* pCoder, const SVCreateStbReq* pReq);
int tDecodeSVCreateStbReq(SDecoder* pCoder, SVCreateStbReq* pReq);
H
Hongze Cheng 已提交
2003

H
Hongze Cheng 已提交
2004
// TDMT_VND_DROP_STB ==============
H
Hongze Cheng 已提交
2005
typedef struct SVDropStbReq {
H
Hongze Cheng 已提交
2006 2007
  char*    name;
  tb_uid_t suid;
H
Hongze Cheng 已提交
2008 2009
} SVDropStbReq;

H
Hongze Cheng 已提交
2010 2011
int32_t tEncodeSVDropStbReq(SEncoder* pCoder, const SVDropStbReq* pReq);
int32_t tDecodeSVDropStbReq(SDecoder* pCoder, SVDropStbReq* pReq);
H
Hongze Cheng 已提交
2012

H
Hongze Cheng 已提交
2013
// TDMT_VND_CREATE_TABLE ==============
H
Hongze Cheng 已提交
2014
#define TD_CREATE_IF_NOT_EXISTS 0x1
H
more  
Hongze Cheng 已提交
2015
typedef struct SVCreateTbReq {
H
Hongze Cheng 已提交
2016
  int32_t  flags;
H
Hongze Cheng 已提交
2017
  char*    name;
H
Hongze Cheng 已提交
2018 2019 2020
  tb_uid_t uid;
  int64_t  ctime;
  int32_t  ttl;
wmmhello's avatar
wmmhello 已提交
2021 2022
  int32_t  commentLen;
  char*    comment;
H
Hongze Cheng 已提交
2023
  int8_t   type;
C
Cary Xu 已提交
2024 2025
  union {
    struct {
L
Liu Jicong 已提交
2026
      char*    name;  // super table name
X
Xiaoyu Wang 已提交
2027
      uint8_t  tagNum;
H
Hongze Cheng 已提交
2028
      tb_uid_t suid;
wmmhello's avatar
wmmhello 已提交
2029
      SArray*  tagName;
H
Hongze Cheng 已提交
2030
      uint8_t* pTag;
H
Hongze Cheng 已提交
2031
    } ctb;
H
more  
Hongze Cheng 已提交
2032
    struct {
2033
      SSchemaWrapper schemaRow;
H
Hongze Cheng 已提交
2034
    } ntb;
H
more  
Hongze Cheng 已提交
2035
  };
H
Hongze Cheng 已提交
2036
} SVCreateTbReq;
H
Hongze Cheng 已提交
2037

H
Hongze Cheng 已提交
2038 2039
int tEncodeSVCreateTbReq(SEncoder* pCoder, const SVCreateTbReq* pReq);
int tDecodeSVCreateTbReq(SDecoder* pCoder, SVCreateTbReq* pReq);
H
Hongze Cheng 已提交
2040

C
Cary Xu 已提交
2041 2042
static FORCE_INLINE void tdDestroySVCreateTbReq(SVCreateTbReq* req) {
  taosMemoryFreeClear(req->name);
wmmhello's avatar
wmmhello 已提交
2043
  taosMemoryFreeClear(req->comment);
C
Cary Xu 已提交
2044 2045
  if (req->type == TSDB_CHILD_TABLE) {
    taosMemoryFreeClear(req->ctb.pTag);
wmmhello's avatar
wmmhello 已提交
2046
    taosMemoryFreeClear(req->ctb.name);
wmmhello's avatar
wmmhello 已提交
2047
    taosArrayDestroy(req->ctb.tagName);
wmmhello's avatar
wmmhello 已提交
2048
    req->ctb.tagName = NULL;
C
Cary Xu 已提交
2049 2050 2051 2052 2053
  } else if (req->type == TSDB_NORMAL_TABLE) {
    taosMemoryFreeClear(req->ntb.schemaRow.pSchema);
  }
}

H
more  
Hongze Cheng 已提交
2054
typedef struct {
H
Hongze Cheng 已提交
2055 2056 2057 2058 2059
  int32_t nReqs;
  union {
    SVCreateTbReq* pReqs;
    SArray*        pArray;
  };
H
more  
Hongze Cheng 已提交
2060
} SVCreateTbBatchReq;
H
more  
Hongze Cheng 已提交
2061

H
Hongze Cheng 已提交
2062 2063
int tEncodeSVCreateTbBatchReq(SEncoder* pCoder, const SVCreateTbBatchReq* pReq);
int tDecodeSVCreateTbBatchReq(SDecoder* pCoder, SVCreateTbBatchReq* pReq);
H
more  
Hongze Cheng 已提交
2064

H
more  
Hongze Cheng 已提交
2065
typedef struct {
2066 2067
  int32_t        code;
  STableMetaRsp* pMeta;
S
Shengliang Guan 已提交
2068
} SVCreateTbRsp, SVUpdateTbRsp;
H
more  
Hongze Cheng 已提交
2069

L
Liu Jicong 已提交
2070 2071
int  tEncodeSVCreateTbRsp(SEncoder* pCoder, const SVCreateTbRsp* pRsp);
int  tDecodeSVCreateTbRsp(SDecoder* pCoder, SVCreateTbRsp* pRsp);
2072
void tFreeSVCreateTbRsp(void* param);
H
Hongze Cheng 已提交
2073

S
Shengliang Guan 已提交
2074 2075
int32_t tSerializeSVCreateTbReq(void** buf, SVCreateTbReq* pReq);
void*   tDeserializeSVCreateTbReq(void* buf, SVCreateTbReq* pReq);
H
more  
Hongze Cheng 已提交
2076

H
more  
Hongze Cheng 已提交
2077
typedef struct {
H
Hongze Cheng 已提交
2078 2079 2080 2081 2082
  int32_t nRsps;
  union {
    SVCreateTbRsp* pRsps;
    SArray*        pArray;
  };
S
Shengliang Guan 已提交
2083
} SVCreateTbBatchRsp;
H
more  
Hongze Cheng 已提交
2084

H
Hongze Cheng 已提交
2085 2086
int tEncodeSVCreateTbBatchRsp(SEncoder* pCoder, const SVCreateTbBatchRsp* pRsp);
int tDecodeSVCreateTbBatchRsp(SDecoder* pCoder, SVCreateTbBatchRsp* pRsp);
H
Hongze Cheng 已提交
2087

L
Liu Jicong 已提交
2088 2089
int32_t tSerializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
int32_t tDeserializeSVCreateTbBatchRsp(void* buf, int32_t bufLen, SVCreateTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
2090

H
Hongze Cheng 已提交
2091
// TDMT_VND_DROP_TABLE =================
S
Shengliang Guan 已提交
2092
typedef struct {
2093 2094 2095
  char*    name;
  uint64_t suid;  // for tmq in wal format
  int8_t   igNotExists;
S
Shengliang Guan 已提交
2096 2097 2098
} SVDropTbReq;

typedef struct {
H
Hongze Cheng 已提交
2099
  int32_t code;
S
Shengliang Guan 已提交
2100 2101
} SVDropTbRsp;

H
Hongze Cheng 已提交
2102 2103 2104 2105 2106 2107 2108 2109
typedef struct {
  int32_t nReqs;
  union {
    SVDropTbReq* pReqs;
    SArray*      pArray;
  };
} SVDropTbBatchReq;

H
Hongze Cheng 已提交
2110 2111
int32_t tEncodeSVDropTbBatchReq(SEncoder* pCoder, const SVDropTbBatchReq* pReq);
int32_t tDecodeSVDropTbBatchReq(SDecoder* pCoder, SVDropTbBatchReq* pReq);
H
Hongze Cheng 已提交
2112 2113 2114 2115 2116 2117 2118 2119 2120

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

H
Hongze Cheng 已提交
2121 2122
int32_t tEncodeSVDropTbBatchRsp(SEncoder* pCoder, const SVDropTbBatchRsp* pRsp);
int32_t tDecodeSVDropTbBatchRsp(SDecoder* pCoder, SVDropTbBatchRsp* pRsp);
S
Shengliang Guan 已提交
2123

H
Hongze Cheng 已提交
2124 2125
// TDMT_VND_ALTER_TABLE =====================
typedef struct {
2126 2127 2128 2129
  char*   tbName;
  int8_t  action;
  char*   colName;
  int32_t colId;
H
Hongze Cheng 已提交
2130
  // TSDB_ALTER_TABLE_ADD_COLUMN
H
Hongze Cheng 已提交
2131 2132 2133
  int8_t  type;
  int8_t  flags;
  int32_t bytes;
H
Hongze Cheng 已提交
2134 2135
  // TSDB_ALTER_TABLE_DROP_COLUMN
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES
wmmhello's avatar
wmmhello 已提交
2136
  int8_t  colModType;
H
Hongze Cheng 已提交
2137
  int32_t colModBytes;
H
Hongze Cheng 已提交
2138
  // TSDB_ALTER_TABLE_UPDATE_COLUMN_NAME
H
Hongze Cheng 已提交
2139
  char* colNewName;
H
Hongze Cheng 已提交
2140
  // TSDB_ALTER_TABLE_UPDATE_TAG_VAL
H
Hongze Cheng 已提交
2141 2142
  char*    tagName;
  int8_t   isNull;
wmmhello's avatar
wmmhello 已提交
2143
  int8_t   tagType;
H
Hongze Cheng 已提交
2144 2145
  uint32_t nTagVal;
  uint8_t* pTagVal;
H
Hongze Cheng 已提交
2146
  // TSDB_ALTER_TABLE_UPDATE_OPTIONS
H
Hongze Cheng 已提交
2147 2148
  int8_t  updateTTL;
  int32_t newTTL;
wmmhello's avatar
wmmhello 已提交
2149
  int32_t newCommentLen;
H
Hongze Cheng 已提交
2150
  char*   newComment;
H
Hongze Cheng 已提交
2151 2152 2153 2154 2155 2156
} SVAlterTbReq;

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

typedef struct {
D
dapan1121 已提交
2157 2158
  int32_t        code;
  STableMetaRsp* pMeta;
H
Hongze Cheng 已提交
2159 2160 2161 2162 2163 2164
} SVAlterTbRsp;

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

S
Shengliang Guan 已提交
2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182 2183
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 已提交
2184 2185 2186
  SMsgHead head;
} SVShowTablesReq;

S
Shengliang Guan 已提交
2187
typedef struct {
H
Hongze Cheng 已提交
2188
  SMsgHead head;
H
Haojun Liao 已提交
2189
  int32_t  id;
H
Hongze Cheng 已提交
2190 2191
} SVShowTablesFetchReq;

S
Shengliang Guan 已提交
2192
typedef struct {
H
Hongze Cheng 已提交
2193 2194 2195 2196 2197 2198 2199 2200 2201
  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 已提交
2202
typedef struct {
L
Liu Jicong 已提交
2203 2204
  int64_t consumerId;
  int32_t epoch;
L
Liu Jicong 已提交
2205
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2206
} SMqAskEpReq;
L
Liu Jicong 已提交
2207

2208 2209 2210 2211 2212 2213 2214 2215 2216
typedef struct {
  int64_t consumerId;
  int32_t epoch;
} SMqHbReq;

typedef struct {
  int8_t reserved;
} SMqHbRsp;

L
Liu Jicong 已提交
2217
typedef struct {
D
dapan1121 已提交
2218
  int32_t key;
L
Liu Jicong 已提交
2219 2220 2221 2222 2223
  int32_t valueLen;
  void*   value;
} SKv;

typedef struct {
D
dapan1121 已提交
2224
  int64_t tscRid;
D
dapan1121 已提交
2225
  int8_t  connType;
L
Liu Jicong 已提交
2226 2227 2228
} SClientHbKey;

typedef struct {
D
dapan1121 已提交
2229
  int64_t tid;
2230
  char    status[TSDB_JOB_STATUS_LEN];
D
dapan1121 已提交
2231 2232 2233 2234 2235 2236
} SQuerySubDesc;

typedef struct {
  char     sql[TSDB_SHOW_SQL_LEN];
  uint64_t queryId;
  int64_t  useconds;
L
Liu Jicong 已提交
2237
  int64_t  stime;  // timestamp precision ms
D
dapan1121 已提交
2238
  int64_t  reqRid;
2239
  bool     stableQuery;
D
dapan1121 已提交
2240 2241
  char     fqdn[TSDB_FQDN_LEN];
  int32_t  subPlanNum;
2242
  SArray*  subDesc;  // SArray<SQuerySubDesc>
D
dapan1121 已提交
2243 2244 2245
} SQueryDesc;

typedef struct {
2246 2247
  uint32_t connId;
  SArray*  queryDesc;  // SArray<SQueryDesc>
D
dapan1121 已提交
2248 2249 2250 2251 2252 2253 2254 2255 2256 2257
} 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 已提交
2258
  SArray*  pQnodeList;
D
dapan1121 已提交
2259 2260
} SQueryHbRspBasic;

D
dapan1121 已提交
2261 2262 2263 2264 2265 2266 2267
typedef struct SAppClusterSummary {
  uint64_t numOfInsertsReq;
  uint64_t numOfInsertRows;
  uint64_t insertElapsedTime;
  uint64_t insertBytes;  // submit to tsdb since launched.

  uint64_t fetchBytes;
D
dapan1121 已提交
2268
  uint64_t numOfQueryReq;
D
dapan1121 已提交
2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282
  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 已提交
2283 2284
typedef struct {
  SClientHbKey      connKey;
D
dapan1121 已提交
2285
  int64_t           clusterId;
D
dapan1121 已提交
2286
  SAppHbReq         app;
D
dapan1121 已提交
2287 2288
  SQueryHbReqBasic* query;
  SHashObj*         info;  // hash<Skv.key, Skv>
L
Liu Jicong 已提交
2289 2290 2291 2292 2293 2294 2295 2296
} SClientHbReq;

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

typedef struct {
D
dapan1121 已提交
2297 2298 2299 2300
  SClientHbKey      connKey;
  int32_t           status;
  SQueryHbRspBasic* query;
  SArray*           info;  // Array<Skv>
L
Liu Jicong 已提交
2301 2302 2303 2304 2305
} SClientHbRsp;

typedef struct {
  int64_t reqId;
  int64_t rspId;
dengyihao's avatar
dengyihao 已提交
2306
  int32_t svrTimestamp;
L
Liu Jicong 已提交
2307 2308 2309
  SArray* rsps;  // SArray<SClientHbRsp>
} SClientHbBatchRsp;

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

2312 2313
static FORCE_INLINE void tFreeReqKvHash(SHashObj* info) {
  void* pIter = taosHashIterate(info, NULL);
D
dapan1121 已提交
2314 2315
  while (pIter != NULL) {
    SKv* kv = (SKv*)pIter;
wafwerar's avatar
wafwerar 已提交
2316
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2317 2318 2319 2320
    pIter = taosHashIterate(info, pIter);
  }
}

D
dapan1121 已提交
2321 2322 2323 2324 2325 2326 2327 2328
static FORCE_INLINE void tFreeClientHbQueryDesc(void* pDesc) {
  SQueryDesc* desc = (SQueryDesc*)pDesc;
  if (desc->subDesc) {
    taosArrayDestroy(desc->subDesc);
    desc->subDesc = NULL;
  }
}

2329
static FORCE_INLINE void tFreeClientHbReq(void* pReq) {
L
Liu Jicong 已提交
2330
  SClientHbReq* req = (SClientHbReq*)pReq;
D
dapan1121 已提交
2331 2332 2333 2334 2335 2336
  if (req->query) {
    if (req->query->queryDesc) {
      taosArrayDestroyEx(req->query->queryDesc, tFreeClientHbQueryDesc);
    }
    taosMemoryFreeClear(req->query);
  }
2337

D
dapan1121 已提交
2338 2339 2340
  if (req->info) {
    tFreeReqKvHash(req->info);
    taosHashCleanup(req->info);
D
dapan1121 已提交
2341
    req->info = NULL;
D
dapan1121 已提交
2342
  }
L
Liu Jicong 已提交
2343 2344
}

S
Shengliang Guan 已提交
2345 2346
int32_t tSerializeSClientHbBatchReq(void* buf, int32_t bufLen, const SClientHbBatchReq* pReq);
int32_t tDeserializeSClientHbBatchReq(void* buf, int32_t bufLen, SClientHbBatchReq* pReq);
L
Liu Jicong 已提交
2347

D
dapan1121 已提交
2348
static FORCE_INLINE void tFreeClientHbBatchReq(void* pReq) {
dengyihao's avatar
dengyihao 已提交
2349
  if (pReq == NULL) return;
2350
  SClientHbBatchReq* req = (SClientHbBatchReq*)pReq;
D
dapan1121 已提交
2351
  taosArrayDestroyEx(req->reqs, tFreeClientHbReq);
wafwerar's avatar
wafwerar 已提交
2352
  taosMemoryFree(pReq);
L
Liu Jicong 已提交
2353 2354
}

2355 2356
static FORCE_INLINE void tFreeClientKv(void* pKv) {
  SKv* kv = (SKv*)pKv;
D
dapan1121 已提交
2357
  if (kv) {
wafwerar's avatar
wafwerar 已提交
2358
    taosMemoryFreeClear(kv->value);
D
dapan1121 已提交
2359 2360 2361
  }
}

2362
static FORCE_INLINE void tFreeClientHbRsp(void* pRsp) {
D
dapan1121 已提交
2363
  SClientHbRsp* rsp = (SClientHbRsp*)pRsp;
D
dapan1121 已提交
2364 2365 2366 2367
  if (rsp->query) {
    taosArrayDestroy(rsp->query->pQnodeList);
    taosMemoryFreeClear(rsp->query);
  }
D
dapan1121 已提交
2368 2369 2370 2371
  if (rsp->info) taosArrayDestroyEx(rsp->info, tFreeClientKv);
}

static FORCE_INLINE void tFreeClientHbBatchRsp(void* pRsp) {
2372
  SClientHbBatchRsp* rsp = (SClientHbBatchRsp*)pRsp;
D
dapan1121 已提交
2373 2374 2375
  taosArrayDestroyEx(rsp->rsps, tFreeClientHbRsp);
}

S
Shengliang Guan 已提交
2376 2377
int32_t tSerializeSClientHbBatchRsp(void* buf, int32_t bufLen, const SClientHbBatchRsp* pBatchRsp);
int32_t tDeserializeSClientHbBatchRsp(void* buf, int32_t bufLen, SClientHbBatchRsp* pBatchRsp);
H
Hongze Cheng 已提交
2378
void    tFreeSClientHbBatchRsp(SClientHbBatchRsp* pBatchRsp);
L
Liu Jicong 已提交
2379

H
Hongze Cheng 已提交
2380
static FORCE_INLINE int32_t tEncodeSKv(SEncoder* pEncoder, const SKv* pKv) {
S
Shengliang Guan 已提交
2381 2382
  if (tEncodeI32(pEncoder, pKv->key) < 0) return -1;
  if (tEncodeI32(pEncoder, pKv->valueLen) < 0) return -1;
H
Hongze Cheng 已提交
2383
  if (tEncodeBinary(pEncoder, (uint8_t*)pKv->value, pKv->valueLen) < 0) return -1;
S
Shengliang Guan 已提交
2384
  return 0;
L
Liu Jicong 已提交
2385 2386
}

H
Hongze Cheng 已提交
2387
static FORCE_INLINE int32_t tDecodeSKv(SDecoder* pDecoder, SKv* pKv) {
S
Shengliang Guan 已提交
2388 2389
  if (tDecodeI32(pDecoder, &pKv->key) < 0) return -1;
  if (tDecodeI32(pDecoder, &pKv->valueLen) < 0) return -1;
wafwerar's avatar
wafwerar 已提交
2390
  pKv->value = taosMemoryMalloc(pKv->valueLen + 1);
S
Shengliang Guan 已提交
2391 2392 2393
  if (pKv->value == NULL) return -1;
  if (tDecodeCStrTo(pDecoder, (char*)pKv->value) < 0) return -1;
  return 0;
L
Liu Jicong 已提交
2394 2395
}

H
Hongze Cheng 已提交
2396
static FORCE_INLINE int32_t tEncodeSClientHbKey(SEncoder* pEncoder, const SClientHbKey* pKey) {
D
dapan1121 已提交
2397
  if (tEncodeI64(pEncoder, pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2398
  if (tEncodeI8(pEncoder, pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2399
  return 0;
L
Liu Jicong 已提交
2400 2401
}

H
Hongze Cheng 已提交
2402
static FORCE_INLINE int32_t tDecodeSClientHbKey(SDecoder* pDecoder, SClientHbKey* pKey) {
D
dapan1121 已提交
2403
  if (tDecodeI64(pDecoder, &pKey->tscRid) < 0) return -1;
D
dapan1121 已提交
2404
  if (tDecodeI8(pDecoder, &pKey->connType) < 0) return -1;
S
Shengliang Guan 已提交
2405
  return 0;
L
Liu Jicong 已提交
2406 2407
}

2408
typedef struct {
L
Liu Jicong 已提交
2409
  int32_t vgId;
2410 2411
  // TODO stas
} SMqReportVgInfo;
L
Liu Jicong 已提交
2412

2413
static FORCE_INLINE int32_t taosEncodeSMqVgInfo(void** buf, const SMqReportVgInfo* pVgInfo) {
S
Shengliang Guan 已提交
2414
  int32_t tlen = 0;
L
Liu Jicong 已提交
2415 2416 2417 2418
  tlen += taosEncodeFixedI32(buf, pVgInfo->vgId);
  return tlen;
}

2419
static FORCE_INLINE void* taosDecodeSMqVgInfo(void* buf, SMqReportVgInfo* pVgInfo) {
L
Liu Jicong 已提交
2420 2421 2422 2423
  buf = taosDecodeFixedI32(buf, &pVgInfo->vgId);
  return buf;
}

2424
typedef struct {
L
Liu Jicong 已提交
2425 2426 2427
  int32_t epoch;
  int64_t topicUid;
  char    name[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2428
  SArray* pVgInfo;  // SArray<SMqHbVgInfo>
2429
} SMqTopicInfo;
L
Liu Jicong 已提交
2430

2431
static FORCE_INLINE int32_t taosEncodeSMqTopicInfoMsg(void** buf, const SMqTopicInfo* pTopicInfo) {
S
Shengliang Guan 已提交
2432
  int32_t tlen = 0;
L
Liu Jicong 已提交
2433 2434 2435 2436 2437 2438
  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++) {
2439
    SMqReportVgInfo* pVgInfo = (SMqReportVgInfo*)taosArrayGet(pTopicInfo->pVgInfo, i);
L
Liu Jicong 已提交
2440 2441 2442 2443 2444
    tlen += taosEncodeSMqVgInfo(buf, pVgInfo);
  }
  return tlen;
}

2445
static FORCE_INLINE void* taosDecodeSMqTopicInfoMsg(void* buf, SMqTopicInfo* pTopicInfo) {
L
Liu Jicong 已提交
2446 2447 2448 2449 2450
  buf = taosDecodeFixedI32(buf, &pTopicInfo->epoch);
  buf = taosDecodeFixedI64(buf, &pTopicInfo->topicUid);
  buf = taosDecodeStringTo(buf, pTopicInfo->name);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
2451
  pTopicInfo->pVgInfo = taosArrayInit(sz, sizeof(SMqReportVgInfo));
L
Liu Jicong 已提交
2452
  for (int32_t i = 0; i < sz; i++) {
2453
    SMqReportVgInfo vgInfo;
L
Liu Jicong 已提交
2454 2455 2456 2457 2458 2459
    buf = taosDecodeSMqVgInfo(buf, &vgInfo);
    taosArrayPush(pTopicInfo->pVgInfo, &vgInfo);
  }
  return buf;
}

2460
typedef struct {
2461 2462 2463 2464
  int32_t status;  // ask hb endpoint
  int32_t epoch;
  int64_t consumerId;
  SArray* pTopics;  // SArray<SMqHbTopicInfo>
2465
} SMqReportReq;
L
Liu Jicong 已提交
2466

2467
static FORCE_INLINE int32_t taosEncodeSMqReportMsg(void** buf, const SMqReportReq* pMsg) {
S
Shengliang Guan 已提交
2468
  int32_t tlen = 0;
L
Liu Jicong 已提交
2469 2470 2471 2472 2473
  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 已提交
2474
  for (int32_t i = 0; i < sz; i++) {
2475 2476
    SMqTopicInfo* topicInfo = (SMqTopicInfo*)taosArrayGet(pMsg->pTopics, i);
    tlen += taosEncodeSMqTopicInfoMsg(buf, topicInfo);
L
Liu Jicong 已提交
2477 2478 2479 2480
  }
  return tlen;
}

2481
static FORCE_INLINE void* taosDecodeSMqReportMsg(void* buf, SMqReportReq* pMsg) {
L
Liu Jicong 已提交
2482 2483 2484 2485 2486
  buf = taosDecodeFixedI32(buf, &pMsg->status);
  buf = taosDecodeFixedI32(buf, &pMsg->epoch);
  buf = taosDecodeFixedI64(buf, &pMsg->consumerId);
  int32_t sz;
  buf = taosDecodeFixedI32(buf, &sz);
2487
  pMsg->pTopics = taosArrayInit(sz, sizeof(SMqTopicInfo));
S
Shengliang Guan 已提交
2488
  for (int32_t i = 0; i < sz; i++) {
2489 2490
    SMqTopicInfo topicInfo;
    buf = taosDecodeSMqTopicInfoMsg(buf, &topicInfo);
L
Liu Jicong 已提交
2491 2492 2493 2494 2495
    taosArrayPush(pMsg->pTopics, &topicInfo);
  }
  return buf;
}

L
Liu Jicong 已提交
2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507
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 已提交
2508
typedef struct {
L
Liu Jicong 已提交
2509 2510
  char   name[TSDB_STREAM_FNAME_LEN];
  int8_t igNotExists;
L
Liu Jicong 已提交
2511
} SMDropStreamReq;
L
Liu Jicong 已提交
2512 2513 2514

typedef struct {
  int8_t reserved;
L
Liu Jicong 已提交
2515
} SMDropStreamRsp;
L
Liu Jicong 已提交
2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526

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

typedef struct {
  int8_t reserved;
} SVDropStreamTaskRsp;

L
Liu Jicong 已提交
2527 2528 2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547
int32_t tSerializeSMDropStreamReq(void* buf, int32_t bufLen, const SMDropStreamReq* pReq);
int32_t tDeserializeSMDropStreamReq(void* buf, int32_t bufLen, SMDropStreamReq* pReq);

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

typedef struct {
  int8_t reserved;
} SMRecoverStreamRsp;

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

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

2548 2549 2550 2551 2552 2553
typedef struct {
  int64_t leftForVer;
  int32_t vgId;
  int64_t oldConsumerId;
  int64_t newConsumerId;
  char    subKey[TSDB_SUBSCRIBE_KEY_LEN];
L
Liu Jicong 已提交
2554
  int8_t  subType;
L
Liu Jicong 已提交
2555
  int8_t  withMeta;
L
Liu Jicong 已提交
2556 2557
  char*   qmsg;
  int64_t suid;
2558 2559 2560 2561 2562 2563 2564 2565 2566
} 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 已提交
2567
  tlen += taosEncodeFixedI8(buf, pReq->subType);
L
Liu Jicong 已提交
2568
  tlen += taosEncodeFixedI8(buf, pReq->withMeta);
L
Liu Jicong 已提交
2569
  if (pReq->subType == TOPIC_SUB_TYPE__COLUMN) {
L
Liu Jicong 已提交
2570
    tlen += taosEncodeString(buf, pReq->qmsg);
L
Liu Jicong 已提交
2571 2572
  } else if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    tlen += taosEncodeFixedI64(buf, pReq->suid);
L
Liu Jicong 已提交
2573
  }
2574 2575 2576 2577 2578 2579 2580 2581 2582
  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 已提交
2583
  buf = taosDecodeFixedI8(buf, &pReq->subType);
L
Liu Jicong 已提交
2584
  buf = taosDecodeFixedI8(buf, &pReq->withMeta);
L
Liu Jicong 已提交
2585
  if (pReq->subType == TOPIC_SUB_TYPE__COLUMN) {
L
Liu Jicong 已提交
2586
    buf = taosDecodeString(buf, &pReq->qmsg);
L
Liu Jicong 已提交
2587 2588
  } else if (pReq->subType == TOPIC_SUB_TYPE__TABLE) {
    buf = taosDecodeFixedI64(buf, &pReq->suid);
L
Liu Jicong 已提交
2589
  }
2590 2591 2592
  return (void*)buf;
}

L
Liu Jicong 已提交
2593 2594 2595 2596
typedef struct {
  char    topic[TSDB_TOPIC_FNAME_LEN];
  int64_t ntbUid;
  SArray* colIdList;  // SArray<int16_t>
2597
} STqCheckInfo;
L
Liu Jicong 已提交
2598

2599 2600 2601 2602 2603 2604
int32_t tEncodeSTqCheckInfo(SEncoder* pEncoder, const STqCheckInfo* pInfo);
int32_t tDecodeSTqCheckInfo(SDecoder* pDecoder, STqCheckInfo* pInfo);

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

L
Liu Jicong 已提交
2606 2607 2608 2609
typedef struct {
  int32_t vgId;
  int64_t offset;
  char    topicName[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2610
  char    cgroup[TSDB_CGROUP_LEN];
L
Liu Jicong 已提交
2611 2612 2613 2614 2615
} SMqOffset;

typedef struct {
  int32_t    num;
  SMqOffset* offsets;
L
Liu Jicong 已提交
2616
} SMqCMCommitOffsetReq;
L
Liu Jicong 已提交
2617 2618 2619

typedef struct {
  int32_t reserved;
L
Liu Jicong 已提交
2620
} SMqCMCommitOffsetRsp;
L
Liu Jicong 已提交
2621

H
Hongze Cheng 已提交
2622 2623 2624 2625
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 已提交
2626

2627 2628
// tqOffset
enum {
L
Liu Jicong 已提交
2629 2630 2631 2632 2633 2634
  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,
2635 2636 2637 2638 2639
};

typedef struct {
  int8_t type;
  union {
wmmhello's avatar
wmmhello 已提交
2640
    // snapshot
2641 2642 2643 2644
    struct {
      int64_t uid;
      int64_t ts;
    };
L
Liu Jicong 已提交
2645
    // log
2646 2647 2648 2649
    struct {
      int64_t version;
    };
  };
L
Liu Jicong 已提交
2650 2651
} STqOffsetVal;

L
Liu Jicong 已提交
2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667
static FORCE_INLINE void tqOffsetResetToData(STqOffsetVal* pOffsetVal, int64_t uid, int64_t ts) {
  pOffsetVal->type = TMQ_OFFSET__SNAPSHOT_DATA;
  pOffsetVal->uid = uid;
  pOffsetVal->ts = ts;
}

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

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

L
Liu Jicong 已提交
2668 2669 2670 2671 2672 2673 2674 2675
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];
2676 2677 2678 2679 2680
} STqOffset;

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

S
Shengliang Guan 已提交
2681 2682 2683 2684 2685 2686 2687
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 已提交
2688
  int32_t dstVgId;  // for stream
S
Shengliang Guan 已提交
2689 2690 2691
  int64_t interval;
  int64_t offset;
  int64_t sliding;
2692 2693
  int64_t maxDelay;
  int64_t watermark;
S
sma  
Shengliang Guan 已提交
2694 2695 2696 2697
  int32_t exprLen;        // strlen + 1
  int32_t tagsFilterLen;  // strlen + 1
  int32_t sqlLen;         // strlen + 1
  int32_t astLen;         // strlen + 1
L
Liu Jicong 已提交
2698
  char*   expr;
S
Shengliang Guan 已提交
2699
  char*   tagsFilter;
S
sma  
Shengliang Guan 已提交
2700 2701
  char*   sql;
  char*   ast;
S
Shengliang Guan 已提交
2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715
} SMCreateSmaReq;

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

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

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

C
Cary Xu 已提交
2716
typedef struct {
C
Cary Xu 已提交
2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736
  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 已提交
2737

2738
typedef STSma SVCreateTSmaReq;
C
Cary Xu 已提交
2739 2740

typedef struct {
C
Cary Xu 已提交
2741 2742 2743
  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 已提交
2744 2745 2746
} STSmaMsg;

typedef struct {
C
Cary Xu 已提交
2747
  int64_t indexUid;
C
Cary Xu 已提交
2748
  char    indexName[TSDB_INDEX_NAME_LEN];
C
Cary Xu 已提交
2749
} SVDropTSmaReq;
2750

C
Cary Xu 已提交
2751
typedef struct {
L
Liu Jicong 已提交
2752
  int tmp;  // TODO: to avoid compile error
C
Cary Xu 已提交
2753 2754
} SVCreateTSmaRsp, SVDropTSmaRsp;

2755
#if 0
C
Cary Xu 已提交
2756 2757 2758 2759
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);
2760
#endif
C
Cary Xu 已提交
2761

2762 2763 2764 2765
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 已提交
2766

C
Cary Xu 已提交
2767
typedef struct {
2768 2769
  int32_t number;
  STSma*  tSma;
C
Cary Xu 已提交
2770 2771
} STSmaWrapper;

C
Cary Xu 已提交
2772
static FORCE_INLINE void tDestroyTSma(STSma* pSma) {
C
Cary Xu 已提交
2773
  if (pSma) {
C
Cary Xu 已提交
2774
    taosMemoryFreeClear(pSma->dstTbName);
wafwerar's avatar
wafwerar 已提交
2775 2776
    taosMemoryFreeClear(pSma->expr);
    taosMemoryFreeClear(pSma->tagsFilter);
C
Cary Xu 已提交
2777 2778 2779
  }
}

C
Cary Xu 已提交
2780
static FORCE_INLINE void tDestroyTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
C
Cary Xu 已提交
2781 2782
  if (pSW) {
    if (pSW->tSma) {
C
Cary Xu 已提交
2783 2784
      if (deepCopy) {
        for (uint32_t i = 0; i < pSW->number; ++i) {
C
Cary Xu 已提交
2785
          tDestroyTSma(pSW->tSma + i);
C
Cary Xu 已提交
2786
        }
C
Cary Xu 已提交
2787
      }
wafwerar's avatar
wafwerar 已提交
2788
      taosMemoryFreeClear(pSW->tSma);
C
Cary Xu 已提交
2789
    }
C
Cary Xu 已提交
2790 2791 2792
  }
}

C
Cary Xu 已提交
2793 2794
static FORCE_INLINE void* tFreeTSmaWrapper(STSmaWrapper* pSW, bool deepCopy) {
  tDestroyTSmaWrapper(pSW, deepCopy);
C
Cary Xu 已提交
2795
  taosMemoryFreeClear(pSW);
C
Cary Xu 已提交
2796
  return NULL;
C
Cary Xu 已提交
2797 2798
}

2799 2800
int32_t tEncodeSVCreateTSmaReq(SEncoder* pCoder, const SVCreateTSmaReq* pReq);
int32_t tDecodeSVCreateTSmaReq(SDecoder* pCoder, SVCreateTSmaReq* pReq);
C
Cary Xu 已提交
2801

2802
int32_t tEncodeTSma(SEncoder* pCoder, const STSma* pSma);
C
Cary Xu 已提交
2803
int32_t tDecodeTSma(SDecoder* pCoder, STSma* pSma, bool deepCopy);
C
Cary Xu 已提交
2804

2805 2806 2807 2808
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 已提交
2809
  }
2810
  return 0;
C
Cary Xu 已提交
2811 2812
}

C
Cary Xu 已提交
2813
static int32_t tDecodeTSmaWrapper(SDecoder* pDecoder, STSmaWrapper* pReq, bool deepCopy) {
2814 2815
  if (tDecodeI32(pDecoder, &pReq->number) < 0) return -1;
  for (int32_t i = 0; i < pReq->number; ++i) {
C
Cary Xu 已提交
2816
    tDecodeTSma(pDecoder, pReq->tSma + i, deepCopy);
C
Cary Xu 已提交
2817
  }
2818
  return 0;
C
Cary Xu 已提交
2819
}
L
Liu Jicong 已提交
2820

dengyihao's avatar
dengyihao 已提交
2821
typedef struct {
dengyihao's avatar
dengyihao 已提交
2822
  int idx;
dengyihao's avatar
dengyihao 已提交
2823 2824 2825 2826 2827 2828
} 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 已提交
2829 2830 2831 2832 2833 2834 2835 2836
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 已提交
2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853 2854
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 已提交
2855 2856 2857 2858 2859 2860 2861 2862
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 {
2863 2864 2865 2866 2867 2868
  int8_t  intervalUnit;
  int8_t  slidingUnit;
  int64_t interval;
  int64_t offset;
  int64_t sliding;
  int64_t dstTbUid;
X
Xiaoyu Wang 已提交
2869
  int32_t dstVgId;
2870 2871
  SEpSet  epSet;
  char*   expr;
D
dapan1121 已提交
2872 2873 2874
} STableIndexInfo;

typedef struct {
D
dapan1121 已提交
2875 2876
  char     tbName[TSDB_TABLE_NAME_LEN];
  char     dbFName[TSDB_DB_FNAME_LEN];
D
dapan1121 已提交
2877 2878 2879
  uint64_t suid;
  int32_t  version;
  SArray*  pIndex;
D
dapan1121 已提交
2880 2881 2882 2883
} STableIndexRsp;

int32_t tSerializeSTableIndexRsp(void* buf, int32_t bufLen, const STableIndexRsp* pRsp);
int32_t tDeserializeSTableIndexRsp(void* buf, int32_t bufLen, STableIndexRsp* pRsp);
2884
void    tFreeSerializeSTableIndexRsp(STableIndexRsp* pRsp);
C
Cary Xu 已提交
2885 2886

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

L
Liu Jicong 已提交
2888 2889 2890 2891
typedef struct {
  int8_t  mqMsgType;
  int32_t code;
  int32_t epoch;
L
Liu Jicong 已提交
2892
  int64_t consumerId;
L
Liu Jicong 已提交
2893 2894
} SMqRspHead;

L
Liu Jicong 已提交
2895 2896 2897
typedef struct {
  SMsgHead head;
  char     subKey[TSDB_SUBSCRIBE_KEY_LEN];
2898
  int8_t   withTbName;
L
Liu Jicong 已提交
2899
  int8_t   useSnapshot;
L
Liu Jicong 已提交
2900 2901 2902
  int32_t  epoch;
  uint64_t reqId;
  int64_t  consumerId;
2903
  int64_t  timeout;
L
Liu Jicong 已提交
2904 2905
  // int64_t      currentOffset;
  STqOffsetVal reqOffset;
L
Liu Jicong 已提交
2906
} SMqPollReq;
L
Liu Jicong 已提交
2907

L
Liu Jicong 已提交
2908
typedef struct {
L
Liu Jicong 已提交
2909
  int32_t vgId;
L
Liu Jicong 已提交
2910
  int64_t offset;
L
Liu Jicong 已提交
2911 2912 2913
  SEpSet  epSet;
} SMqSubVgEp;

L
Liu Jicong 已提交
2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928
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 已提交
2929
typedef struct {
L
Liu Jicong 已提交
2930
  char           topic[TSDB_TOPIC_FNAME_LEN];
L
Liu Jicong 已提交
2931
  char           db[TSDB_DB_FNAME_LEN];
L
Liu Jicong 已提交
2932 2933
  SArray*        vgs;  // SArray<SMqSubVgEp>
  SSchemaWrapper schema;
L
Liu Jicong 已提交
2934 2935
} SMqSubTopicEp;

L
Liu Jicong 已提交
2936 2937 2938
static FORCE_INLINE int32_t tEncodeSMqSubTopicEp(void** buf, const SMqSubTopicEp* pTopicEp) {
  int32_t tlen = 0;
  tlen += taosEncodeString(buf, pTopicEp->topic);
L
Liu Jicong 已提交
2939
  tlen += taosEncodeString(buf, pTopicEp->db);
L
Liu Jicong 已提交
2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951
  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 已提交
2952
  buf = taosDecodeStringTo(buf, pTopicEp->db);
L
Liu Jicong 已提交
2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968
  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) {
L
Liu Jicong 已提交
2969
  if (pSubTopicEp->schema.nCols) taosMemoryFreeClear(pSubTopicEp->schema.pSchema);
L
Liu Jicong 已提交
2970 2971 2972
  taosArrayDestroy(pSubTopicEp->vgs);
}

L
Liu Jicong 已提交
2973
typedef struct {
L
Liu Jicong 已提交
2974
  SMqRspHead   head;
2975
  STqOffsetVal rspOffset;
L
Liu Jicong 已提交
2976 2977 2978
  int16_t      resMsgType;
  int32_t      metaRspLen;
  void*        metaRsp;
L
Liu Jicong 已提交
2979 2980
} SMqMetaRsp;

2981 2982
int32_t tEncodeSMqMetaRsp(SEncoder* pEncoder, const SMqMetaRsp* pRsp);
int32_t tDecodeSMqMetaRsp(SDecoder* pDecoder, SMqMetaRsp* pRsp);
L
Liu Jicong 已提交
2983

L
Liu Jicong 已提交
2984 2985 2986 2987 2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998
typedef struct {
  SMqRspHead   head;
  STqOffsetVal reqOffset;
  STqOffsetVal rspOffset;
  int32_t      blockNum;
  int8_t       withTbName;
  int8_t       withSchema;
  SArray*      blockDataLen;
  SArray*      blockData;
  SArray*      blockTbName;
  SArray*      blockSchema;
} SMqDataRsp;

int32_t tEncodeSMqDataRsp(SEncoder* pEncoder, const SMqDataRsp* pRsp);
int32_t tDecodeSMqDataRsp(SDecoder* pDecoder, SMqDataRsp* pRsp);
L
Liu Jicong 已提交
2999
void    tDeleteSMqDataRsp(SMqDataRsp* pRsp);
L
Liu Jicong 已提交
3000

L
Liu Jicong 已提交
3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017 3018
typedef struct {
  SMqRspHead   head;
  STqOffsetVal reqOffset;
  STqOffsetVal rspOffset;
  int32_t      blockNum;
  int8_t       withTbName;
  int8_t       withSchema;
  SArray*      blockDataLen;
  SArray*      blockData;
  SArray*      blockTbName;
  SArray*      blockSchema;
  int32_t      createTableNum;
  SArray*      createTableLen;
  SArray*      createTableReq;
} STaosxRsp;

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

L
Liu Jicong 已提交
3021
typedef struct {
L
Liu Jicong 已提交
3022
  SMqRspHead head;
L
Liu Jicong 已提交
3023 3024
  char       cgroup[TSDB_CGROUP_LEN];
  SArray*    topics;  // SArray<SMqSubTopicEp>
L
Liu Jicong 已提交
3025
} SMqAskEpRsp;
L
Liu Jicong 已提交
3026

L
Liu Jicong 已提交
3027
static FORCE_INLINE int32_t tEncodeSMqAskEpRsp(void** buf, const SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
3028
  int32_t tlen = 0;
L
Liu Jicong 已提交
3029
  // tlen += taosEncodeString(buf, pRsp->cgroup);
L
Liu Jicong 已提交
3030 3031 3032 3033 3034 3035 3036 3037 3038
  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 已提交
3039
static FORCE_INLINE void* tDecodeSMqAskEpRsp(void* buf, SMqAskEpRsp* pRsp) {
L
Liu Jicong 已提交
3040
  // buf = taosDecodeStringTo(buf, pRsp->cgroup);
L
Liu Jicong 已提交
3041 3042 3043 3044 3045 3046 3047 3048 3049 3050 3051 3052 3053
  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 已提交
3054

L
Liu Jicong 已提交
3055 3056 3057 3058
static FORCE_INLINE void tDeleteSMqAskEpRsp(SMqAskEpRsp* pRsp) {
  taosArrayDestroyEx(pRsp->topics, (void (*)(void*))tDeleteSMqSubTopicEp);
}

H
Hongze Cheng 已提交
3059 3060
#define TD_AUTO_CREATE_TABLE 0x1
typedef struct {
H
Hongze Cheng 已提交
3061 3062 3063 3064 3065 3066
  int64_t       suid;
  int64_t       uid;
  int32_t       sver;
  uint32_t      nData;
  uint8_t*      pData;
  SVCreateTbReq cTbReq;
H
Hongze Cheng 已提交
3067 3068 3069 3070 3071 3072 3073 3074 3075 3076 3077
} SVSubmitBlk;

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

H
Hongze Cheng 已提交
3078 3079
int32_t tEncodeSVSubmitReq(SEncoder* pCoder, const SVSubmitReq* pReq);
int32_t tDecodeSVSubmitReq(SDecoder* pCoder, SVSubmitReq* pReq);
H
Hongze Cheng 已提交
3080

H
more  
Hongze Cheng 已提交
3081
typedef struct {
D
dapan1121 已提交
3082 3083 3084 3085 3086 3087 3088 3089
  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 已提交
3090 3091
} SVDeleteReq;

C
Cary Xu 已提交
3092 3093
int32_t tSerializeSVDeleteReq(void* buf, int32_t bufLen, SVDeleteReq* pReq);
int32_t tDeserializeSVDeleteReq(void* buf, int32_t bufLen, SVDeleteReq* pReq);
C
Cary Xu 已提交
3094

H
more  
Hongze Cheng 已提交
3095
typedef struct {
C
Cary Xu 已提交
3096
  int64_t affectedRows;
H
more  
Hongze Cheng 已提交
3097 3098
} SVDeleteRsp;

C
Cary Xu 已提交
3099 3100 3101
int32_t tEncodeSVDeleteRsp(SEncoder* pCoder, const SVDeleteRsp* pReq);
int32_t tDecodeSVDeleteRsp(SDecoder* pCoder, SVDeleteRsp* pReq);

H
Hongze Cheng 已提交
3102 3103 3104 3105 3106 3107
typedef struct SDeleteRes {
  uint64_t suid;
  SArray*  uidList;
  int64_t  skey;
  int64_t  ekey;
  int64_t  affectedRows;
3108 3109
  char     tableFName[TSDB_TABLE_NAME_LEN];
  char     tsColName[TSDB_COL_NAME_LEN];
H
Hongze Cheng 已提交
3110 3111 3112 3113 3114
} SDeleteRes;

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

3115 3116 3117 3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129 3130
typedef struct {
  int64_t uid;
  int64_t ts;
} SSingleDeleteReq;

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

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

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

D
dapan1121 已提交
3131
typedef struct {
D
dapan1121 已提交
3132
  int32_t msgIdx;
D
dapan1121 已提交
3133 3134 3135 3136 3137
  int32_t msgType;
  int32_t msgLen;
  void*   msg;
} SBatchMsg;

3138 3139 3140 3141 3142 3143
typedef struct {
  SMsgHead  header;
  int32_t   msgNum;
  SBatchMsg msg[];
} SBatchReq;

D
dapan1121 已提交
3144 3145
typedef struct {
  int32_t reqType;
D
dapan1121 已提交
3146
  int32_t msgIdx;
D
dapan1121 已提交
3147 3148 3149 3150 3151
  int32_t msgLen;
  int32_t rspCode;
  void*   msg;
} SBatchRsp;

L
Liu Jicong 已提交
3152
static FORCE_INLINE void tFreeSBatchRsp(void* p) {
D
dapan1121 已提交
3153 3154 3155 3156
  if (NULL == p) {
    return;
  }

3157
  SBatchRsp* pRsp = (SBatchRsp*)p;
D
dapan1121 已提交
3158 3159 3160
  taosMemoryFree(pRsp->msg);
}

L
Liu Jicong 已提交
3161 3162
#pragma pack(pop)

D
dapan1121 已提交
3163 3164 3165 3166 3167
#ifdef __cplusplus
}
#endif

#endif /*_TD_COMMON_TAOS_MSG_H_*/