taosdata/TDengine | Build 3780 | source/dnode/mnode/impl/src/mndDump.c | Coveralls

29

void reportStartup(const char *name, const char *desc) {}

×

30

void sendRsp(SRpcMsg *pMsg) { rpcFreeCont(pMsg->pCont); }

×

32

int32_t sendReq(const SEpSet *pEpSet, SRpcMsg *pMsg) {

×

33

  int32_t code = 0;

×

34

  code = TSDB_CODE_INVALID_PTR;

×

35

  TAOS_RETURN(code);

×

37

int32_t sendSyncReq(const SEpSet *pEpSet, SRpcMsg *pMsg) {

×

38

  int32_t code = 0;

×

39

  code = TSDB_CODE_INVALID_PTR;

×

40

  TAOS_RETURN(code);

×

43

char *i642str(int64_t val) {

×

45

  (void)snprintf(str, sizeof(str), "%" PRId64, val);

×

46

  return str;

×

49

void dumpFunc(SSdb *pSdb, SJson *json) {

×

50

  int32_t code = 0;

×

51

  int32_t lino = 0;

×

52

  void   *pIter = NULL;

×

53

  SJson *items = tjsonAddArrayToObject(json, "funcs");

×

55

  while (1) {

×

56

    SFuncObj *pObj = NULL;

×

57

    pIter = sdbFetch(pSdb, SDB_FUNC, pIter, (void **)&pObj);

×

58

    if (pIter == NULL) break;

×

60

    SJson *item = tjsonCreateObject();

×

61

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

62

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", pObj->name), pObj, &lino, _OVER);

×

63

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

64

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "funcType", i642str(pObj->funcType)), pObj, &lino, _OVER);

×

65

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "scriptType", i642str(pObj->scriptType)), pObj, &lino, _OVER);

×

66

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "align", i642str(pObj->align)), pObj, &lino, _OVER);

×

67

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "outputType", i642str(pObj->outputType)), pObj, &lino, _OVER);

×

68

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "outputLen", i642str(pObj->outputLen)), pObj, &lino, _OVER);

×

69

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "bufSize", i642str(pObj->bufSize)), pObj, &lino, _OVER);

×

70

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "signature", i642str(pObj->signature)), pObj, &lino, _OVER);

×

71

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "commentSize", i642str(pObj->commentSize)), pObj, &lino, _OVER);

×

72

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "codeSize", i642str(pObj->codeSize)), pObj, &lino, _OVER);

×

73

    sdbRelease(pSdb, pObj);

×

75

_OVER:

×

76

  if (code != 0) mError("failed to dump func info at line:%d since %s", lino, tstrerror(code));

×

77

×

79

void dumpDb(SSdb *pSdb, SJson *json) {

×

80

  int32_t code = 0;

×

81

  int32_t lino = 0;

×

82

  void  *pIter = NULL;

×

83

  SJson *items = tjsonCreateObject();

×

84

  TAOS_CHECK_GOTO(tjsonAddItemToObject(json, "dbs", items), &lino, _OVER);

×

86

  while (1) {

×

87

    SDbObj *pObj = NULL;

×

88

    pIter = sdbFetch(pSdb, SDB_DB, pIter, (void **)&pObj);

×

89

    if (pIter == NULL) break;

×

91

    SJson *item = tjsonCreateObject();

×

92

    RETRIEVE_CHECK_GOTO(tjsonAddItemToObject(items, "db", item), pObj, &lino, _OVER);

×

94

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->name)), pObj, &lino, _OVER);

×

95

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "acct", pObj->acct), pObj, &lino, _OVER);

×

96

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createUser", pObj->createUser), pObj, &lino, _OVER);

×

97

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

98

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

99

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "uid", i642str(pObj->uid)), pObj, &lino, _OVER);

×

100

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "cfgVersion", i642str(pObj->cfgVersion)), pObj, &lino, _OVER);

×

101

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "vgVersion", i642str(pObj->vgVersion)), pObj, &lino, _OVER);

×

102

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfVgroups", i642str(pObj->cfg.numOfVgroups)), pObj, &lino,

×

104

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfStables", i642str(pObj->cfg.numOfStables)), pObj, &lino,

×

106

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "buffer", i642str(pObj->cfg.buffer)), pObj, &lino, _OVER);

×

107

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "pageSize", i642str(pObj->cfg.pageSize)), pObj, &lino, _OVER);

×

108

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "pages", i642str(pObj->cfg.pages)), pObj, &lino, _OVER);

×

109

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "cacheLastSize", i642str(pObj->cfg.cacheLastSize)), pObj, &lino,

×

111

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "daysPerFile", i642str(pObj->cfg.daysPerFile)), pObj, &lino,

×

113

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "daysToKeep0", i642str(pObj->cfg.daysToKeep0)), pObj, &lino,

×

115

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "daysToKeep1", i642str(pObj->cfg.daysToKeep1)), pObj, &lino,

×

117

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "daysToKeep2", i642str(pObj->cfg.daysToKeep2)), pObj, &lino,

×

