mndDnode.c 42.3 KB
Newer Older
H
refact  
Hongze Cheng 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
/*
 * 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/>.
 */

S
Shengliang Guan 已提交
16
#define _DEFAULT_SOURCE
S
Shengliang Guan 已提交
17
#include "mndDnode.h"
18
#include "mndDb.h"
S
Shengliang Guan 已提交
19
#include "mndMnode.h"
20
#include "mndPrivilege.h"
D
dapan1121 已提交
21
#include "mndQnode.h"
S
Shengliang Guan 已提交
22
#include "mndShow.h"
23
#include "mndSnode.h"
S
Shengliang Guan 已提交
24
#include "mndTrans.h"
S
Shengliang Guan 已提交
25
#include "mndUser.h"
S
Shengliang Guan 已提交
26
#include "mndVgroup.h"
H
Haojun Liao 已提交
27
#include "tmisce.h"
C
cadem 已提交
28
#include "mndCluster.h"
S
Shengliang Guan 已提交
29

K
kailixu 已提交
30
#define TSDB_DNODE_VER_NUMBER   2
31
#define TSDB_DNODE_RESERVE_SIZE 64
S
Shengliang Guan 已提交
32

S
Shengliang Guan 已提交
33
static const char *offlineReason[] = {
S
Shengliang Guan 已提交
34 35 36 37 38 39 40 41 42 43 44 45 46
    "",
    "status msg timeout",
    "status not received",
    "version not match",
    "dnodeId not match",
    "clusterId not match",
    "interval not match",
    "timezone not match",
    "locale not match",
    "charset not match",
    "unknown",
};

K
kailixu 已提交
47 48 49 50 51
enum {
  DND_ACTIVE_CODE,
  DND_CONN_ACTIVE_CODE,
};

S
Shengliang Guan 已提交
52 53 54 55 56
static int32_t  mndCreateDefaultDnode(SMnode *pMnode);
static SSdbRaw *mndDnodeActionEncode(SDnodeObj *pDnode);
static SSdbRow *mndDnodeActionDecode(SSdbRaw *pRaw);
static int32_t  mndDnodeActionInsert(SSdb *pSdb, SDnodeObj *pDnode);
static int32_t  mndDnodeActionDelete(SSdb *pSdb, SDnodeObj *pDnode);
57
static int32_t  mndDnodeActionUpdate(SSdb *pSdb, SDnodeObj *pOld, SDnodeObj *pNew);
D
dapan1121 已提交
58
static int32_t  mndProcessDnodeListReq(SRpcMsg *pReq);
D
dapan1121 已提交
59
static int32_t  mndProcessShowVariablesReq(SRpcMsg *pReq);
S
Shengliang Guan 已提交
60

S
Shengliang Guan 已提交
61 62 63 64 65
static int32_t mndProcessCreateDnodeReq(SRpcMsg *pReq);
static int32_t mndProcessDropDnodeReq(SRpcMsg *pReq);
static int32_t mndProcessConfigDnodeReq(SRpcMsg *pReq);
static int32_t mndProcessConfigDnodeRsp(SRpcMsg *pRsp);
static int32_t mndProcessStatusReq(SRpcMsg *pReq);
D
dmchen 已提交
66
static int32_t mndProcessRestoreDnodeReq(SRpcMsg *pReq);
S
Shengliang Guan 已提交
67

S
Shengliang Guan 已提交
68
static int32_t mndRetrieveConfigs(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pBlock, int32_t rows);
S
Shengliang Guan 已提交
69
static void    mndCancelGetNextConfig(SMnode *pMnode, void *pIter);
S
Shengliang Guan 已提交
70
static int32_t mndRetrieveDnodes(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pBlock, int32_t rows);
S
Shengliang Guan 已提交
71
static void    mndCancelGetNextDnode(SMnode *pMnode, void *pIter);
S
Shengliang Guan 已提交
72 73

int32_t mndInitDnode(SMnode *pMnode) {
74 75 76 77 78 79 80 81 82 83
  SSdbTable table = {
      .sdbType = SDB_DNODE,
      .keyType = SDB_KEY_INT32,
      .deployFp = (SdbDeployFp)mndCreateDefaultDnode,
      .encodeFp = (SdbEncodeFp)mndDnodeActionEncode,
      .decodeFp = (SdbDecodeFp)mndDnodeActionDecode,
      .insertFp = (SdbInsertFp)mndDnodeActionInsert,
      .updateFp = (SdbUpdateFp)mndDnodeActionUpdate,
      .deleteFp = (SdbDeleteFp)mndDnodeActionDelete,
  };
S
Shengliang Guan 已提交
84

S
Shengliang Guan 已提交
85 86 87
  mndSetMsgHandle(pMnode, TDMT_MND_CREATE_DNODE, mndProcessCreateDnodeReq);
  mndSetMsgHandle(pMnode, TDMT_MND_DROP_DNODE, mndProcessDropDnodeReq);
  mndSetMsgHandle(pMnode, TDMT_MND_CONFIG_DNODE, mndProcessConfigDnodeReq);
H
Hongze Cheng 已提交
88
  mndSetMsgHandle(pMnode, TDMT_DND_CONFIG_DNODE_RSP, mndProcessConfigDnodeRsp);
S
Shengliang Guan 已提交
89
  mndSetMsgHandle(pMnode, TDMT_MND_STATUS, mndProcessStatusReq);
D
dapan1121 已提交
90
  mndSetMsgHandle(pMnode, TDMT_MND_DNODE_LIST, mndProcessDnodeListReq);
D
dapan1121 已提交
91
  mndSetMsgHandle(pMnode, TDMT_MND_SHOW_VARIABLES, mndProcessShowVariablesReq);
D
dmchen 已提交
92
  mndSetMsgHandle(pMnode, TDMT_MND_RESTORE_DNODE, mndProcessRestoreDnodeReq);
S
Shengliang Guan 已提交
93

94 95
  mndAddShowRetrieveHandle(pMnode, TSDB_MGMT_TABLE_CONFIGS, mndRetrieveConfigs);
  mndAddShowFreeIterHandle(pMnode, TSDB_MGMT_TABLE_CONFIGS, mndCancelGetNextConfig);
S
Shengliang Guan 已提交
96 97 98
  mndAddShowRetrieveHandle(pMnode, TSDB_MGMT_TABLE_DNODE, mndRetrieveDnodes);
  mndAddShowFreeIterHandle(pMnode, TSDB_MGMT_TABLE_DNODE, mndCancelGetNextDnode);

S
Shengliang Guan 已提交
99 100 101 102 103 104
  return sdbSetTable(pMnode->pSdb, table);
}

void mndCleanupDnode(SMnode *pMnode) {}

static int32_t mndCreateDefaultDnode(SMnode *pMnode) {
S
Shengliang Guan 已提交
105 106 107 108
  int32_t  code = -1;
  SSdbRaw *pRaw = NULL;
  STrans  *pTrans = NULL;

S
Shengliang Guan 已提交
109 110 111 112
  SDnodeObj dnodeObj = {0};
  dnodeObj.id = 1;
  dnodeObj.createdTime = taosGetTimestampMs();
  dnodeObj.updateTime = dnodeObj.createdTime;
S
Shengliang Guan 已提交
113
  dnodeObj.port = tsServerPort;
S
Shengliang Guan 已提交
114 115
  tstrncpy(dnodeObj.fqdn, tsLocalFqdn, TSDB_FQDN_LEN);
  dnodeObj.fqdn[TSDB_FQDN_LEN - 1] = 0;
S
Shengliang Guan 已提交
116
  snprintf(dnodeObj.ep, TSDB_EP_LEN - 1, "%s:%u", tsLocalFqdn, tsServerPort);
S
Shengliang Guan 已提交
117

118
  pTrans = mndTransCreate(pMnode, TRN_POLICY_RETRY, TRN_CONFLICT_GLOBAL, NULL, "create-dnode");
S
Shengliang Guan 已提交
119
  if (pTrans == NULL) goto _OVER;
120
  mInfo("trans:%d, used to create dnode:%s on first deploy", pTrans->id, dnodeObj.ep);
121

S
Shengliang Guan 已提交
122 123
  pRaw = mndDnodeActionEncode(&dnodeObj);
  if (pRaw == NULL || mndTransAppendCommitlog(pTrans, pRaw) != 0) goto _OVER;
S
Shengliang Guan 已提交
124
  (void)sdbSetRawStatus(pRaw, SDB_STATUS_READY);
S
Shengliang Guan 已提交
125
  pRaw = NULL;
126

S
Shengliang Guan 已提交
127 128
  if (mndTransPrepare(pMnode, pTrans) != 0) goto _OVER;
  code = 0;
129

S
Shengliang Guan 已提交
130
_OVER:
131
  mndTransDrop(pTrans);
S
Shengliang Guan 已提交
132 133
  sdbFreeRaw(pRaw);
  return code;
S
Shengliang Guan 已提交
134 135
}