119

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "minRows", i642str(pObj->cfg.minRows)), pObj, &lino, _OVER);

×

120

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "maxRows", i642str(pObj->cfg.maxRows)), pObj, &lino, _OVER);

×

121

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "precision", i642str(pObj->cfg.precision)), pObj, &lino, _OVER);

×

122

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "compression", i642str(pObj->cfg.compression)), pObj, &lino,

×

124

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "encryptAlgorithm", i642str(pObj->cfg.encryptAlgorithm)), pObj,

×

126

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "replications", i642str(pObj->cfg.replications)), pObj, &lino,

×

128

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "strict", i642str(pObj->cfg.strict)), pObj, &lino, _OVER);

×

129

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "cacheLast", i642str(pObj->cfg.cacheLast)), pObj, &lino, _OVER);

×

130

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "hashMethod", i642str(pObj->cfg.hashMethod)), pObj, &lino, _OVER);

×

131

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "hashPrefix", i642str(pObj->cfg.hashPrefix)), pObj, &lino, _OVER);

×

132

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "hashSuffix", i642str(pObj->cfg.hashSuffix)), pObj, &lino, _OVER);

×

133

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sstTrigger", i642str(pObj->cfg.sstTrigger)), pObj, &lino, _OVER);

×

134

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "tsdbPageSize", i642str(pObj->cfg.tsdbPageSize)), pObj, &lino,

×

136

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "schemaless", i642str(pObj->cfg.schemaless)), pObj, &lino, _OVER);

×

137

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "walLevel", i642str(pObj->cfg.walLevel)), pObj, &lino, _OVER);

×

138

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "walFsyncPeriod", i642str(pObj->cfg.walFsyncPeriod)), pObj, &lino,

×

140

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "walRetentionPeriod", i642str(pObj->cfg.walRetentionPeriod)), pObj,

×

142

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "walRetentionSize", i642str(pObj->cfg.walRetentionSize)), pObj,

×

144

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "walRollPeriod", i642str(pObj->cfg.walRollPeriod)), pObj, &lino,

×

146

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "walSegmentSize", i642str(pObj->cfg.walSegmentSize)), pObj, &lino,

×

149

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfRetensions", i642str(pObj->cfg.numOfRetensions)), pObj,

×

151

    for (int32_t i = 0; i < pObj->cfg.numOfRetensions; ++i) {

×

152

      SJson *rentensions = tjsonAddArrayToObject(item, "rentensions");

×

153

      SJson *rentension = tjsonCreateObject();

×

154

      RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(rentensions, rentension), pObj, &lino, _OVER);

×

156

      SRetention *pRetension = taosArrayGet(pObj->cfg.pRetensions, i);

×

157

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "freq", i642str(pRetension->freq)), pObj, &lino, _OVER);

×

158

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "freqUnit", i642str(pRetension->freqUnit)), pObj, &lino, _OVER);

×

159

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "keep", i642str(pRetension->keep)), pObj, &lino, _OVER);

×

160

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "keepUnit", i642str(pRetension->keepUnit)), pObj, &lino, _OVER);

×

163

    sdbRelease(pSdb, pObj);

×

165

_OVER:

×

166

  if (code != 0) mError("failed to dump db info at line:%d since %s", lino, tstrerror(code));

×

167

×

169

void dumpStb(SSdb *pSdb, SJson *json) {

×

170

  int32_t code = 0;

×

171

  int32_t lino = 0;

×

172

  void  *pIter = NULL;

×

173

  SJson *items = tjsonAddArrayToObject(json, "stbs");

×

175

  while (1) {

×

176

    SStbObj *pObj = NULL;

×

177

    pIter = sdbFetch(pSdb, SDB_STB, pIter, (void **)&pObj);

×

178

    if (pIter == NULL) break;

×

180

    SJson *item = tjsonCreateObject();

×

181

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

182

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", mndGetStbStr(pObj->name)), pObj, &lino, _OVER);

×

183

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "db", mndGetDbStr(pObj->db)), pObj, &lino, _OVER);

×

184

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

185

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

186

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "uid", i642str(pObj->uid)), pObj, &lino, _OVER);

×

187

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid)), pObj, &lino, _OVER);

×

188

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "tagVer", i642str(pObj->tagVer)), pObj, &lino, _OVER);

×

189

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "colVer", i642str(pObj->colVer)), pObj, &lino, _OVER);

×

190

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "smaVer", i642str(pObj->smaVer)), pObj, &lino, _OVER);

×

191

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "nextColId", i642str(pObj->nextColId)), pObj, &lino, _OVER);

×

192

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "watermark1", i642str(pObj->watermark[0])), pObj, &lino, _OVER);

×

193

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "watermark2", i642str(pObj->watermark[1])), pObj, &lino, _OVER);

×

194

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "maxdelay0", i642str(pObj->maxdelay[0])), pObj, &lino, _OVER);

×

195

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "maxdelay1", i642str(pObj->maxdelay[1])), pObj, &lino, _OVER);

×

196

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "ttl", i642str(pObj->ttl)), pObj, &lino, _OVER);

×

197

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfFuncs", i642str(pObj->numOfFuncs)), pObj, &lino, _OVER);

×

198

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "commentLen", i642str(pObj->commentLen)), pObj, &lino, _OVER);

×

199

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "ast1Len", i642str(pObj->ast1Len)), pObj, &lino, _OVER);

×

200

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "ast2Len", i642str(pObj->ast2Len)), pObj, &lino, _OVER);

×

201

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "virtual", i642str(pObj->virtualStb)), pObj, &lino, _OVER);

×

203

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfColumns", i642str(pObj->numOfColumns)), pObj, &lino, _OVER);

×

204

    SJson *columns = tjsonAddArrayToObject(item, "columns");

×

205

    for (int32_t i = 0; i < pObj->numOfColumns; ++i) {

×

206

      SJson *column = tjsonCreateObject();

×

207

      RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(columns, column), pObj, &lino, _OVER);

×

209

      SSchema *pColumn = &pObj->pColumns[i];

×

210

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(column, "type", i642str(pColumn->type)), pObj, &lino, _OVER);

×

211

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(column, "typestr", tDataTypes[pColumn->type].name), pObj, &lino,

×

213

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(column, "flags", i642str(pColumn->flags)), pObj, &lino, _OVER);

×

214

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(column, "colId", i642str(pColumn->colId)), pObj, &lino, _OVER);

×

215

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(column, "bytes", i642str(pColumn->bytes)), pObj, &lino, _OVER);

×

216

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(column, "name", pColumn->name), pObj, &lino, _OVER);

×

219

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfTags", i642str(pObj->numOfTags)), pObj, &lino, _OVER);

×

220

    SJson *tags = tjsonAddArrayToObject(item, "tags");

×

221

    for (int32_t i = 0; i < pObj->numOfTags; ++i) {

×

222

      SJson *tag = tjsonCreateObject();

×

223

      RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(tags, tag), pObj, &lino, _OVER);

×

225

      SSchema *pTag = &pObj->pTags[i];

×

226

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(tag, "type", i642str(pTag->type)), pObj, &lino, _OVER);

×

227

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(tag, "typestr", tDataTypes[pTag->type].name), pObj, &lino, _OVER);

×

228

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(tag, "flags", i642str(pTag->flags)), pObj, &lino, _OVER);

×

229

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(tag, "colId", i642str(pTag->colId)), pObj, &lino, _OVER);

×

230

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(tag, "bytes", i642str(pTag->bytes)), pObj, &lino, _OVER);

×

231

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(tag, "name", pTag->name), pObj, &lino, _OVER);

×

234

    sdbRelease(pSdb, pObj);

×

236

_OVER:

×

237

  if (code != 0) mError("failed to dump stable info at line:%d since %s", lino, tstrerror(code));

×

238

×

240

void dumpSma(SSdb *pSdb, SJson *json) {

×

241

  int32_t code = 0;

×

242

  int32_t lino = 0;

×

243

  void  *pIter = NULL;

×

244

  SJson *items = tjsonAddArrayToObject(json, "smas");

×

246

  while (1) {

×

247

    SSmaObj *pObj = NULL;

×

248

    pIter = sdbFetch(pSdb, SDB_SMA, pIter, (void **)&pObj);

×

249

    if (pIter == NULL) break;

×

251

    SJson *item = tjsonCreateObject();

×

252

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

253

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", mndGetStbStr(pObj->name)), pObj, &lino, _OVER);

×

254

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stb", mndGetStbStr(pObj->stb)), pObj, &lino, _OVER);

×

255

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "db", mndGetDbStr(pObj->db)), pObj, &lino, _OVER);

×

256

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dstTbName", mndGetStbStr(pObj->dstTbName)), pObj, &lino, _OVER);

×

257

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

258

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "uid", i642str(pObj->uid)), pObj, &lino, _OVER);

×

259

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stbUid", i642str(pObj->stbUid)), pObj, &lino, _OVER);

×

260

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid)), pObj, &lino, _OVER);

×

261

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dstTbUid", i642str(pObj->dstTbUid)), pObj, &lino, _OVER);

×

262

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "intervalUnit", i642str(pObj->intervalUnit)), pObj, &lino, _OVER);

×

263

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "slidingUnit", i642str(pObj->slidingUnit)), pObj, &lino, _OVER);

×

264

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "timezone", i642str(pObj->timezone)), pObj, &lino, _OVER);

×

265

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dstVgId", i642str(pObj->dstVgId)), pObj, &lino, _OVER);

×

266

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "interval", i642str(pObj->interval)), pObj, &lino, _OVER);

×

267

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "offset", i642str(pObj->offset)), pObj, &lino, _OVER);

×

268

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sliding", i642str(pObj->sliding)), pObj, &lino, _OVER);

×

269

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "exprLen", i642str(pObj->exprLen)), pObj, &lino, _OVER);

×

270

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "tagsFilterLen", i642str(pObj->tagsFilterLen)), pObj, &lino,

×

272

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sqlLen", i642str(pObj->sqlLen)), pObj, &lino, _OVER);