S
Shengliang Guan 已提交
136
static SSdbRaw *mndDnodeActionEncode(SDnodeObj *pDnode) {
137 138
  terrno = TSDB_CODE_OUT_OF_MEMORY;

S
Shengliang Guan 已提交
139
  SSdbRaw *pRaw = sdbAllocRaw(SDB_DNODE, TSDB_DNODE_VER_NUMBER, sizeof(SDnodeObj) + TSDB_DNODE_RESERVE_SIZE);
S
Shengliang Guan 已提交
140
  if (pRaw == NULL) goto _OVER;
S
Shengliang Guan 已提交
141 142

  int32_t dataPos = 0;
S
Shengliang Guan 已提交
143 144 145 146 147 148
  SDB_SET_INT32(pRaw, dataPos, pDnode->id, _OVER)
  SDB_SET_INT64(pRaw, dataPos, pDnode->createdTime, _OVER)
  SDB_SET_INT64(pRaw, dataPos, pDnode->updateTime, _OVER)
  SDB_SET_INT16(pRaw, dataPos, pDnode->port, _OVER)
  SDB_SET_BINARY(pRaw, dataPos, pDnode->fqdn, TSDB_FQDN_LEN, _OVER)
  SDB_SET_RESERVE(pRaw, dataPos, TSDB_DNODE_RESERVE_SIZE, _OVER)
K
kailixu 已提交
149
  SDB_SET_INT16(pRaw, dataPos, TSDB_ACTIVE_KEY_LEN, _OVER)
K
kailixu 已提交
150
  SDB_SET_BINARY(pRaw, dataPos, pDnode->active, TSDB_ACTIVE_KEY_LEN, _OVER)
K
kailixu 已提交
151
  SDB_SET_INT16(pRaw, dataPos, TSDB_CONN_ACTIVE_KEY_LEN, _OVER)
K
kailixu 已提交
152
  SDB_SET_BINARY(pRaw, dataPos, pDnode->connActive, TSDB_CONN_ACTIVE_KEY_LEN, _OVER)
S
Shengliang Guan 已提交
153
  SDB_SET_DATALEN(pRaw, dataPos, _OVER);
154 155 156

  terrno = 0;

S
Shengliang Guan 已提交
157
_OVER:
158 159 160 161 162
  if (terrno != 0) {
    mError("dnode:%d, failed to encode to raw:%p since %s", pDnode->id, pRaw, terrstr());
    sdbFreeRaw(pRaw);
    return NULL;
  }
S
Shengliang Guan 已提交
163

164
  mTrace("dnode:%d, encode to raw:%p, row:%p", pDnode->id, pRaw, pDnode);
S
Shengliang Guan 已提交
165 166 167 168
  return pRaw;
}

static SSdbRow *mndDnodeActionDecode(SSdbRaw *pRaw) {
169
  terrno = TSDB_CODE_OUT_OF_MEMORY;
170 171
  SSdbRow   *pRow = NULL;
  SDnodeObj *pDnode = NULL;
172

S
Shengliang Guan 已提交
173
  int8_t sver = 0;
S
Shengliang Guan 已提交
174
  if (sdbGetRawSoftVer(pRaw, &sver) != 0) goto _OVER;
K
kailixu 已提交
175
  if (sver < 1 || sver > TSDB_DNODE_VER_NUMBER) {
S
Shengliang Guan 已提交
176
    terrno = TSDB_CODE_SDB_INVALID_DATA_VER;
S
Shengliang Guan 已提交
177
    goto _OVER;
S
Shengliang Guan 已提交
178 179
  }

S
Shengliang Guan 已提交
180 181
  pRow = sdbAllocRow(sizeof(SDnodeObj));
  if (pRow == NULL) goto _OVER;
182 183

  pDnode = sdbGetRowObj(pRow);
S
Shengliang Guan 已提交
184
  if (pDnode == NULL) goto _OVER;
S
Shengliang Guan 已提交
185 186

  int32_t dataPos = 0;
S
Shengliang Guan 已提交
187 188 189 190 191 192
  SDB_GET_INT32(pRaw, dataPos, &pDnode->id, _OVER)
  SDB_GET_INT64(pRaw, dataPos, &pDnode->createdTime, _OVER)
  SDB_GET_INT64(pRaw, dataPos, &pDnode->updateTime, _OVER)
  SDB_GET_INT16(pRaw, dataPos, &pDnode->port, _OVER)
  SDB_GET_BINARY(pRaw, dataPos, pDnode->fqdn, TSDB_FQDN_LEN, _OVER)
  SDB_GET_RESERVE(pRaw, dataPos, TSDB_DNODE_RESERVE_SIZE, _OVER)
K
kailixu 已提交
193
  if (sver > 1) {
K
kailixu 已提交
194 195 196 197 198
    int16_t keyLen = 0;
    SDB_GET_INT16(pRaw, dataPos, &keyLen, _OVER)
    SDB_GET_BINARY(pRaw, dataPos, pDnode->active, keyLen, _OVER)
    SDB_GET_INT16(pRaw, dataPos, &keyLen, _OVER)
    SDB_GET_BINARY(pRaw, dataPos, pDnode->connActive, keyLen, _OVER)
K
kailixu 已提交
199
  }
200 201

  terrno = 0;
202 203 204
  if (tmsgUpdateDnodeInfo(&pDnode->id, NULL, pDnode->fqdn, &pDnode->port)) {
    mInfo("dnode:%d, endpoint changed", pDnode->id);
  }
205

S
Shengliang Guan 已提交
206
_OVER:
207
  if (terrno != 0) {
208
    mError("dnode:%d, failed to decode from raw:%p since %s", pDnode == NULL ? 0 : pDnode->id, pRaw, terrstr());
wafwerar's avatar
wafwerar 已提交
209
    taosMemoryFreeClear(pRow);
210 211
    return NULL;
  }
S
Shengliang Guan 已提交
212

213
  mTrace("dnode:%d, decode from raw:%p, row:%p ep:%s:%u", pDnode->id, pRaw, pDnode, pDnode->fqdn, pDnode->port);
S
Shengliang Guan 已提交
214 215 216
  return pRow;
}

217
static int32_t mndDnodeActionInsert(SSdb *pSdb, SDnodeObj *pDnode) {
218
  mTrace("dnode:%d, perform insert action, row:%p", pDnode->id, pDnode);
S
Shengliang Guan 已提交
219
  pDnode->offlineReason = DND_REASON_STATUS_NOT_RECEIVED;
S
Shengliang Guan 已提交
220 221 222 223

  char ep[TSDB_EP_LEN] = {0};
  snprintf(ep, TSDB_EP_LEN - 1, "%s:%u", pDnode->fqdn, pDnode->port);
  tstrncpy(pDnode->ep, ep, TSDB_EP_LEN);
S
Shengliang Guan 已提交
224 225 226
  return 0;
}

S
Shengliang Guan 已提交
227
static int32_t mndDnodeActionDelete(SSdb *pSdb, SDnodeObj *pDnode) {
228
  mTrace("dnode:%d, perform delete action, row:%p", pDnode->id, pDnode);
S
Shengliang Guan 已提交
229 230
  return 0;
}
S
Shengliang Guan 已提交
231

232
static int32_t mndDnodeActionUpdate(SSdb *pSdb, SDnodeObj *pOld, SDnodeObj *pNew) {
S
Shengliang Guan 已提交
233
  mTrace("dnode:%d, perform update action, old row:%p new row:%p", pOld->id, pOld, pNew);
234
  pOld->updateTime = pNew->updateTime;
235 236 237 238 239 240 241 242
#ifdef TD_ENTERPRISE
  if (strncmp(pOld->active, pNew->active, TSDB_ACTIVE_KEY_LEN) != 0) {
    strncpy(pOld->active, pNew->active, TSDB_ACTIVE_KEY_LEN);
  }
  if (strncmp(pOld->connActive, pNew->connActive, TSDB_CONN_ACTIVE_KEY_LEN) != 0) {
    strncpy(pOld->connActive, pNew->connActive, TSDB_CONN_ACTIVE_KEY_LEN);
  }
#endif
S
Shengliang Guan 已提交
243
  return 0;
S
Shengliang Guan 已提交
244 245
}

S
Shengliang Guan 已提交
246
SDnodeObj *mndAcquireDnode(SMnode *pMnode, int32_t dnodeId) {
S
Shengliang Guan 已提交
247 248 249
  SSdb      *pSdb = pMnode->pSdb;
  SDnodeObj *pDnode = sdbAcquire(pSdb, SDB_DNODE, &dnodeId);
  if (pDnode == NULL) {
250 251 252 253 254 255 256 257 258 259
    if (terrno == TSDB_CODE_SDB_OBJ_NOT_THERE) {
      terrno = TSDB_CODE_MND_DNODE_NOT_EXIST;
    } else if (terrno == TSDB_CODE_SDB_OBJ_CREATING) {
      terrno = TSDB_CODE_MND_DNODE_IN_CREATING;
    } else if (terrno == TSDB_CODE_SDB_OBJ_DROPPING) {
      terrno = TSDB_CODE_MND_DNODE_IN_DROPPING;
    } else {
      terrno = TSDB_CODE_APP_ERROR;
      mFatal("dnode:%d, failed to acquire db since %s", dnodeId, terrstr());
    }
S
Shengliang Guan 已提交
260
  }
261

S
Shengliang Guan 已提交
262
  return pDnode;
S
Shengliang Guan 已提交
263
}
S
Shengliang Guan 已提交
264

S
Shengliang Guan 已提交
265 266 267
void mndReleaseDnode(SMnode *pMnode, SDnodeObj *pDnode) {
  SSdb *pSdb = pMnode->pSdb;
  sdbRelease(pSdb, pDnode);
S
Shengliang Guan 已提交
268 269
}

S
Shengliang Guan 已提交
270
SEpSet mndGetDnodeEpset(SDnodeObj *pDnode) {
H
Haojun Liao 已提交
271 272
  SEpSet epSet = {0};
  addEpIntoEpSet(&epSet, pDnode->fqdn, pDnode->port);
S
Shengliang Guan 已提交
273 274 275
  return epSet;
}

S
Shengliang Guan 已提交
276 277 278 279 280 281 282 283 284 285 286 287 288
static SDnodeObj *mndAcquireDnodeByEp(SMnode *pMnode, char *pEpStr) {
  SSdb *pSdb = pMnode->pSdb;

  void *pIter = NULL;
  while (1) {
    SDnodeObj *pDnode = NULL;
    pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pDnode);
    if (pIter == NULL) break;

    if (strncasecmp(pEpStr, pDnode->ep, TSDB_EP_LEN) == 0) {
      sdbCancelFetch(pSdb, pIter);
      return pDnode;
    }
S
Shengliang Guan 已提交
289 290

    sdbRelease(pSdb, pDnode);
S
Shengliang Guan 已提交
291 292
  }

S
Shengliang Guan 已提交
293
  terrno = TSDB_CODE_MND_DNODE_NOT_EXIST;
S
Shengliang Guan 已提交
294 295 296
  return NULL;
}

297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317
static SDnodeObj *mndAcquireDnodeAllStatusByEp(SMnode *pMnode, char *pEpStr) {
  SSdb *pSdb = pMnode->pSdb;

  void *pIter = NULL;
  while (1) {
    SDnodeObj *pDnode = NULL;
    ESdbStatus objStatus = 0;
    pIter = sdbFetchAll(pSdb, SDB_DNODE, pIter, (void **)&pDnode, &objStatus, true);
    if (pIter == NULL) break;

    if (strncasecmp(pEpStr, pDnode->ep, TSDB_EP_LEN) == 0) {
      sdbCancelFetch(pSdb, pIter);
      return pDnode;
    }

    sdbRelease(pSdb, pDnode);
  }

  return NULL;
}