×

273

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "astLen", i642str(pObj->astLen)), pObj, &lino, _OVER);

×

274

    sdbRelease(pSdb, pObj);

×

276

_OVER:

×

277

  if (code != 0) mError("failed to dump sma info at line:%d since %s", lino, tstrerror(code));

×

278

×

280

void dumpVgroup(SSdb *pSdb, SJson *json) {

×

281

  int32_t code = 0;

×

282

  int32_t lino = 0;

×

283

  void  *pIter = NULL;

×

284

  SJson *items = tjsonAddArrayToObject(json, "vgroups");

×

286

  while (1) {

×

287

    SVgObj *pObj = NULL;

×

288

    pIter = sdbFetch(pSdb, SDB_VGROUP, pIter, (void **)&pObj);

×

289

    if (pIter == NULL) break;

×

291

    SJson *item = tjsonCreateObject();

×

292

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

293

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "vgId", i642str(pObj->vgId)), pObj, &lino, _OVER);

×

294

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

295

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

296

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "version", i642str(pObj->version)), pObj, &lino, _OVER);

×

297

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "hashBegin", i642str(pObj->hashBegin)), pObj, &lino, _OVER);

×

298

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "hashEnd", i642str(pObj->hashEnd)), pObj, &lino, _OVER);

×

299

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "db", mndGetDbStr(pObj->dbName)), pObj, &lino, _OVER);

×

300

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid)), pObj, &lino, _OVER);

×

301

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "isTsma", i642str(pObj->isTsma)), pObj, &lino, _OVER);

×

302

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "replica", i642str(pObj->replica)), pObj, &lino, _OVER);

×

303

    for (int32_t i = 0; i < pObj->replica; ++i) {

×

304

      SJson *replicas = tjsonAddArrayToObject(item, "replicas");

×

305

      SJson *replica = tjsonCreateObject();

×

306

      RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(replicas, replica), pObj, &lino, _OVER);

×

307

      RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(replica, "dnodeId", i642str(pObj->vnodeGid[i].dnodeId)), pObj, &lino,

×

310

    sdbRelease(pSdb, pObj);

×

312

_OVER:

×

313

  if (code != 0) mError("failed to dump vgroup info at line:%d since %s", lino, tstrerror(code));

×

314

×

316

void dumpTopic(SSdb *pSdb, SJson *json) {

×

317

  int32_t code = 0;

×

318

  int32_t lino = 0;

×

319

  void  *pIter = NULL;

×

320

  SJson *items = tjsonAddArrayToObject(json, "topics");

×

322

  while (1) {

×

323

    SMqTopicObj *pObj = NULL;

×

324

    pIter = sdbFetch(pSdb, SDB_TOPIC, pIter, (void **)&pObj);

×

325

    if (pIter == NULL) break;

×

327

    SJson *item = tjsonCreateObject();

×

328

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

329

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->name)), pObj, &lino, _OVER);

×

330

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->db)), pObj, &lino, _OVER);

×

331

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createTime", i642str(pObj->createTime)), pObj, &lino, _OVER);

×

332

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

333

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "uid", i642str(pObj->uid)), pObj, &lino, _OVER);

×

334

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid)), pObj, &lino, _OVER);

×

335

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "version", i642str(pObj->version)), pObj, &lino, _OVER);

×

336

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "subType", i642str(pObj->subType)), pObj, &lino, _OVER);

×

337

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "withMeta", i642str(pObj->withMeta)), pObj, &lino, _OVER);

×

338

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stbUid", i642str(pObj->stbUid)), pObj, &lino, _OVER);

×

339

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stbName", mndGetStableStr(pObj->stbName)), pObj, &lino, _OVER);

×

340

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sqlLen", i642str(pObj->sqlLen)), pObj, &lino, _OVER);

×

341

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "astLen", i642str(pObj->astLen)), pObj, &lino, _OVER);

×

342

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sqlLen", i642str(pObj->sqlLen)), pObj, &lino, _OVER);

×

343

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "ntbUid", i642str(pObj->ntbUid)), pObj, &lino, _OVER);

×

344

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "ctbStbUid", i642str(pObj->ctbStbUid)), pObj, &lino, _OVER);

×

345

    sdbRelease(pSdb, pObj);

×

347

_OVER:

×

348

  if (code != 0) mError("failed to dump topic info at line:%d since %s", lino, tstrerror(code));

×

349

×

351

void dumpConsumer(SSdb *pSdb, SJson *json) {

×

352

  int32_t code = 0;

×

353

  int32_t lino = 0;

×

354

  void  *pIter = NULL;

×

355

  SJson *items = tjsonAddArrayToObject(json, "consumers");

×

357

  while (1) {

×

358

    SMqConsumerObj *pObj = NULL;

×

359

    pIter = sdbFetch(pSdb, SDB_CONSUMER, pIter, (void **)&pObj);

×

360

    if (pIter == NULL) break;

×

362

    SJson *item = tjsonCreateObject();

×

363

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

364

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "consumerId", i642str(pObj->consumerId)), pObj, &lino, _OVER);

×

365

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "cgroup", pObj->cgroup), pObj, &lino, _OVER);

×

366

    sdbRelease(pSdb, pObj);

×

368

_OVER:

×

369

  if (code != 0) mError("failed to dump consumer info at line:%d since %s", lino, tstrerror(code));

×

370

×

372

void dumpSubscribe(SSdb *pSdb, SJson *json) {

×

373

  int32_t code = 0;

×

374

  int32_t lino = 0;

×

375

  void  *pIter = NULL;

×

376

  SJson *items = tjsonAddArrayToObject(json, "subscribes");

×

378

  while (1) {

×

379

    SMqSubscribeObj *pObj = NULL;

×

380

    pIter = sdbFetch(pSdb, SDB_SUBSCRIBE, pIter, (void **)&pObj);

×

381

    if (pIter == NULL) break;

×

383

    SJson *item = tjsonCreateObject();

×

384

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

385

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "key", pObj->key), pObj, &lino, _OVER);

×

386

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dbUid", i642str(pObj->dbUid)), pObj, &lino, _OVER);

×

387

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stbUid", i642str(pObj->stbUid)), pObj, &lino, _OVER);

×

388

    sdbRelease(pSdb, pObj);

×

390

_OVER:

×

391

  if (code != 0) mError("failed to dump subscribe info at line:%d since %s", lino, tstrerror(code));

×

392

×

394

void dumpStream(SSdb *pSdb, SJson *json) {

×

395

  int32_t code = 0;

×

396

  int32_t lino = 0;

×

397

  void   *pIter = NULL;

×

398

  SJson *items = tjsonAddArrayToObject(json, "streams");

×

400

  while (1) {

×

401

    SStreamObj *pObj = NULL;

×

402

    pIter = sdbFetch(pSdb, SDB_STREAM, pIter, (void **)&pObj);

×

403

    if (pIter == NULL) break;

×

405

    SJson *item = tjsonCreateObject();

×

406

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

407

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", mndGetDbStr(pObj->name)), pObj, &lino, _OVER);

×

408

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createTime", i642str(pObj->createTime)), pObj, &lino, _OVER);

×

409

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

410

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "version", i642str(pObj->version)), pObj, &lino, _OVER);

×

411

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "totalLevel", i642str(pObj->totalLevel)), pObj, &lino, _OVER);

×

412

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "smaId", i642str(pObj->smaId)), pObj, &lino, _OVER);

×

413

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "uid", i642str(pObj->uid)), pObj, &lino, _OVER);

×

414

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "status", i642str(pObj->status)), pObj, &lino, _OVER);

×

415

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "igExpired", i642str(pObj->conf.igExpired)), pObj, &lino, _OVER);

×

416

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "trigger", i642str(pObj->conf.trigger)), pObj, &lino, _OVER);

×

417

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "triggerParam", i642str(pObj->conf.triggerParam)), pObj, &lino,

×

419

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "watermark", i642str(pObj->conf.watermark)), pObj, &lino, _OVER);

×

420

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sourceDbUid", i642str(pObj->sourceDbUid)), pObj, &lino, _OVER);

×

421

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "targetDbUid", i642str(pObj->targetDbUid)), pObj, &lino, _OVER);

×

422

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "sourceDb", mndGetDbStr(pObj->sourceDb)), pObj, &lino, _OVER);

×

423

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "targetDb", mndGetDbStr(pObj->targetDb)), pObj, &lino, _OVER);

×

424

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "targetSTbName", mndGetStbStr(pObj->targetSTbName)), pObj, &lino,

×

426

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "targetStbUid", i642str(pObj->targetStbUid)), pObj, &lino, _OVER);

×

427

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "fixedSinkVgId", i642str(pObj->fixedSinkVgId)), pObj, &lino,

×

429

    sdbRelease(pSdb, pObj);

×

431

_OVER:

×

432

  if (code != 0) mError("failed to dump stream info at line:%d since %s", lino, tstrerror(code));

×

433

×

435

void dumpAcct(SSdb *pSdb, SJson *json) {

×

436

  int32_t code = 0;

×

437

  int32_t lino = 0;

×

438

  void  *pIter = NULL;

×

439

  SJson *items = tjsonAddArrayToObject(json, "accts");

×

441

  while (1) {

×

442

    SAcctObj *pObj = NULL;

×

443

    pIter = sdbFetch(pSdb, SDB_ACCT, pIter, (void **)&pObj);

×

444

    if (pIter == NULL) break;

×

446

    SJson *item = tjsonCreateObject();

×

447

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

448

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "acct", pObj->acct), pObj, &lino, _OVER);

×

449

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

450

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

451

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "acctId", i642str(pObj->acctId)), pObj, &lino, _OVER);

×

452

    sdbRelease(pSdb, pObj);

×

454

_OVER:

×

455

  if (code != 0) mError("failed to dump acct info at line:%d since %s", lino, tstrerror(code));

×

456

×

458