S
Shengliang Guan 已提交
318
int32_t mndGetDnodeSize(SMnode *pMnode) {
S
Shengliang Guan 已提交
319 320 321 322
  SSdb *pSdb = pMnode->pSdb;
  return sdbGetSize(pSdb, SDB_DNODE);
}

C
cadem 已提交
323 324 325 326 327
int32_t mndGetDbSize(SMnode *pMnode) {
  SSdb *pSdb = pMnode->pSdb;
  return sdbGetSize(pSdb, SDB_DB);
}

S
Shengliang Guan 已提交
328
bool mndIsDnodeOnline(SDnodeObj *pDnode, int64_t curMs) {
dengyihao's avatar
dengyihao 已提交
329
  int64_t interval = TABS(pDnode->lastAccessTime - curMs);
S
Shengliang Guan 已提交
330
  if (interval > 5000 * (int64_t)tsStatusInterval) {
S
Shengliang Guan 已提交
331 332 333
    if (pDnode->rebootTime > 0) {
      pDnode->offlineReason = DND_REASON_STATUS_MSG_TIMEOUT;
    }
S
Shengliang Guan 已提交
334 335 336 337 338
    return false;
  }
  return true;
}

K
kailixu 已提交
339
static void mndGetDnodeEps(SMnode *pMnode, SArray *pDnodeEps) {
S
Shengliang Guan 已提交
340 341
  SSdb *pSdb = pMnode->pSdb;

342
  int32_t numOfEps = 0;
S
Shengliang Guan 已提交
343 344 345
  void   *pIter = NULL;
  while (1) {
    SDnodeObj *pDnode = NULL;
346 347
    ESdbStatus objStatus = 0;
    pIter = sdbFetchAll(pSdb, SDB_DNODE, pIter, (void **)&pDnode, &objStatus, true);
S
Shengliang Guan 已提交
348 349
    if (pIter == NULL) break;

S
Shengliang Guan 已提交
350 351 352
    SDnodeEp dnodeEp = {0};
    dnodeEp.id = pDnode->id;
    dnodeEp.ep.port = pDnode->port;
S
Shengliang Guan 已提交
353
    tstrncpy(dnodeEp.ep.fqdn, pDnode->fqdn, TSDB_FQDN_LEN);
S
Shengliang Guan 已提交
354
    sdbRelease(pSdb, pDnode);
S
Shengliang Guan 已提交
355

S
Shengliang Guan 已提交
356
    dnodeEp.isMnode = 0;
S
Shengliang Guan 已提交
357
    if (mndIsMnode(pMnode, pDnode->id)) {
S
Shengliang Guan 已提交
358
      dnodeEp.isMnode = 1;
S
Shengliang Guan 已提交
359
    }
S
Shengliang Guan 已提交
360
    taosArrayPush(pDnodeEps, &dnodeEp);
S
Shengliang Guan 已提交
361 362 363
  }
}

K
kailixu 已提交
364
void mndGetDnodeData(SMnode *pMnode, SArray *pDnodeInfo) {
K
kailixu 已提交
365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381
  SSdb *pSdb = pMnode->pSdb;

  int32_t numOfEps = 0;
  void   *pIter = NULL;
  while (1) {
    SDnodeObj *pDnode = NULL;
    ESdbStatus objStatus = 0;
    pIter = sdbFetchAll(pSdb, SDB_DNODE, pIter, (void **)&pDnode, &objStatus, true);
    if (pIter == NULL) break;

    SDnodeInfo dInfo;
    dInfo.id = pDnode->id;
    dInfo.ep.port = pDnode->port;
    tstrncpy(dInfo.ep.fqdn, pDnode->fqdn, TSDB_FQDN_LEN);
    tstrncpy(dInfo.active, pDnode->active, TSDB_ACTIVE_KEY_LEN);
    tstrncpy(dInfo.connActive, pDnode->connActive, TSDB_CONN_ACTIVE_KEY_LEN);
    sdbRelease(pSdb, pDnode);
K
kailixu 已提交
382 383 384 385 386
    if (mndIsMnode(pMnode, pDnode->id)) {
      dInfo.isMnode = 1;
    } else {
      dInfo.isMnode = 0;
    }
K
kailixu 已提交
387 388 389 390 391

    taosArrayPush(pDnodeInfo, &dInfo);
  }
}

S
Shengliang Guan 已提交
392
static int32_t mndCheckClusterCfgPara(SMnode *pMnode, SDnodeObj *pDnode, const SClusterCfg *pCfg) {
S
Shengliang Guan 已提交
393
  if (pCfg->statusInterval != tsStatusInterval) {
S
Shengliang Guan 已提交
394 395
    mError("dnode:%d, statusInterval:%d inconsistent with cluster:%d", pDnode->id, pCfg->statusInterval,
           tsStatusInterval);
S
Shengliang Guan 已提交
396 397 398
    return DND_REASON_STATUS_INTERVAL_NOT_MATCH;
  }

wafwerar's avatar
wafwerar 已提交
399
  if ((0 != strcasecmp(pCfg->timezone, tsTimezoneStr)) && (pMnode->checkTime != pCfg->checkTime)) {
S
Shengliang Guan 已提交
400 401
    mError("dnode:%d, timezone:%s checkTime:%" PRId64 " inconsistent with cluster %s %" PRId64, pDnode->id,
           pCfg->timezone, pCfg->checkTime, tsTimezoneStr, pMnode->checkTime);
S
Shengliang Guan 已提交
402 403 404
    return DND_REASON_TIME_ZONE_NOT_MATCH;
  }

S
os env  
Shengliang Guan 已提交
405
  if (0 != strcasecmp(pCfg->locale, tsLocale)) {
S
Shengliang Guan 已提交
406
    mError("dnode:%d, locale:%s inconsistent with cluster:%s", pDnode->id, pCfg->locale, tsLocale);
S
Shengliang Guan 已提交
407 408 409
    return DND_REASON_LOCALE_NOT_MATCH;
  }

S
os env  
Shengliang Guan 已提交
410
  if (0 != strcasecmp(pCfg->charset, tsCharset)) {
S
Shengliang Guan 已提交
411
    mError("dnode:%d, charset:%s inconsistent with cluster:%s", pDnode->id, pCfg->charset, tsCharset);
S
Shengliang Guan 已提交
412 413 414 415 416 417
    return DND_REASON_CHARSET_NOT_MATCH;
  }

  return 0;
}

S
Shengliang Guan 已提交
418 419
static int32_t mndProcessStatusReq(SRpcMsg *pReq) {
  SMnode    *pMnode = pReq->info.node;
S
Shengliang Guan 已提交
420 421 422
  SStatusReq statusReq = {0};
  SDnodeObj *pDnode = NULL;
  int32_t    code = -1;
S
Shengliang Guan 已提交
423

S
Shengliang Guan 已提交
424
  if (tDeserializeSStatusReq(pReq->pCont, pReq->contLen, &statusReq) != 0) {
S
Shengliang Guan 已提交
425
    terrno = TSDB_CODE_INVALID_MSG;
S
Shengliang Guan 已提交
426
    goto _OVER;
S
Shengliang Guan 已提交
427
  }
S
Shengliang Guan 已提交
428

C
cadem 已提交
429
  int64_t clusterid = mndGetClusterId(pMnode);
S
Shengliang Guan 已提交
430
  if (statusReq.clusterId != 0 && statusReq.clusterId != clusterid) {
C
cadem 已提交
431
    code = TSDB_CODE_MND_DNODE_DIFF_CLUSTER;
S
Shengliang Guan 已提交
432 433
    mWarn("dnode:%d, %s, its clusterid:%" PRId64 " differ from current cluster:%" PRId64 ", code:0x%x",
          statusReq.dnodeId, statusReq.dnodeEp, statusReq.clusterId, clusterid, code);
C
cadem 已提交
434 435 436
    goto _OVER;
  }

S
Shengliang Guan 已提交
437 438
  if (statusReq.dnodeId == 0) {
    pDnode = mndAcquireDnodeByEp(pMnode, statusReq.dnodeEp);
S
Shengliang Guan 已提交
439
    if (pDnode == NULL) {
440
      mInfo("dnode:%s, not created yet", statusReq.dnodeEp);
S
Shengliang Guan 已提交
441
      goto _OVER;
S
Shengliang Guan 已提交
442 443
    }
  } else {
S
Shengliang Guan 已提交
444
    pDnode = mndAcquireDnode(pMnode, statusReq.dnodeId);
S
Shengliang Guan 已提交
445
    if (pDnode == NULL) {
446
      int32_t err = terrno;
S
Shengliang Guan 已提交
447
      pDnode = mndAcquireDnodeByEp(pMnode, statusReq.dnodeEp);
S
Shengliang Guan 已提交
448
      if (pDnode != NULL) {
S
Shengliang Guan 已提交
449
        pDnode->offlineReason = DND_REASON_DNODE_ID_NOT_MATCH;
450 451 452 453 454 455 456 457 458 459 460
        terrno = err;
        goto _OVER;
      }

      mError("dnode:%d, %s not exist, code:0x%x", statusReq.dnodeId, statusReq.dnodeEp, err);
      if (err == TSDB_CODE_MND_DNODE_NOT_EXIST) {
        terrno = err;
        goto _OVER;
      } else {
        pDnode = mndAcquireDnodeAllStatusByEp(pMnode, statusReq.dnodeEp);
        if (pDnode == NULL) goto _OVER;
S
Shengliang Guan 已提交
461 462 463 464
      }
    }
  }

465 466 467 468 469 470 471 472 473
  int64_t dnodeVer = sdbGetTableVer(pMnode->pSdb, SDB_DNODE) + sdbGetTableVer(pMnode->pSdb, SDB_MNODE);
  int64_t curMs = taosGetTimestampMs();
  bool    online = mndIsDnodeOnline(pDnode, curMs);
  bool    dnodeChanged = (statusReq.dnodeVer == 0) || (statusReq.dnodeVer != dnodeVer);
  bool    reboot = (pDnode->rebootTime != statusReq.rebootTime);
  bool    needCheck = !online || dnodeChanged || reboot;

  const STraceId *trace = &pReq->info.traceId;
  mGTrace("dnode:%d, status received, accessTimes:%d check:%d online:%d reboot:%d changed:%d statusSeq:%d", pDnode->id,
474
          pDnode->accessTimes, needCheck, online, reboot, dnodeChanged, statusReq.statusSeq);
475

S
Shengliang Guan 已提交
476
  for (int32_t v = 0; v < taosArrayGetSize(statusReq.pVloads); ++v) {
S
Shengliang Guan 已提交
477 478 479 480
    SVnodeLoad *pVload = taosArrayGet(statusReq.pVloads, v);

    SVgObj *pVgroup = mndAcquireVgroup(pMnode, pVload->vgId);
    if (pVgroup != NULL) {
S
Shengliang Guan 已提交
481
      if (pVload->syncState == TAOS_SYNC_STATE_LEADER) {
482
        pVgroup->cacheUsage = pVload->cacheUsage;
D
dapan1121 已提交
483
        pVgroup->numOfCachedTables = pVload->numOfCachedTables;
S
Shengliang Guan 已提交
484 485 486 487 488 489
        pVgroup->numOfTables = pVload->numOfTables;
        pVgroup->numOfTimeSeries = pVload->numOfTimeSeries;
        pVgroup->totalStorage = pVload->totalStorage;
        pVgroup->compStorage = pVload->compStorage;
        pVgroup->pointsWritten = pVload->pointsWritten;
      }
L
Liu Jicong 已提交
490
      bool roleChanged = false;
S
Shengliang Guan 已提交
491
      for (int32_t vg = 0; vg < pVgroup->replica; ++vg) {
492 493 494 495 496 497
        SVnodeGid *pGid = &pVgroup->vnodeGid[vg];
        if (pGid->dnodeId == statusReq.dnodeId) {
          if (pGid->syncState != pVload->syncState || pGid->syncRestore != pVload->syncRestore ||
              pGid->syncCanRead != pVload->syncCanRead) {
            mInfo(
                "vgId:%d, state changed by status msg, old state:%s restored:%d canRead:%d new state:%s restored:%d "
498
                "canRead:%d, dnode:%d",
499
                pVgroup->vgId, syncStr(pGid->syncState), pGid->syncRestore, pGid->syncCanRead,
500
                syncStr(pVload->syncState), pVload->syncRestore, pVload->syncCanRead, pDnode->id);
501 502 503
            pGid->syncState = pVload->syncState;
            pGid->syncRestore = pVload->syncRestore;
            pGid->syncCanRead = pVload->syncCanRead;
M
Minghao Li 已提交
504 505
            roleChanged = true;
          }
S
Shengliang Guan 已提交
506
          break;
L
Liu Jicong 已提交
507
        }
S
Shengliang Guan 已提交
508
      }
L
Liu Jicong 已提交
509
      if (roleChanged) {
510
        SDbObj *pDb = mndAcquireDb(pMnode, pVgroup->dbName);
511
        if (pDb != NULL && pDb->stateTs != curMs) {
dengyihao's avatar
dengyihao 已提交
512 513
          mInfo("db:%s, stateTs changed by status msg, old stateTs:%" PRId64 " new stateTs:%" PRId64, pDb->name,
                pDb->stateTs, curMs);
514 515 516
          pDb->stateTs = curMs;
        }
        mndReleaseDb(pMnode, pDb);
L
Liu Jicong 已提交
517
      }
S
Shengliang Guan 已提交
518 519 520 521 522
    }

    mndReleaseVgroup(pMnode, pVgroup);
  }

523 524
  SMnodeObj *pObj = mndAcquireMnode(pMnode, pDnode->id);
  if (pObj != NULL) {
525 526 527 528 529
    if (pObj->syncState != statusReq.mload.syncState || pObj->syncRestore != statusReq.mload.syncRestore) {
      mInfo("dnode:%d, mnode syncState from %s to %s, restoreState from %d to %d", pObj->id, syncStr(pObj->syncState),
            syncStr(statusReq.mload.syncState), pObj->syncRestore, statusReq.mload.syncRestore);
      pObj->syncState = statusReq.mload.syncState;
      pObj->syncRestore = statusReq.mload.syncRestore;
530 531 532 533 534
      pObj->stateStartTime = taosGetTimestampMs();
    }
    mndReleaseMnode(pMnode, pObj);
  }

D
dapan1121 已提交
535 536 537 538 539 540
  SQnodeObj *pQnode = mndAcquireQnode(pMnode, statusReq.qload.dnodeId);
  if (pQnode != NULL) {
    pQnode->load = statusReq.qload;
    mndReleaseQnode(pMnode, pQnode);
  }

541
  if (needCheck) {
S
Shengliang Guan 已提交
542
    if (statusReq.sver != tsVersion) {
S
Shengliang Guan 已提交
543
      if (pDnode != NULL) {
S
Shengliang Guan 已提交
544
        pDnode->offlineReason = DND_REASON_VERSION_NOT_MATCH;
S
Shengliang Guan 已提交
545
      }
S
Shengliang Guan 已提交
546
      mError("dnode:%d, status msg version:%d not match cluster:%d", statusReq.dnodeId, statusReq.sver, tsVersion);
547
      terrno = TSDB_CODE_VERSION_NOT_COMPATIBLE;
S
Shengliang Guan 已提交
548
      goto _OVER;
S
Shengliang Guan 已提交
549 550
    }

S
Shengliang Guan 已提交
551
    if (statusReq.dnodeId == 0) {
S
Shengliang Guan 已提交
552
      mInfo("dnode:%d, %s first access, clusterId:%" PRId64, pDnode->id, pDnode->ep, pMnode->clusterId);
S
Shengliang Guan 已提交
553
    } else {
S
Shengliang Guan 已提交
554
      if (statusReq.clusterId != pMnode->clusterId) {
S
Shengliang Guan 已提交
555 556 557
        if (pDnode != NULL) {
          pDnode->offlineReason = DND_REASON_CLUSTER_ID_NOT_MATCH;
        }
S
Shengliang Guan 已提交
558
        mError("dnode:%d, clusterId %" PRId64 " not match exist %" PRId64, pDnode->id, statusReq.clusterId,
S
Shengliang Guan 已提交
559 560
               pMnode->clusterId);
        terrno = TSDB_CODE_MND_INVALID_CLUSTER_ID;
S
Shengliang Guan 已提交
561
        goto _OVER;
S
Shengliang Guan 已提交
562
      }
S
Shengliang Guan 已提交
563 564 565
    }

    // Verify whether the cluster parameters are consistent when status change from offline to ready
S
Shengliang Guan 已提交
566 567 568
    pDnode->offlineReason = mndCheckClusterCfgPara(pMnode, pDnode, &statusReq.clusterCfg);
    if (pDnode->offlineReason != 0) {
      mError("dnode:%d, cluster cfg inconsistent since:%s", pDnode->id, offlineReason[pDnode->offlineReason]);
569
      terrno = TSDB_CODE_MND_INVALID_CLUSTER_CFG;
S
Shengliang Guan 已提交
570
      goto _OVER;
S
Shengliang Guan 已提交
571 572
    }

573
    if (!online) {
574 575
      mInfo("dnode:%d, from offline to online, memory avail:%" PRId64 " total:%" PRId64 " cores:%.2f", pDnode->id,
            statusReq.memAvail, statusReq.memTotal, statusReq.numOfCores);
576
    } else {
577
      mInfo("dnode:%d, send dnode epset, online:%d dnodeVer:%" PRId64 ":%" PRId64 " reboot:%d", pDnode->id, online,
H
Hongze Cheng 已提交
578
            statusReq.dnodeVer, dnodeVer, reboot);
579
    }
S
Shengliang Guan 已提交
580

S
Shengliang Guan 已提交
581 582 583
    pDnode->rebootTime = statusReq.rebootTime;
    pDnode->numOfCores = statusReq.numOfCores;
    pDnode->numOfSupportVnodes = statusReq.numOfSupportVnodes;
584 585
    pDnode->memAvail = statusReq.memAvail;
    pDnode->memTotal = statusReq.memTotal;
S
Shengliang Guan 已提交
586

S
Shengliang Guan 已提交
587
    SStatusRsp statusRsp = {0};
588
    statusRsp.statusSeq++;
589
    statusRsp.dnodeVer = dnodeVer;
S
Shengliang Guan 已提交
590 591 592 593
    statusRsp.dnodeCfg.dnodeId = pDnode->id;
    statusRsp.dnodeCfg.clusterId = pMnode->clusterId;
    statusRsp.pDnodeEps = taosArrayInit(mndGetDnodeSize(pMnode), sizeof(SDnodeEp));
    if (statusRsp.pDnodeEps == NULL) {
S
Shengliang Guan 已提交
594
      terrno = TSDB_CODE_OUT_OF_MEMORY;
S
Shengliang Guan 已提交
595
      goto _OVER;
S
Shengliang Guan 已提交
596 597
    }

K
kailixu 已提交
598
    mndGetDnodeEps(pMnode, statusRsp.pDnodeEps);
S
Shengliang Guan 已提交
599

S
Shengliang Guan 已提交
600
    int32_t contLen = tSerializeSStatusRsp(NULL, 0, &statusRsp);
S
Shengliang Guan 已提交
601
    void   *pHead = rpcMallocCont(contLen);
S
Shengliang Guan 已提交
602
    tSerializeSStatusRsp(pHead, contLen, &statusRsp);
S
Shengliang Guan 已提交
603
    taosArrayDestroy(statusRsp.pDnodeEps);
S
Shengliang Guan 已提交
604

S
Shengliang Guan 已提交
605 606
    pReq->info.rspLen = contLen;
    pReq->info.rsp = pHead;
S
Shengliang Guan 已提交
607
  }
S
Shengliang Guan 已提交
608

609 610
  pDnode->accessTimes++;
  pDnode->lastAccessTime = curMs;
S
Shengliang Guan 已提交
611 612
  code = 0;

S
Shengliang Guan 已提交
613
_OVER:
S
Shengliang Guan 已提交
614
  mndReleaseDnode(pMnode, pDnode);
S
Shengliang Guan 已提交
615
  taosArrayDestroy(statusReq.pVloads);
S
Shengliang Guan 已提交
616
  return code;
S
Shengliang Guan 已提交
617 618
}