void dumpAuth(SSdb *pSdb, SJson *json) {

×

460

×

462

void dumpUser(SSdb *pSdb, SJson *json) {

×

463

  int32_t code = 0;

×

464

  int32_t lino = 0;

×

465

  void  *pIter = NULL;

×

466

  SJson *items = tjsonAddArrayToObject(json, "users");

×

468

  while (1) {

×

469

    SUserObj *pObj = NULL;

×

470

    pIter = sdbFetch(pSdb, SDB_USER, pIter, (void **)&pObj);

×

471

    if (pIter == NULL) break;

×

473

    SJson *item = tjsonCreateObject();

×

474

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

475

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", pObj->user), pObj, &lino, _OVER);

×

476

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "acct", pObj->acct), pObj, &lino, _OVER);

×

477

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

478

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

479

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "superUser", i642str(pObj->superUser)), pObj, &lino, _OVER);

×

480

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "authVersion", i642str(pObj->authVersion)), pObj, &lino, _OVER);

×

481

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "passVersion", i642str(pObj->passVersion)), pObj, &lino, _OVER);

×

482

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfReadDbs", i642str(taosHashGetSize(pObj->readDbs))), pObj,

×

484

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "numOfWriteDbs", i642str(taosHashGetSize(pObj->writeDbs))), pObj,

×

486

    sdbRelease(pSdb, pObj);

×

488

_OVER:

×

489

  if (code != 0) mError("failed to dump user info at line:%d since %s", lino, tstrerror(code));

×

490

×

492

void dumpDnode(SSdb *pSdb, SJson *json) {

×

493

  int32_t code = 0;

×

494

  int32_t lino = 0;

×

495

  void  *pIter = NULL;

×

496

  SJson *items = tjsonAddArrayToObject(json, "dnodes");

×

498

  while (1) {

×

499

    SDnodeObj *pObj = NULL;

×

500

    pIter = sdbFetch(pSdb, SDB_DNODE, pIter, (void **)&pObj);

×

501

    if (pIter == NULL) break;

×

503

    SJson *item = tjsonCreateObject();

×

504

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

505

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "id", i642str(pObj->id)), pObj, &lino, _OVER);

×

506

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

507

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

508

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "port", i642str(pObj->port)), pObj, &lino, _OVER);

×

509

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "fqdn", pObj->fqdn), pObj, &lino, _OVER);

×

510

    sdbRelease(pSdb, pObj);

×

512

_OVER:

×

513

  if (code != 0) mError("failed to dump dnode info at line:%d since %s", lino, tstrerror(code));

×

514

×

516

void dumpSnode(SSdb *pSdb, SJson *json) {

×

517

  int32_t code = 0;

×

518

  int32_t lino = 0;

×

519

  void  *pIter = NULL;

×

520

  SJson *items = tjsonAddArrayToObject(json, "snodes");

×

522

  while (1) {

×

523

    SSnodeObj *pObj = NULL;

×

524

    pIter = sdbFetch(pSdb, SDB_QNODE, pIter, (void **)&pObj);

×

525

    if (pIter == NULL) break;

×

527

    SJson *item = tjsonCreateObject();

×

528

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

529

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "id", i642str(pObj->id)), pObj, &lino, _OVER);

×

530

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

531

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

532

    sdbRelease(pSdb, pObj);

×

534

_OVER:

×

535

  if (code != 0) mError("failed to dump snode info at line:%d since %s", lino, tstrerror(code));

×

536

×

538

void dumpQnode(SSdb *pSdb, SJson *json) {

×

539

  int32_t code = 0;

×

540

  int32_t lino = 0;

×

541

  void  *pIter = NULL;

×

542

  SJson *items = tjsonAddArrayToObject(json, "qnodes");

×

544

  while (1) {

×

545

    SQnodeObj *pObj = NULL;

×

546

    pIter = sdbFetch(pSdb, SDB_QNODE, pIter, (void **)&pObj);

×

547

    if (pIter == NULL) break;

×

549

    SJson *item = tjsonCreateObject();

×

550

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

551

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "id", i642str(pObj->id)), pObj, &lino, _OVER);

×

552

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

553

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

554

    sdbRelease(pSdb, pObj);

×

556

_OVER:

×

557

  if (code != 0) mError("failed to dump qnode info at line:%d since %s", lino, tstrerror(code));

×

558

×

560

void dumpMnode(SSdb *pSdb, SJson *json) {

×

561

  int32_t code = 0;

×

562

  int32_t lino = 0;

×

563

  void  *pIter = NULL;

×

564

  SJson *items = tjsonAddArrayToObject(json, "mnodes");

×

566

  while (1) {

×

567

    SMnodeObj *pObj = NULL;

×

568

    pIter = sdbFetch(pSdb, SDB_MNODE, pIter, (void **)&pObj);

×

569

    if (pIter == NULL) break;

×

571

    SJson *item = tjsonCreateObject();

×

572

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

573

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "id", i642str(pObj->id)), pObj, &lino, _OVER);

×

574

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

575

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

576

    sdbRelease(pSdb, pObj);

×

578

_OVER:

×