S
Shengliang Guan 已提交
619
static int32_t mndCreateDnode(SMnode *pMnode, SRpcMsg *pReq, SCreateDnodeReq *pCreate) {
S
Shengliang Guan 已提交
620 621 622 623
  int32_t  code = -1;
  SSdbRaw *pRaw = NULL;
  STrans  *pTrans = NULL;

S
Shengliang Guan 已提交
624
  SDnodeObj dnodeObj = {0};
S
Shengliang Guan 已提交
625
  dnodeObj.id = sdbGetMaxId(pMnode->pSdb, SDB_DNODE);
S
Shengliang Guan 已提交
626 627
  dnodeObj.createdTime = taosGetTimestampMs();
  dnodeObj.updateTime = dnodeObj.createdTime;
S
Shengliang Guan 已提交
628
  dnodeObj.port = pCreate->port;
S
Shengliang Guan 已提交
629
  tstrncpy(dnodeObj.fqdn, pCreate->fqdn, TSDB_FQDN_LEN);
S
Shengliang Guan 已提交
630
  snprintf(dnodeObj.ep, TSDB_EP_LEN - 1, "%s:%u", pCreate->fqdn, pCreate->port);
S
Shengliang Guan 已提交
631

632
  pTrans = mndTransCreate(pMnode, TRN_POLICY_ROLLBACK, TRN_CONFLICT_GLOBAL, pReq, "create-dnode");
S
Shengliang Guan 已提交
633
  if (pTrans == NULL) goto _OVER;
634
  mInfo("trans:%d, used to create dnode:%s", pTrans->id, dnodeObj.ep);
635
  if (mndTrancCheckConflict(pMnode, pTrans) != 0) goto _OVER;
S
Shengliang Guan 已提交
636

S
Shengliang Guan 已提交
637 638
  pRaw = mndDnodeActionEncode(&dnodeObj);
  if (pRaw == NULL || mndTransAppendCommitlog(pTrans, pRaw) != 0) goto _OVER;
S
Shengliang Guan 已提交
639
  (void)sdbSetRawStatus(pRaw, SDB_STATUS_READY);
S
Shengliang Guan 已提交
640
  pRaw = NULL;
S
Shengliang Guan 已提交
641

S
Shengliang Guan 已提交
642 643
  if (mndTransPrepare(pMnode, pTrans) != 0) goto _OVER;
  code = 0;
S
Shengliang Guan 已提交
644

S
Shengliang Guan 已提交
645
_OVER:
S
Shengliang Guan 已提交
646
  mndTransDrop(pTrans);
S
Shengliang Guan 已提交
647 648
  sdbFreeRaw(pRaw);
  return code;
S
Shengliang Guan 已提交
649 650
}

K
kailixu 已提交
651
static int32_t mndConfigDnode(SMnode *pMnode, SRpcMsg *pReq, SMCfgDnodeReq *pCfgReq, int8_t action) {
K
kailixu 已提交
652 653 654 655
  SSdbRaw   *pRaw = NULL;
  STrans    *pTrans = NULL;
  SDnodeObj *pDnode = NULL;
  bool       cfgAll = pCfgReq->dnodeId == -1;
656 657 658 659

  SSdb *pSdb = pMnode->pSdb;
  void *pIter = NULL;
  while (1) {
K
kailixu 已提交
660 661 662
    if (cfgAll) {
      pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pDnode);
      if (pIter == NULL) break;
K
kailixu 已提交
663
    } else if(!(pDnode = mndAcquireDnode(pMnode, pCfgReq->dnodeId))) {
K
kailixu 已提交
664
      goto _OVER;
665 666
    }

667
    if (!pTrans) {
K
kailixu 已提交
668
      pTrans = mndTransCreate(pMnode, TRN_POLICY_RETRY, TRN_CONFLICT_GLOBAL, pReq, "config-dnode");
669 670 671
      if (!pTrans) goto _OVER;
      if (mndTrancCheckConflict(pMnode, pTrans) != 0) goto _OVER;
    }
672 673

    SDnodeObj tmpDnode = *pDnode;
K
kailixu 已提交
674
    if (action == DND_ACTIVE_CODE) {
675
      strncpy(tmpDnode.active, pCfgReq->value, TSDB_ACTIVE_KEY_LEN);
K
kailixu 已提交
676
    } else if (action == DND_CONN_ACTIVE_CODE) {
677 678
      strncpy(tmpDnode.connActive, pCfgReq->value, TSDB_CONN_ACTIVE_KEY_LEN);
    } else {
K
kailixu 已提交
679 680
      terrno = TSDB_CODE_INVALID_CFG;
      goto _OVER;
681 682 683 684 685 686 687 688 689 690
    }

    pRaw = mndDnodeActionEncode(&tmpDnode);
    if (pRaw == NULL || mndTransAppendCommitlog(pTrans, pRaw) != 0) goto _OVER;
    (void)sdbSetRawStatus(pRaw, SDB_STATUS_READY);
    pRaw = NULL;

    mInfo("dnode:%d, config dnode, cfg:%d, app:%p config:%s value:%s", pDnode->id, pCfgReq->dnodeId, pReq->info.ahandle,
          pCfgReq->config, pCfgReq->value);

K
kailixu 已提交
691 692 693 694 695 696
    if (cfgAll) {
      sdbRelease(pSdb, pDnode);
      pDnode = NULL;
    } else {
      break;
    }
697 698
  }

699 700 701
  if (pTrans && mndTransPrepare(pMnode, pTrans) != 0) goto _OVER;

  terrno = 0;
702 703

_OVER:
K
kailixu 已提交
704 705 706 707 708
  if (cfgAll) {
    sdbRelease(pSdb, pDnode);
  } else {
    mndReleaseDnode(pMnode, pDnode);
  }
709 710
  mndTransDrop(pTrans);
  sdbFreeRaw(pRaw);
711
  return terrno;
712 713
}

D
dapan1121 已提交
714
static int32_t mndProcessDnodeListReq(SRpcMsg *pReq) {
S
Shengliang Guan 已提交
715 716 717 718
  SMnode       *pMnode = pReq->info.node;
  SSdb         *pSdb = pMnode->pSdb;
  SDnodeObj    *pObj = NULL;
  void         *pIter = NULL;
D
dapan1121 已提交
719
  SDnodeListRsp rsp = {0};
S
Shengliang Guan 已提交
720 721
  int32_t       code = -1;

D
dapan1121 已提交
722 723 724 725 726 727
  rsp.dnodeList = taosArrayInit(5, sizeof(SEpSet));
  if (NULL == rsp.dnodeList) {
    mError("failed to alloc epSet while process dnode list req");
    terrno = TSDB_CODE_OUT_OF_MEMORY;
    goto _OVER;
  }
S
Shengliang Guan 已提交
728

D
dapan1121 已提交
729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766
  while (1) {
    pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pObj);
    if (pIter == NULL) break;

    SEpSet epSet = {0};
    epSet.numOfEps = 1;
    tstrncpy(epSet.eps[0].fqdn, pObj->fqdn, TSDB_FQDN_LEN);
    epSet.eps[0].port = pObj->port;

    (void)taosArrayPush(rsp.dnodeList, &epSet);

    sdbRelease(pSdb, pObj);
  }

  int32_t rspLen = tSerializeSDnodeListRsp(NULL, 0, &rsp);
  void   *pRsp = rpcMallocCont(rspLen);
  if (pRsp == NULL) {
    terrno = TSDB_CODE_OUT_OF_MEMORY;
    goto _OVER;
  }

  tSerializeSDnodeListRsp(pRsp, rspLen, &rsp);

  pReq->info.rspLen = rspLen;
  pReq->info.rsp = pRsp;
  code = 0;

_OVER:

  if (code != 0) {
    mError("failed to get dnode list since %s", terrstr());
  }

  tFreeSDnodeListRsp(&rsp);

  return code;
}

D
dapan1121 已提交
767 768
static int32_t mndProcessShowVariablesReq(SRpcMsg *pReq) {
  SShowVariablesRsp rsp = {0};
769 770 771 772 773
  int32_t           code = -1;

  if (mndCheckOperPrivilege(pReq->info.node, pReq->info.conn.user, MND_OPER_SHOW_VARIBALES) != 0) {
    goto _OVER;
  }
D
dapan1121 已提交
774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790

  rsp.variables = taosArrayInit(4, sizeof(SVariablesInfo));
  if (NULL == rsp.variables) {
    mError("failed to alloc SVariablesInfo array while process show variables req");
    terrno = TSDB_CODE_OUT_OF_MEMORY;
    goto _OVER;
  }

  SVariablesInfo info = {0};

  strcpy(info.name, "statusInterval");
  snprintf(info.value, TSDB_CONFIG_VALUE_LEN, "%d", tsStatusInterval);
  taosArrayPush(rsp.variables, &info);

  strcpy(info.name, "timezone");
  snprintf(info.value, TSDB_CONFIG_VALUE_LEN, "%s", tsTimezoneStr);
  taosArrayPush(rsp.variables, &info);
791

D
dapan1121 已提交
792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823
  strcpy(info.name, "locale");
  snprintf(info.value, TSDB_CONFIG_VALUE_LEN, "%s", tsLocale);
  taosArrayPush(rsp.variables, &info);

  strcpy(info.name, "charset");
  snprintf(info.value, TSDB_CONFIG_VALUE_LEN, "%s", tsCharset);
  taosArrayPush(rsp.variables, &info);

  int32_t rspLen = tSerializeSShowVariablesRsp(NULL, 0, &rsp);
  void   *pRsp = rpcMallocCont(rspLen);
  if (pRsp == NULL) {
    terrno = TSDB_CODE_OUT_OF_MEMORY;
    goto _OVER;
  }

  tSerializeSShowVariablesRsp(pRsp, rspLen, &rsp);

  pReq->info.rspLen = rspLen;
  pReq->info.rsp = pRsp;
  code = 0;

_OVER:

  if (code != 0) {
    mError("failed to get show variables info since %s", terrstr());
  }

  tFreeSShowVariablesRsp(&rsp);

  return code;
}

S
Shengliang Guan 已提交
824 825
static int32_t mndProcessCreateDnodeReq(SRpcMsg *pReq) {
  SMnode         *pMnode = pReq->info.node;
S
Shengliang Guan 已提交
826 827 828 829
  int32_t         code = -1;
  SDnodeObj      *pDnode = NULL;
  SCreateDnodeReq createReq = {0};

830
  if ((terrno = grantCheck(TSDB_GRANT_DNODE)) != 0 || (terrno = grantCheck(TSDB_GRANT_CPU_CORES)) != 0) {
C
Cary Xu 已提交
831 832 833
    code = terrno;
    goto _OVER;
  }
834

S
Shengliang Guan 已提交
835
  if (tDeserializeSCreateDnodeReq(pReq->pCont, pReq->contLen, &createReq) != 0) {
S
Shengliang Guan 已提交
836
    terrno = TSDB_CODE_INVALID_MSG;
S
Shengliang Guan 已提交
837
    goto _OVER;
S
Shengliang Guan 已提交
838 839
  }

S
Shengliang Guan 已提交
840
  mInfo("dnode:%s:%d, start to create", createReq.fqdn, createReq.port);
841
  if (mndCheckOperPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CREATE_DNODE) != 0) {
S
Shengliang Guan 已提交
842 843
    goto _OVER;
  }
S
Shengliang Guan 已提交
844

S
Shengliang Guan 已提交
845
  if (createReq.fqdn[0] == 0 || createReq.port <= 0 || createReq.port > UINT16_MAX) {
846
    terrno = TSDB_CODE_MND_INVALID_DNODE_EP;
S
Shengliang Guan 已提交
847
    goto _OVER;
S
Shengliang Guan 已提交
848 849
  }

S
Shengliang Guan 已提交
850
  char ep[TSDB_EP_LEN];
S
Shengliang Guan 已提交
851 852
  snprintf(ep, TSDB_EP_LEN, "%s:%d", createReq.fqdn, createReq.port);
  pDnode = mndAcquireDnodeByEp(pMnode, ep);
S
Shengliang Guan 已提交
853
  if (pDnode != NULL) {
854
    terrno = TSDB_CODE_MND_DNODE_ALREADY_EXIST;
S
Shengliang Guan 已提交
855
    goto _OVER;
S
Shengliang Guan 已提交
856
  }
S
Shengliang Guan 已提交
857

S
Shengliang Guan 已提交
858
  code = mndCreateDnode(pMnode, pReq, &createReq);
S
Shengliang Guan 已提交
859
  if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS;
S
Shengliang Guan 已提交
860

S
Shengliang Guan 已提交
861
_OVER:
S
Shengliang Guan 已提交
862
  if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) {
S
Shengliang Guan 已提交
863
    mError("dnode:%s:%d, failed to create since %s", createReq.fqdn, createReq.port, terrstr());
S
Shengliang Guan 已提交
864 865
  }

S
Shengliang Guan 已提交
866 867
  mndReleaseDnode(pMnode, pDnode);
  return code;
S
Shengliang Guan 已提交
868 869
}

C
cadem 已提交
870 871 872 873 874 875 876 877
extern int32_t mndProcessRestoreDnodeReqImpl(SRpcMsg *pReq);

int32_t mndProcessRestoreDnodeReq(SRpcMsg *pReq){
  return mndProcessRestoreDnodeReqImpl(pReq);
}

#ifndef TD_ENTERPRISE
int32_t mndProcessRestoreDnodeReqImpl(SRpcMsg *pReq){
D
dmchen 已提交
878
  return 0;
C
cadem 已提交
879
}
D
dmchen 已提交
880
#endif
C
cadem 已提交
881

882
static int32_t mndDropDnode(SMnode *pMnode, SRpcMsg *pReq, SDnodeObj *pDnode, SMnodeObj *pMObj, SQnodeObj *pQObj,
D
dmchen 已提交
883
                            SSnodeObj *pSObj, int32_t numOfVnodes, bool force, bool unsafe) {
S
Shengliang Guan 已提交
884 885 886 887
  int32_t  code = -1;
  SSdbRaw *pRaw = NULL;
  STrans  *pTrans = NULL;

888
  pTrans = mndTransCreate(pMnode, TRN_POLICY_RETRY, TRN_CONFLICT_GLOBAL, pReq, "drop-dnode");
S
Shengliang Guan 已提交
889
  if (pTrans == NULL) goto _OVER;
S
Shengliang Guan 已提交
890
  mndTransSetSerial(pTrans);
S
Shengliang Guan 已提交
891
  mInfo("trans:%d, used to drop dnode:%d, force:%d", pTrans->id, pDnode->id, force);
892
  if (mndTrancCheckConflict(pMnode, pTrans) != 0) goto _OVER;
S
Shengliang Guan 已提交
893

S
Shengliang Guan 已提交
894
  pRaw = mndDnodeActionEncode(pDnode);
S
Shengliang Guan 已提交
895 896
  if (pRaw == NULL) goto _OVER;
  if (mndTransAppendRedolog(pTrans, pRaw) != 0) goto _OVER;
S
Shengliang Guan 已提交
897
  (void)sdbSetRawStatus(pRaw, SDB_STATUS_DROPPING);
S
Shengliang Guan 已提交
898
  pRaw = NULL;
S
Shengliang Guan 已提交
899

S
Shengliang Guan 已提交
900
  pRaw = mndDnodeActionEncode(pDnode);
S
Shengliang Guan 已提交
901 902
  if (pRaw == NULL) goto _OVER;
  if (mndTransAppendCommitlog(pTrans, pRaw) != 0) goto _OVER;
S
Shengliang Guan 已提交
903
  (void)sdbSetRawStatus(pRaw, SDB_STATUS_DROPPED);
S
Shengliang Guan 已提交
904 905
  pRaw = NULL;

S
Shengliang Guan 已提交
906
  if (pMObj != NULL) {
S
Shengliang Guan 已提交
907
    mInfo("trans:%d, mnode on dnode:%d will be dropped", pTrans->id, pDnode->id);
S
Shengliang Guan 已提交
908
    if (mndSetDropMnodeInfoToTrans(pMnode, pTrans, pMObj, force) != 0) goto _OVER;
S
Shengliang Guan 已提交
909
  }
910 911 912

  if (pQObj != NULL) {
    mInfo("trans:%d, qnode on dnode:%d will be dropped", pTrans->id, pDnode->id);
S
Shengliang Guan 已提交
913
    if (mndSetDropQnodeInfoToTrans(pMnode, pTrans, pQObj, force) != 0) goto _OVER;
914 915 916 917
  }

  if (pSObj != NULL) {
    mInfo("trans:%d, snode on dnode:%d will be dropped", pTrans->id, pDnode->id);
S
Shengliang Guan 已提交
918
    if (mndSetDropSnodeInfoToTrans(pMnode, pTrans, pSObj, force) != 0) goto _OVER;
919 920
  }

S
Shengliang Guan 已提交
921
  if (numOfVnodes > 0) {
S
Shengliang Guan 已提交
922
    mInfo("trans:%d, %d vnodes on dnode:%d will be dropped", pTrans->id, numOfVnodes, pDnode->id);
D
dmchen 已提交
923
    if (mndSetMoveVgroupsInfoToTrans(pMnode, pTrans, pDnode->id, force, unsafe) != 0) goto _OVER;
S
Shengliang Guan 已提交
924
  }
S
Shengliang Guan 已提交
925

S
Shengliang Guan 已提交
926
  if (mndTransPrepare(pMnode, pTrans) != 0) goto _OVER;
S
Shengliang Guan 已提交
927

S
Shengliang Guan 已提交
928 929 930
  code = 0;

_OVER:
S
Shengliang Guan 已提交
931
  mndTransDrop(pTrans);
S
Shengliang Guan 已提交
932 933
  sdbFreeRaw(pRaw);
  return code;
S
Shengliang Guan 已提交
934 935
}

S
Shengliang Guan 已提交
936
static int32_t mndProcessDropDnodeReq(SRpcMsg *pReq) {
937 938 939 940 941 942 943 944 945
  SMnode       *pMnode = pReq->info.node;
  int32_t       code = -1;
  SDnodeObj    *pDnode = NULL;
  SMnodeObj    *pMObj = NULL;
  SQnodeObj    *pQObj = NULL;
  SSnodeObj    *pSObj = NULL;
  SDropDnodeReq dropReq = {0};

  if (tDeserializeSDropDnodeReq(pReq->pCont, pReq->contLen, &dropReq) != 0) {
S
Shengliang Guan 已提交
946
    terrno = TSDB_CODE_INVALID_MSG;
S
Shengliang Guan 已提交
947
    goto _OVER;
S
Shengliang Guan 已提交
948
  }
S
Shengliang Guan 已提交
949

D
dmchen 已提交
950 951
  mInfo("dnode:%d, start to drop, ep:%s:%d, force:%s, unsafe:%s", 
          dropReq.dnodeId, dropReq.fqdn, dropReq.port, dropReq.force?"true":"false", dropReq.unsafe?"true":"false");
952
  if (mndCheckOperPrivilege(pMnode, pReq->info.conn.user, MND_OPER_DROP_MNODE) != 0) {
S
Shengliang Guan 已提交
953 954
    goto _OVER;
  }
S
Shengliang Guan 已提交
955

D
dmchen 已提交
956 957 958 959 960 961
  bool force = dropReq.force;
  if(dropReq.unsafe)
  {
    force = true;
  }

S
Shengliang Guan 已提交
962
  pDnode = mndAcquireDnode(pMnode, dropReq.dnodeId);
S
Shengliang Guan 已提交
963
  if (pDnode == NULL) {
964 965
    int32_t err = terrno;
    char    ep[TSDB_EP_LEN + 1] = {0};
966 967 968
    snprintf(ep, sizeof(ep), dropReq.fqdn, dropReq.port);
    pDnode = mndAcquireDnodeByEp(pMnode, ep);
    if (pDnode == NULL) {
969
      terrno = err;
970 971
      goto _OVER;
    }
S
Shengliang Guan 已提交
972 973
  }

974 975
  pQObj = mndAcquireQnode(pMnode, dropReq.dnodeId);
  pSObj = mndAcquireSnode(pMnode, dropReq.dnodeId);
976 977
  pMObj = mndAcquireMnode(pMnode, dropReq.dnodeId);
  if (pMObj != NULL) {
S
Shengliang Guan 已提交
978 979 980 981 982
    if (sdbGetSize(pMnode->pSdb, SDB_MNODE) <= 1) {
      terrno = TSDB_CODE_MND_TOO_FEW_MNODES;
      goto _OVER;
    }
    if (pMnode->selfDnodeId == dropReq.dnodeId) {
S
Shengliang Guan 已提交
983 984 985 986 987 988
      terrno = TSDB_CODE_MND_CANT_DROP_LEADER;
      goto _OVER;
    }
  }

  int32_t numOfVnodes = mndGetVnodesNum(pMnode, pDnode->id);
D
dmchen 已提交
989
  if ((numOfVnodes > 0 || pMObj != NULL || pSObj != NULL || pQObj != NULL) && !force) {
S
Shengliang Guan 已提交
990
    if (!mndIsDnodeOnline(pDnode, taosGetTimestampMs())) {
991
      terrno = TSDB_CODE_DNODE_OFFLINE;
S
Shengliang Guan 已提交
992 993
      mError("dnode:%d, failed to drop since %s, vnodes:%d mnode:%d qnode:%d snode:%d", pDnode->id, terrstr(),
             numOfVnodes, pMObj != NULL, pQObj != NULL, pSObj != NULL);
S
Shengliang Guan 已提交
994 995
      goto _OVER;
    }
996 997
  }

D
dmchen 已提交
998
  code = mndDropDnode(pMnode, pReq, pDnode, pMObj, pQObj, pSObj, numOfVnodes, force, dropReq.unsafe);
S
Shengliang Guan 已提交
999
  if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS;
S
Shengliang Guan 已提交
1000

S
Shengliang Guan 已提交
1001
_OVER:
S
Shengliang Guan 已提交
1002
  if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) {
S
Shengliang Guan 已提交
1003
    mError("dnode:%d, failed to drop since %s", dropReq.dnodeId, terrstr());
S
Shengliang Guan 已提交
1004 1005
  }