579

  if (code != 0) mError("failed to dump mnode info at line:%d since %s", lino, tstrerror(code));

×

580

×

582

void dumpCluster(SSdb *pSdb, SJson *json) {

×

583

  int32_t code = 0;

×

584

  int32_t lino = 0;

×

586

  void  *pIter = NULL;

×

587

  SJson *items = tjsonAddArrayToObject(json, "clusters");

×

589

  while (1) {

×

590

    SClusterObj *pObj = NULL;

×

591

    pIter = sdbFetch(pSdb, SDB_CLUSTER, pIter, (void **)&pObj);

×

592

    if (pIter == NULL) break;

×

594

    SJson *item = tjsonCreateObject();

×

595

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

596

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "id", i642str(pObj->id)), pObj, &lino, _OVER);

×

597

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

598

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "updateTime", i642str(pObj->updateTime)), pObj, &lino, _OVER);

×

599

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "name", pObj->name), pObj, &lino, _OVER);

×

600

    sdbRelease(pSdb, pObj);

×

603

_OVER:

×

604

  if (code != 0) mError("failed to dump cluster info at line:%d since %s", lino, tstrerror(code));

×

605

×

607

void dumpTrans(SSdb *pSdb, SJson *json) {

×

608

  int32_t code = 0;

×

609

  int32_t lino = 0;

×

610

  void  *pIter = NULL;

×

611

  SJson *items = tjsonAddArrayToObject(json, "transactions");

×

613

  while (1) {

×

614

    STrans *pObj = NULL;

×

615

    pIter = sdbFetch(pSdb, SDB_TRANS, pIter, (void **)&pObj);

×

616

    if (pIter == NULL) break;

×

618

    SJson *item = tjsonCreateObject();

×

619

    RETRIEVE_CHECK_GOTO(tjsonAddItemToArray(items, item), pObj, &lino, _OVER);

×

620

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "id", i642str(pObj->id)), pObj, &lino, _OVER);

×

621

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stage", i642str(pObj->stage)), pObj, &lino, _OVER);

×

622

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "policy", i642str(pObj->policy)), pObj, &lino, _OVER);

×

623

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "conflict", i642str(pObj->conflict)), pObj, &lino, _OVER);

×

624

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "exec", i642str(pObj->exec)), pObj, &lino, _OVER);

×

625

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "oper", i642str(pObj->oper)), pObj, &lino, _OVER);

×

626

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "createdTime", i642str(pObj->createdTime)), pObj, &lino, _OVER);

×

627

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "dbname", pObj->dbname), pObj, &lino, _OVER);

×

628

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "stbname", pObj->stbname), pObj, &lino, _OVER);

×

629

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "opername", pObj->opername), pObj, &lino, _OVER);

×

630

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "commitLogNum", i642str(taosArrayGetSize(pObj->commitActions))),

×

632

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "redoActionNum", i642str(taosArrayGetSize(pObj->redoActions))),

×