1006
  mndReleaseDnode(pMnode, pDnode);
1007
  mndReleaseMnode(pMnode, pMObj);
1008 1009
  mndReleaseQnode(pMnode, pQObj);
  mndReleaseSnode(pMnode, pSObj);
S
Shengliang Guan 已提交
1010
  return code;
S
Shengliang Guan 已提交
1011 1012
}

S
Shengliang Guan 已提交
1013
static int32_t mndProcessConfigDnodeReq(SRpcMsg *pReq) {
1014 1015
  SMnode     *pMnode = pReq->info.node;
  const char *options[] = {
1016 1017 1018
      "debugFlag",   "dDebugFlag",   "vDebugFlag",   "mDebugFlag",   "wDebugFlag",    "sDebugFlag",   "tsdbDebugFlag",
      "tqDebugFlag", "fsDebugFlag",  "udfDebugFlag", "smaDebugFlag", "idxDebugFlag",  "tdbDebugFlag", "tmrDebugFlag",
      "uDebugFlag",  "smaDebugFlag", "rpcDebugFlag", "qDebugFlag",   "metaDebugFlag",
1019 1020
  };
  int32_t optionSize = tListLen(options);
S
Shengliang Guan 已提交
1021 1022

  SMCfgDnodeReq cfgReq = {0};
S
Shengliang Guan 已提交
1023
  if (tDeserializeSMCfgDnodeReq(pReq->pCont, pReq->contLen, &cfgReq) != 0) {
S
Shengliang Guan 已提交
1024 1025 1026
    terrno = TSDB_CODE_INVALID_MSG;
    return -1;
  }
S
Shengliang Guan 已提交
1027

1028
  mInfo("dnode:%d, start to config, option:%s, value:%s", cfgReq.dnodeId, cfgReq.config, cfgReq.value);
1029
  if (mndCheckOperPrivilege(pMnode, pReq->info.conn.user, MND_OPER_CONFIG_DNODE) != 0) {
S
Shengliang Guan 已提交
1030 1031 1032
    return -1;
  }

S
Shengliang Guan 已提交
1033
  SDCfgDnodeReq dcfgReq = {0};
1034 1035 1036
  if (strcasecmp(cfgReq.config, "resetlog") == 0) {
    strcpy(dcfgReq.config, "resetlog");
  } else if (strncasecmp(cfgReq.config, "monitor", 7) == 0) {
1037 1038 1039 1040 1041 1042
    if (' ' != cfgReq.config[7] && 0 != cfgReq.config[7]) {
      mError("dnode:%d, failed to config monitor since invalid conf:%s", cfgReq.dnodeId, cfgReq.config);
      terrno = TSDB_CODE_INVALID_CFG;
      return -1;
    }

S
Shengliang Guan 已提交
1043 1044 1045
    const char *value = cfgReq.value;
    int32_t     flag = atoi(value);
    if (flag <= 0) {
1046
      flag = atoi(cfgReq.config + 8);
S
Shengliang Guan 已提交
1047
    }
1048 1049
    if (flag < 0 || flag > 2) {
      mError("dnode:%d, failed to config monitor since value:%d", cfgReq.dnodeId, flag);
S
Shengliang Guan 已提交
1050 1051 1052 1053
      terrno = TSDB_CODE_INVALID_CFG;
      return -1;
    }

1054
    strcpy(dcfgReq.config, "monitor");
S
Shengliang Guan 已提交
1055
    snprintf(dcfgReq.value, TSDB_DNODE_VALUE_LEN, "%d", flag);
1056
#ifdef TD_ENTERPRISE
K
kailixu 已提交
1057 1058 1059 1060
  } else if (strncasecmp(cfgReq.config, "activeCode", 10) == 0 || strncasecmp(cfgReq.config, "cActiveCode", 11) == 0) {
    int8_t opt = strncasecmp(cfgReq.config, "a", 1) == 0 ? DND_ACTIVE_CODE : DND_CONN_ACTIVE_CODE;
    int8_t index = opt == DND_ACTIVE_CODE ? 10 : 11;
    if (' ' != cfgReq.config[index] && 0 != cfgReq.config[index]) {
1061 1062 1063 1064
      mError("dnode:%d, failed to config activeCode since invalid conf:%s", cfgReq.dnodeId, cfgReq.config);
      terrno = TSDB_CODE_INVALID_CFG;
      return -1;
    }
1065
    int32_t vlen = strlen(cfgReq.value);
K
kailixu 已提交
1066 1067 1068
    if (vlen > 0 && ((opt == DND_ACTIVE_CODE && vlen != (TSDB_ACTIVE_KEY_LEN - 1)) ||
                     (opt == DND_CONN_ACTIVE_CODE &&
                      (vlen > (TSDB_CONN_ACTIVE_KEY_LEN - 1) || vlen < (TSDB_ACTIVE_KEY_LEN - 1))))) {
1069 1070
      mError("dnode:%d, failed to config activeCode since invalid vlen:%d. conf:%s, val:%s", cfgReq.dnodeId, vlen,
             cfgReq.config, cfgReq.value);
1071 1072 1073 1074
      terrno = TSDB_CODE_INVALID_OPTION;
      return -1;
    }

K
kailixu 已提交
1075
    strcpy(dcfgReq.config, opt == DND_ACTIVE_CODE ? "activeCode" : "cActiveCode");
K
kailixu 已提交
1076 1077
    snprintf(dcfgReq.value, TSDB_DNODE_VALUE_LEN, "%s", cfgReq.value);

K
kailixu 已提交
1078
    if (mndConfigDnode(pMnode, pReq, &cfgReq, opt) != 0) {
K
kailixu 已提交
1079 1080 1081
      mError("dnode:%d, failed to config activeCode since %s", cfgReq.dnodeId, terrstr());
      return -1;
    }
K
kailixu 已提交
1082
    return 0;
1083
#endif
S
Shengliang Guan 已提交
1084
  } else {
1085 1086 1087 1088 1089 1090
    bool findOpt = false;
    for (int32_t d = 0; d < optionSize; ++d) {
      const char *optName = options[d];
      int32_t     optLen = strlen(optName);
      if (strncasecmp(cfgReq.config, optName, optLen) != 0) continue;

1091 1092 1093 1094 1095 1096
      if (' ' != cfgReq.config[optLen] && 0 != cfgReq.config[optLen]) {
        mError("dnode:%d, failed to config since invalid conf:%s", cfgReq.dnodeId, cfgReq.config);
        terrno = TSDB_CODE_INVALID_CFG;
        return -1;
      }

1097
      const char *value = cfgReq.value;
M
Minglei Jin 已提交
1098
      int32_t     flag = atoi(value);
1099 1100 1101
      if (flag <= 0) {
        flag = atoi(cfgReq.config + optLen + 1);
      }
1102
      if (flag < 0 || flag > 255) {
1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117
        mError("dnode:%d, failed to config %s since value:%d", cfgReq.dnodeId, optName, flag);
        terrno = TSDB_CODE_INVALID_CFG;
        return -1;
      }

      tstrncpy(dcfgReq.config, optName, optLen + 1);
      snprintf(dcfgReq.value, TSDB_DNODE_VALUE_LEN, "%d", flag);
      findOpt = true;
    }

    if (!findOpt) {
      terrno = TSDB_CODE_INVALID_CFG;
      mError("dnode:%d, failed to config since %s", cfgReq.dnodeId, terrstr());
      return -1;
    }
S
Shengliang Guan 已提交
1118 1119
  }

S
Shengliang Guan 已提交
1120
  int32_t code = -1;
1121 1122
  SSdb   *pSdb = pMnode->pSdb;
  void   *pIter = NULL;
S
Shengliang Guan 已提交
1123 1124 1125 1126
  while (1) {
    SDnodeObj *pDnode = NULL;
    pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pDnode);
    if (pIter == NULL) break;
S
Shengliang Guan 已提交
1127

S
Shengliang Guan 已提交
1128 1129 1130 1131 1132 1133 1134 1135 1136
    if (pDnode->id == cfgReq.dnodeId || cfgReq.dnodeId == -1 || cfgReq.dnodeId == 0) {
      SEpSet  epSet = mndGetDnodeEpset(pDnode);
      int32_t bufLen = tSerializeSDCfgDnodeReq(NULL, 0, &dcfgReq);
      void   *pBuf = rpcMallocCont(bufLen);

      if (pBuf != NULL) {
        tSerializeSDCfgDnodeReq(pBuf, bufLen, &dcfgReq);
        mInfo("dnode:%d, send config req to dnode, app:%p config:%s value:%s", cfgReq.dnodeId, pReq->info.ahandle,
              dcfgReq.config, dcfgReq.value);
1137
        SRpcMsg rpcMsg = {.msgType = TDMT_DND_CONFIG_DNODE, .pCont = pBuf, .contLen = bufLen};
S
Shengliang Guan 已提交
1138 1139 1140 1141
        tmsgSendReq(&epSet, &rpcMsg);
        code = 0;
      }
    }
S
Shengliang Guan 已提交
1142

S
Shengliang Guan 已提交
1143 1144
    sdbRelease(pSdb, pDnode);
  }
1145

S
Shengliang Guan 已提交
1146 1147 1148 1149
  if (code == -1) {
    terrno = TSDB_CODE_MND_DNODE_NOT_EXIST;
  }
  return code;
S
Shengliang Guan 已提交
1150 1151
}

S
Shengliang Guan 已提交
1152
static int32_t mndProcessConfigDnodeRsp(SRpcMsg *pRsp) {
1153
  mInfo("config rsp from dnode");
S
Shengliang Guan 已提交
1154
  return 0;
1155
}
S
Shengliang Guan 已提交
1156

S
Shengliang Guan 已提交
1157 1158
static int32_t mndRetrieveConfigs(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pBlock, int32_t rows) {
  SMnode *pMnode = pReq->info.node;
S
Shengliang Guan 已提交
1159
  int32_t totalRows = 0;
S
Shengliang Guan 已提交
1160 1161
  int32_t numOfRows = 0;
  char   *cfgOpts[TSDB_CONFIG_NUMBER] = {0};
D
dapan1121 已提交
1162
  char    cfgVals[TSDB_CONFIG_NUMBER][TSDB_CONFIG_VALUE_LEN + 1] = {0};
S
Shengliang Guan 已提交
1163
  char   *pWrite = NULL;
S
Shengliang Guan 已提交
1164 1165
  int32_t cols = 0;

S
Shengliang Guan 已提交
1166
  cfgOpts[totalRows] = "statusInterval";
D
dapan1121 已提交
1167
  snprintf(cfgVals[totalRows], TSDB_CONFIG_VALUE_LEN, "%d", tsStatusInterval);
S
Shengliang Guan 已提交
1168
  totalRows++;
S
Shengliang Guan 已提交
1169

S
Shengliang Guan 已提交
1170
  cfgOpts[totalRows] = "timezone";
D
dapan1121 已提交
1171
  snprintf(cfgVals[totalRows], TSDB_CONFIG_VALUE_LEN, "%s", tsTimezoneStr);
S
Shengliang Guan 已提交
1172
  totalRows++;
S
Shengliang Guan 已提交
1173

S
Shengliang Guan 已提交
1174
  cfgOpts[totalRows] = "locale";
D
dapan1121 已提交
1175
  snprintf(cfgVals[totalRows], TSDB_CONFIG_VALUE_LEN, "%s", tsLocale);
S
Shengliang Guan 已提交
1176
  totalRows++;
S
Shengliang Guan 已提交
1177

S
Shengliang Guan 已提交
1178
  cfgOpts[totalRows] = "charset";
D
dapan1121 已提交
1179
  snprintf(cfgVals[totalRows], TSDB_CONFIG_VALUE_LEN, "%s", tsCharset);
S
Shengliang Guan 已提交
1180
  totalRows++;
S
Shengliang Guan 已提交
1181

1182
  char buf[TSDB_CONFIG_OPTION_LEN + VARSTR_HEADER_SIZE] = {0};
D
dapan1121 已提交
1183
  char bufVal[TSDB_CONFIG_VALUE_LEN + VARSTR_HEADER_SIZE] = {0};
1184

S
Shengliang Guan 已提交
1185
  for (int32_t i = 0; i < totalRows; i++) {
S
Shengliang Guan 已提交
1186 1187
    cols = 0;

1188
    STR_WITH_MAXSIZE_TO_VARSTR(buf, cfgOpts[i], TSDB_CONFIG_OPTION_LEN);
M
Minghao Li 已提交
1189
    SColumnInfoData *pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1190
    colDataSetVal(pColInfo, numOfRows, (const char *)buf, false);
S
Shengliang Guan 已提交
1191

D
dapan1121 已提交
1192
    STR_WITH_MAXSIZE_TO_VARSTR(bufVal, cfgVals[i], TSDB_CONFIG_VALUE_LEN);
1193
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1194
    colDataSetVal(pColInfo, numOfRows, (const char *)bufVal, false);
S
Shengliang Guan 已提交
1195 1196

    numOfRows++;
S
Shengliang Guan 已提交
1197 1198
  }

1199
  pShow->numOfRows += numOfRows;
S
Shengliang Guan 已提交
1200 1201 1202 1203 1204
  return numOfRows;
}

static void mndCancelGetNextConfig(SMnode *pMnode, void *pIter) {}

S
Shengliang Guan 已提交
1205 1206
static int32_t mndRetrieveDnodes(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pBlock, int32_t rows) {
  SMnode    *pMnode = pReq->info.node;
S
Shengliang Guan 已提交
1207 1208 1209
  SSdb      *pSdb = pMnode->pSdb;
  int32_t    numOfRows = 0;
  int32_t    cols = 0;
1210
  ESdbStatus objStatus = 0;
S
Shengliang Guan 已提交
1211
  SDnodeObj *pDnode = NULL;
S
Shengliang Guan 已提交
1212
  int64_t    curMs = taosGetTimestampMs();
K
kailixu 已提交
1213
  char       buf[TSDB_CONN_ACTIVE_KEY_LEN + VARSTR_HEADER_SIZE];  // make sure TSDB_CONN_ACTIVE_KEY_LEN >= TSDB_EP_LEN
S
Shengliang Guan 已提交
1214 1215

  while (numOfRows < rows) {
1216
    pShow->pIter = sdbFetchAll(pSdb, SDB_DNODE, pShow->pIter, (void **)&pDnode, &objStatus, true);
S
Shengliang Guan 已提交
1217
    if (pShow->pIter == NULL) break;
S
Shengliang Guan 已提交
1218
    bool online = mndIsDnodeOnline(pDnode, curMs);
S
Shengliang Guan 已提交
1219 1220 1221

    cols = 0;

M
Minghao Li 已提交
1222
    SColumnInfoData *pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1223
    colDataSetVal(pColInfo, numOfRows, (const char *)&pDnode->id, false);
1224

1225
    STR_WITH_MAXSIZE_TO_VARSTR(buf, pDnode->ep, pShow->pMeta->pSchemas[cols].bytes);
1226 1227

    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1228
    colDataSetVal(pColInfo, numOfRows, buf, false);
1229 1230 1231

    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
    int16_t id = mndGetVnodesNum(pMnode, pDnode->id);
1232
    colDataSetVal(pColInfo, numOfRows, (const char *)&id, false);
S
Shengliang Guan 已提交
1233

1234
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1235
    colDataSetVal(pColInfo, numOfRows, (const char *)&pDnode->numOfSupportVnodes, false);
S
Shengliang Guan 已提交
1236

1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248
    const char *status = "ready";
    if (objStatus == SDB_STATUS_CREATING) status = "creating";
    if (objStatus == SDB_STATUS_DROPPING) status = "dropping";
    if (!online) {
      if (objStatus == SDB_STATUS_CREATING)
        status = "creating*";
      else if (objStatus == SDB_STATUS_DROPPING)
        status = "dropping*";
      else
        status = "offline";
    }

K
kailixu 已提交
1249
    STR_TO_VARSTR(buf, status);
1250
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
K
kailixu 已提交
1251
    colDataSetVal(pColInfo, numOfRows, buf, false);
S
Shengliang Guan 已提交
1252

1253
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1254
    colDataSetVal(pColInfo, numOfRows, (const char *)&pDnode->createdTime, false);
S
Shengliang Guan 已提交
1255

C
cadem 已提交
1256 1257 1258
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
    colDataSetVal(pColInfo, numOfRows, (const char *)&pDnode->rebootTime, false);

wafwerar's avatar
wafwerar 已提交
1259
    char *b = taosMemoryCalloc(VARSTR_HEADER_SIZE + strlen(offlineReason[pDnode->offlineReason]) + 1, 1);
1260
    STR_TO_VARSTR(b, online ? "" : offlineReason[pDnode->offlineReason]);
S
Shengliang Guan 已提交
1261

1262
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
1263
    colDataSetVal(pColInfo, numOfRows, b, false);
wafwerar's avatar
wafwerar 已提交
1264
    taosMemoryFreeClear(b);
S
Shengliang Guan 已提交
1265

K
kailixu 已提交
1266 1267
#ifdef TD_ENTERPRISE
    STR_TO_VARSTR(buf, pDnode->active);
K
kailixu 已提交
1268
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
K
kailixu 已提交
1269
    colDataSetVal(pColInfo, numOfRows, buf, false);
K
kailixu 已提交
1270

K
kailixu 已提交
1271
    STR_TO_VARSTR(buf, pDnode->connActive);
K
kailixu 已提交
1272
    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
K
kailixu 已提交
1273 1274
    colDataSetVal(pColInfo, numOfRows, buf, false);
#endif
K
kailixu 已提交
1275

S
Shengliang Guan 已提交
1276 1277 1278 1279
    numOfRows++;
    sdbRelease(pSdb, pDnode);
  }

1280
  pShow->numOfRows += numOfRows;
S
Shengliang Guan 已提交
1281 1282 1283 1284 1285 1286
  return numOfRows;
}

static void mndCancelGetNextDnode(SMnode *pMnode, void *pIter) {
  SSdb *pSdb = pMnode->pSdb;
  sdbCancelFetch(pSdb, pIter);
L
Liu Jicong 已提交
1287
}