634

    RETRIEVE_CHECK_GOTO(tjsonAddStringToObject(item, "undoActionNum", i642str(taosArrayGetSize(pObj->undoActions))),

×

636

    sdbRelease(pSdb, pObj);

×

639

_OVER:

×

640

  if (code != 0) mError("failed to dump trans info at line:%d since %s", lino, tstrerror(code));

×

641

×

643

void dumpHeader(SSdb *pSdb, SJson *json) {

×

644

  int32_t code = 0;

×

645

  int32_t lino = 0;

×

646

  TAOS_CHECK_GOTO(tjsonAddStringToObject(json, "sver", i642str(1)), &lino, _OVER);

×

647

  TAOS_CHECK_GOTO(tjsonAddStringToObject(json, "applyIndex", i642str(pSdb->applyIndex)), &lino, _OVER);

×

648

  TAOS_CHECK_GOTO(tjsonAddStringToObject(json, "applyTerm", i642str(pSdb->applyTerm)), &lino, _OVER);

×

649

  TAOS_CHECK_GOTO(tjsonAddStringToObject(json, "applyConfig", i642str(pSdb->applyConfig)), &lino, _OVER);

×

651

  SJson *maxIdsJson = tjsonCreateObject();

×

652

  TAOS_CHECK_GOTO(tjsonAddItemToObject(json, "maxIds", maxIdsJson), &lino, _OVER);

×

653

  for (int32_t i = 0; i < SDB_MAX; ++i) {

×

654

    if(i == 5) continue;

×

655

    int64_t maxId = 0;

×

656

    if (i < SDB_MAX) {

×

657

      maxId = pSdb->maxId[i];

×

659

    TAOS_CHECK_GOTO(tjsonAddStringToObject(maxIdsJson, sdbTableName(i), i642str(maxId)), &lino, _OVER);

×

662

  SJson *tableVersJson = tjsonCreateObject();

×

663

  TAOS_CHECK_GOTO(tjsonAddItemToObject(json, "tableVers", tableVersJson), &lino, _OVER);

×

664

  for (int32_t i = 0; i < SDB_MAX; ++i) {

×

665

    int64_t tableVer = 0;

×

666

    if (i < SDB_MAX) {

×

667

      tableVer = pSdb->tableVer[i];

×

669

    TAOS_CHECK_GOTO(tjsonAddStringToObject(tableVersJson, sdbTableName(i), i642str(tableVer)), &lino, _OVER);

×

672

_OVER:

×

673

  if (code != 0) mError("failed to dump sdb info at line:%d since %s", lino, tstrerror(code));

×

674

×

676

int32_t mndDumpSdb() {

×

677

  mInfo("start to dump sdb info to sdb.json");

×

679

  char path[PATH_MAX * 2] = {0};

×

680

  (void)snprintf(path, sizeof(path), "%s%smnode", tsDataDir, TD_DIRSEP);

×

682

  SMsgCb msgCb = {0};

×

683

  msgCb.reportStartupFp = reportStartup;

×

684

  msgCb.sendReqFp = sendReq;

×

685

  msgCb.sendSyncReqFp = sendSyncReq;

×

686

  msgCb.sendRspFp = sendRsp;

×

687

  msgCb.mgmt = (SMgmtWrapper *)(&msgCb);  // hack

×

688

  tmsgSetDefault(&msgCb);

×

690

  TAOS_CHECK_RETURN(walInit(NULL));

×

691

  TAOS_CHECK_RETURN(syncInit());

×

693

  SMnodeOpt opt = {.msgCb = msgCb};

×

694

  SMnode   *pMnode = mndOpen(path, &opt);

×

695

  if (pMnode == NULL) return -1;

×

697

  SSdb  *pSdb = pMnode->pSdb;

×

698

  SJson *json = tjsonCreateObject();

×

699

  dumpHeader(pSdb, json);

×

700

  dumpFunc(pSdb, json);

×

701

  dumpDb(pSdb, json);

×

702

  dumpStb(pSdb, json);

×

703

  dumpSma(pSdb, json);

×

704

  dumpVgroup(pSdb, json);

×

705

  dumpTopic(pSdb, json);

×

706

  dumpConsumer(pSdb, json);

×

707

  dumpSubscribe(pSdb, json);

×

709

  dumpStream(pSdb, json);

×

710

  dumpAcct(pSdb, json);

×

711

  dumpAuth(pSdb, json);

×

712

  dumpUser(pSdb, json);

×

713

  dumpDnode(pSdb, json);

×

714

  dumpSnode(pSdb, json);

×

715

  dumpQnode(pSdb, json);

×

716

  dumpMnode(pSdb, json);

×

717

  dumpCluster(pSdb, json);

×

718

  dumpTrans(pSdb, json);

×

720

  char     *pCont = tjsonToString(json);

×

721

  int32_t   contLen = strlen(pCont);

×

722

  char      file[] = "sdb.json";

×

723

  TdFilePtr pFile = taosOpenFile(file, TD_FILE_CREATE | TD_FILE_WRITE | TD_FILE_TRUNC | TD_FILE_WRITE_THROUGH);

×

724

  if (pFile == NULL) {

×

725

    mError("failed to write %s since %s", file, terrstr());

×

726

    return terrno;

×

728

  TAOS_CHECK_RETURN(taosWriteFile(pFile, pCont, contLen));

×

729

  TAOS_CHECK_RETURN(taosWriteFile(pFile, "\n", 1));

×

730

  TAOS_CHECK_RETURN(taosFsyncFile(pFile));

×

731

  TAOS_CHECK_RETURN(taosCloseFile(&pFile));

×

732

  tjsonDelete(json);

×

733

  taosMemoryFree(pCont);

×

735

  mInfo("dump sdb info success");

×

736

  return 0;

×

739

int32_t mndDeleteTrans() {

×

740

  mInfo("start to dump sdb info to sdb.json");

×

742

  char path[PATH_MAX * 2] = {0};

×

743

  (void)snprintf(path, sizeof(path), "%s%smnode", tsDataDir, TD_DIRSEP);

×

745

  SMsgCb msgCb = {0};

×

746

  msgCb.reportStartupFp = reportStartup;

×

747

  msgCb.sendReqFp = sendReq;

×

748

  msgCb.sendSyncReqFp = sendSyncReq;

×

749

  msgCb.sendRspFp = sendRsp;

×

750

  msgCb.mgmt = (SMgmtWrapper *)(&msgCb);  // hack

×

751

  tmsgSetDefault(&msgCb);

×

753

  TAOS_CHECK_RETURN(walInit(NULL));

×

754

  TAOS_CHECK_RETURN(syncInit());

×

756

  SMnodeOpt opt = {.msgCb = msgCb};

×

757

  SMnode   *pMnode = mndOpen(path, &opt);

×

758

  if (pMnode == NULL) return terrno;

×

760

  TAOS_CHECK_RETURN(sdbWriteFileForDump(pMnode->pSdb));

×

762

  mInfo("dump sdb info success");

×

764

  return 0;

×

taosdata / TDengine / #3780

Source File
Press 'n' to go to next uncovered line, 'b' for previous

taosdata / TDengine / #3780

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous