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

UNCOV

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

×

UNCOV

43

char *i642str(int64_t val) {

×

UNCOV

45

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

×

UNCOV

46

  return str;

×

UNCOV

49

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

×

UNCOV

50

  int32_t code = 0;

×

UNCOV

51

  int32_t lino = 0;

×

UNCOV

52

  void   *pIter = NULL;

×

UNCOV

53

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

×

55

  while (1) {

×

UNCOV

56

    SFuncObj *pObj = NULL;

×

UNCOV

57

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

×

UNCOV

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

×

UNCOV

75

_OVER:

×

UNCOV

76

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

×

UNCOV

77

×

UNCOV

79

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

×

UNCOV

80

  int32_t code = 0;

×

UNCOV

81

  int32_t lino = 0;

×

UNCOV

82

  void  *pIter = NULL;

×

UNCOV

83

  SJson *items = tjsonCreateObject();

×

UNCOV

84

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

×

86

  while (1) {

×

UNCOV

87

    SDbObj *pObj = NULL;

×

UNCOV

88

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

×

UNCOV

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

×

UNCOV

165

_OVER:

×

UNCOV

166

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

×

UNCOV

167

×

UNCOV

169

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

×

UNCOV

170

  int32_t code = 0;

×

UNCOV

171

  int32_t lino = 0;

×

UNCOV

172

  void  *pIter = NULL;

×

UNCOV

173

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

×

175

  while (1) {

×

UNCOV

176

    SStbObj *pObj = NULL;

×

UNCOV

177

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

×

UNCOV

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

×

202

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

×

203

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

×

204

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

×

205

      SJson *column = tjsonCreateObject();

×

206

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

×

208

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

×

209

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

×

210

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

×

212

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

×

213

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

×

214

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

×

215

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

×

218

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

×

219

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

×

220

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

×

221

      SJson *tag = tjsonCreateObject();

×

222

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

×

224

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

×

225

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

×

226

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

×

227

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

×

228

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

×

229

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

×

230

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

×

233

    sdbRelease(pSdb, pObj);

×

UNCOV

235

_OVER:

×

UNCOV

236

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

×

UNCOV

237

×

UNCOV

239

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

×

UNCOV

240

  int32_t code = 0;

×

UNCOV

241

  int32_t lino = 0;

×

UNCOV

242

  void  *pIter = NULL;

×

UNCOV

243

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

×

245

  while (1) {

×

UNCOV

246

    SSmaObj *pObj = NULL;

×

UNCOV

247

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

×

UNCOV

248

    if (pIter == NULL) break;

×

250

    SJson *item = tjsonCreateObject();

×

251

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

×

252

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

×

253

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

×

254

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

×

255

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

×

256

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

×

257

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

×

258

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

×

259

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

×

260

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

×

261

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

×

262

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

×

263

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

×

264

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

×

265

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

×

266

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

×

267

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

×

268

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

×

269

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

×

271

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

×

272

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

×

273

    sdbRelease(pSdb, pObj);

×

UNCOV

275

_OVER:

×

UNCOV

276

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

×

UNCOV

277

×

UNCOV

279

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

×

UNCOV

280

  int32_t code = 0;

×

UNCOV

281

  int32_t lino = 0;

×

UNCOV

282

  void  *pIter = NULL;

×

UNCOV

283

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

×

285

  while (1) {

×

UNCOV

286

    SVgObj *pObj = NULL;

×

UNCOV

287

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

×

UNCOV

288

    if (pIter == NULL) break;

×

290

    SJson *item = tjsonCreateObject();

×

291

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

×

292

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

×

293

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

×

294

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

×

295

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

×

296

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

×

297

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

×

298

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

×

299

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

×

300

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

×

301

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

×

302

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

×

303

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

×

304

      SJson *replica = tjsonCreateObject();

×

305

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

×

306

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

×

309

    sdbRelease(pSdb, pObj);

×

UNCOV

311

_OVER:

×

UNCOV

312

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

×

UNCOV

313

×

UNCOV

315

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

×

UNCOV

316

  int32_t code = 0;

×

UNCOV

317

  int32_t lino = 0;

×

UNCOV

318

  void  *pIter = NULL;

×

UNCOV

319

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

×

321

  while (1) {

×

UNCOV

322

    SMqTopicObj *pObj = NULL;

×

UNCOV

323

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

×

UNCOV

324

    if (pIter == NULL) break;

×

326

    SJson *item = tjsonCreateObject();

×

327

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

×

328

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

×

329

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

×

330

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

×

331

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

×

332

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

×

333

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

×

334

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

×

335

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

×

336

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

×

337

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

×

338

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

×

339

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

×

340

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

×

341

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

×

342

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

×

343

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

×

344

    sdbRelease(pSdb, pObj);

×

UNCOV

346

_OVER:

×

UNCOV

347

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

×

UNCOV

348

×

UNCOV

350

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

×

UNCOV

351

  int32_t code = 0;

×

UNCOV

352

  int32_t lino = 0;

×

UNCOV

353

  void  *pIter = NULL;

×

UNCOV

354

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

×

356

  while (1) {

×

UNCOV

357

    SMqConsumerObj *pObj = NULL;

×

UNCOV

358

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

×

UNCOV

359

    if (pIter == NULL) break;

×

361

    SJson *item = tjsonCreateObject();

×

362

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

×

363

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

×

364

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

×

365

    sdbRelease(pSdb, pObj);

×

UNCOV

367

_OVER:

×

UNCOV

368

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

×

UNCOV

369

×

UNCOV

371

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

×

UNCOV

372

  int32_t code = 0;

×

UNCOV

373

  int32_t lino = 0;

×

UNCOV

374

  void  *pIter = NULL;

×

UNCOV

375

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

×

377

  while (1) {

×

UNCOV

378

    SMqSubscribeObj *pObj = NULL;

×

UNCOV

379

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

×

UNCOV

380

    if (pIter == NULL) break;

×

382

    SJson *item = tjsonCreateObject();

×

383

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

×

384

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

×

385

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

×

386

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

×

387

    sdbRelease(pSdb, pObj);

×

UNCOV

389

_OVER:

×

UNCOV

390

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

×

UNCOV

391

×

UNCOV

393

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

×

UNCOV

394

  int32_t code = 0;

×

UNCOV

395

  int32_t lino = 0;

×

UNCOV

396

  void   *pIter = NULL;

×

UNCOV

397

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

×

399

  while (1) {

×

UNCOV

400

    SStreamObj *pObj = NULL;

×

UNCOV

401

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

×

UNCOV

402

    if (pIter == NULL) break;

×

404

    SJson *item = tjsonCreateObject();

×

405

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

×

406

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

×

407

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

×

408

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

×

409

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

×

410

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

×

411

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

×

412

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

×

413

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

×

414

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

×

415

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

×

416

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

×

418

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

×

419

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

×

420

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

×

421

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

×

422

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

×

423

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

×

425

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

×

426

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

×

428

    sdbRelease(pSdb, pObj);

×

UNCOV

430

_OVER:

×

UNCOV

431

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

×

UNCOV

432

×

UNCOV

434

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

×

UNCOV

435

  int32_t code = 0;

×

UNCOV

436

  int32_t lino = 0;

×

UNCOV

437

  void  *pIter = NULL;

×

UNCOV

438

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

×

UNCOV

440

  while (1) {

×

UNCOV

441

    SAcctObj *pObj = NULL;

×

UNCOV

442

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

×

UNCOV

443

    if (pIter == NULL) break;

×

UNCOV

445

    SJson *item = tjsonCreateObject();

×

UNCOV

446

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

×

UNCOV

447

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

×

UNCOV

448

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

×

UNCOV

449

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

×

UNCOV

450

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

×

UNCOV

451

    sdbRelease(pSdb, pObj);

×

UNCOV

453

_OVER:

×

UNCOV

454

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

×

UNCOV

455

×

UNCOV

457

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

×

UNCOV

459

×

UNCOV

461

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

×

UNCOV

462

  int32_t code = 0;

×

UNCOV

463

  int32_t lino = 0;

×

UNCOV

464

  void  *pIter = NULL;

×

UNCOV

465

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

×

UNCOV

467

  while (1) {

×

UNCOV

468

    SUserObj *pObj = NULL;

×

UNCOV

469

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

×

UNCOV

470

    if (pIter == NULL) break;

×

UNCOV

472

    SJson *item = tjsonCreateObject();

×

UNCOV

473

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

×

UNCOV

474

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

×

UNCOV

475

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

×

UNCOV

476

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

×

UNCOV

477

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

×

UNCOV

478

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

×

UNCOV

479

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

×

UNCOV

480

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

×

UNCOV

481

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

×

UNCOV

483

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

×

UNCOV

485

    sdbRelease(pSdb, pObj);

×

UNCOV

487

_OVER:

×

UNCOV

488

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

×

UNCOV

489

×

UNCOV

491

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

×

UNCOV

492

  int32_t code = 0;

×

UNCOV

493

  int32_t lino = 0;

×

UNCOV

494

  void  *pIter = NULL;

×

UNCOV

495

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

×

UNCOV

497

  while (1) {

×

UNCOV

498

    SDnodeObj *pObj = NULL;

×

UNCOV

499

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

×

UNCOV

500

    if (pIter == NULL) break;

×

UNCOV

502

    SJson *item = tjsonCreateObject();

×

UNCOV

503

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

×

UNCOV

504

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

×

UNCOV

505

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

×

UNCOV

506

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

×

UNCOV

507

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

×

UNCOV

508

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

×

UNCOV

509

    sdbRelease(pSdb, pObj);

×

UNCOV

511

_OVER:

×

UNCOV

512

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

×

UNCOV

513

×

UNCOV

515

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

×

UNCOV

516

  int32_t code = 0;

×

UNCOV

517

  int32_t lino = 0;

×

UNCOV

518

  void  *pIter = NULL;

×

UNCOV

519

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

×

521

  while (1) {

×

UNCOV

522

    SSnodeObj *pObj = NULL;

×

UNCOV

523

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

×

UNCOV

524

    if (pIter == NULL) break;

×

526

    SJson *item = tjsonCreateObject();

×

527

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

×

528

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

×

529

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

×

530

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

×

531

    sdbRelease(pSdb, pObj);

×

UNCOV

533

_OVER:

×

UNCOV

534

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

×

UNCOV

535

×

UNCOV

537

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

×

UNCOV

538

  int32_t code = 0;

×

UNCOV

539

  int32_t lino = 0;

×

UNCOV

540

  void  *pIter = NULL;

×

UNCOV

541

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

×

543

  while (1) {

×

UNCOV

544

    SQnodeObj *pObj = NULL;

×

UNCOV

545

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

×

UNCOV

546

    if (pIter == NULL) break;

×

548

    SJson *item = tjsonCreateObject();

×

549

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

×

550

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

×

551

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

×

552

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

×

553

    sdbRelease(pSdb, pObj);

×

UNCOV

555

_OVER:

×

UNCOV

556

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

×

UNCOV

557

×

UNCOV

559

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

×

UNCOV

560

  int32_t code = 0;

×

UNCOV

561

  int32_t lino = 0;

×

UNCOV

562

  void  *pIter = NULL;

×

UNCOV

563

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

×

UNCOV

565

  while (1) {

×

UNCOV

566

    SMnodeObj *pObj = NULL;

×

UNCOV

567

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

×

UNCOV

568

    if (pIter == NULL) break;

×

UNCOV

570

    SJson *item = tjsonCreateObject();

×

UNCOV

571

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

×

UNCOV

572

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

×

UNCOV

573

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

×

UNCOV

574

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

×

UNCOV

575

    sdbRelease(pSdb, pObj);

×

UNCOV

577

_OVER:

×

UNCOV

578

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

×

UNCOV

579

×

UNCOV

581

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

×

UNCOV

582

  int32_t code = 0;

×

UNCOV

583

  int32_t lino = 0;

×

UNCOV

585

  void  *pIter = NULL;

×

UNCOV

586

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

×

UNCOV

588

  while (1) {

×

UNCOV

589

    SClusterObj *pObj = NULL;

×

UNCOV

590

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

×

UNCOV

591

    if (pIter == NULL) break;

×

UNCOV

593

    SJson *item = tjsonCreateObject();

×

UNCOV

594

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

×

UNCOV

595

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

×

UNCOV

596

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

×

UNCOV

597

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

×

UNCOV

598

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

×

UNCOV

599

    sdbRelease(pSdb, pObj);

×

UNCOV

602

_OVER:

×

UNCOV

603

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

×

UNCOV

604

×

UNCOV

606

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

×

UNCOV

607

  int32_t code = 0;

×

UNCOV

608

  int32_t lino = 0;

×

UNCOV

609

  void  *pIter = NULL;

×

UNCOV

610

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

×

612

  while (1) {

×

UNCOV

613

    STrans *pObj = NULL;

×

UNCOV

614

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

×

UNCOV

615

    if (pIter == NULL) break;

×

617

    SJson *item = tjsonCreateObject();

×

618

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

×

619

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

×

620

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

×

621

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

×

622

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

×

623

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

×

624

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

×

625

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

×

626

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

×

627

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

×

628

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

×

629

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

×

631

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

×

633

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

×

635

    sdbRelease(pSdb, pObj);

×

UNCOV

638

_OVER:

×

UNCOV

639

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

×

UNCOV

640

×

UNCOV

642

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

×

UNCOV

643

  int32_t code = 0;

×

UNCOV

644

  int32_t lino = 0;

×

UNCOV

645

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

×

UNCOV

646

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

×

UNCOV

647

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

×

UNCOV

648

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

×

UNCOV

650

  SJson *maxIdsJson = tjsonCreateObject();

×

UNCOV

651

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

×

UNCOV

652

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

×

UNCOV

653

    if(i == 5) continue;

×

UNCOV

654

    int64_t maxId = 0;

×

UNCOV

655

    if (i < SDB_MAX) {

×

UNCOV

656

      maxId = pSdb->maxId[i];

×

UNCOV

658

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

×

UNCOV

661

  SJson *tableVersJson = tjsonCreateObject();

×

UNCOV

662

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

×

UNCOV

663

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

×

UNCOV

664

    int64_t tableVer = 0;

×

UNCOV

665

    if (i < SDB_MAX) {

×

UNCOV

666

      tableVer = pSdb->tableVer[i];

×

UNCOV

668

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

×

UNCOV

671

_OVER:

×

UNCOV

672

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

×

UNCOV

673

×

UNCOV

675

int32_t mndDumpSdb() {

×

UNCOV

676

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

×

UNCOV

678

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

×

UNCOV

679

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

×

UNCOV

681

  SMsgCb msgCb = {0};

×

UNCOV

682

  msgCb.reportStartupFp = reportStartup;

×

UNCOV

683

  msgCb.sendReqFp = sendReq;

×

UNCOV

684

  msgCb.sendSyncReqFp = sendSyncReq;

×

UNCOV

685

  msgCb.sendRspFp = sendRsp;

×

UNCOV

686

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

×

UNCOV

687

  tmsgSetDefault(&msgCb);

×

UNCOV

689

  TAOS_CHECK_RETURN(walInit(NULL));

×

UNCOV

690

  TAOS_CHECK_RETURN(syncInit());

×

UNCOV

692

  SMnodeOpt opt = {.msgCb = msgCb};

×

UNCOV

693

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

×

UNCOV

694

  if (pMnode == NULL) return -1;

×

UNCOV

696

  SSdb  *pSdb = pMnode->pSdb;

×

UNCOV

697

  SJson *json = tjsonCreateObject();

×

UNCOV

698

  dumpHeader(pSdb, json);

×

UNCOV

699

  dumpFunc(pSdb, json);

×

UNCOV

700

  dumpDb(pSdb, json);

×

UNCOV

701

  dumpStb(pSdb, json);

×

UNCOV

702

  dumpSma(pSdb, json);

×

UNCOV

703

  dumpVgroup(pSdb, json);

×

UNCOV

704

  dumpTopic(pSdb, json);

×

UNCOV

705

  dumpConsumer(pSdb, json);

×

UNCOV

706

  dumpSubscribe(pSdb, json);

×

UNCOV

708

  dumpStream(pSdb, json);

×

UNCOV

709

  dumpAcct(pSdb, json);

×

UNCOV

710

  dumpAuth(pSdb, json);

×

UNCOV

711

  dumpUser(pSdb, json);

×

UNCOV

712

  dumpDnode(pSdb, json);

×

UNCOV

713

  dumpSnode(pSdb, json);

×

UNCOV

714

  dumpQnode(pSdb, json);

×

UNCOV

715

  dumpMnode(pSdb, json);

×

UNCOV

716

  dumpCluster(pSdb, json);

×

UNCOV

717

  dumpTrans(pSdb, json);

×

UNCOV

719

  char     *pCont = tjsonToString(json);

×

UNCOV

720

  int32_t   contLen = strlen(pCont);

×

UNCOV

721

  char      file[] = "sdb.json";

×

UNCOV

722

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

×

UNCOV

723

  if (pFile == NULL) {

×

724

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

×

725

    return terrno;

×

UNCOV

727

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

×

728

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

×

729

  TAOS_CHECK_RETURN(taosFsyncFile(pFile));

×

730

  TAOS_CHECK_RETURN(taosCloseFile(&pFile));

×

731

  tjsonDelete(json);

×

732

  taosMemoryFree(pCont);

×

734

  mInfo("dump sdb info success");

×

735

  return 0;

×

738

int32_t mndDeleteTrans() {

×

739

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

×

741

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

×

742

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

×

744

  SMsgCb msgCb = {0};

×

745

  msgCb.reportStartupFp = reportStartup;

×

746

  msgCb.sendReqFp = sendReq;

×

747

  msgCb.sendSyncReqFp = sendSyncReq;

×

748

  msgCb.sendRspFp = sendRsp;

×

749

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

×

750

  tmsgSetDefault(&msgCb);

×

752

  TAOS_CHECK_RETURN(walInit(NULL));

×

753

  TAOS_CHECK_RETURN(syncInit());

×

755

  SMnodeOpt opt = {.msgCb = msgCb};

×

756

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

×

757

  if (pMnode == NULL) return terrno;

×

759

  TAOS_CHECK_RETURN(sdbWriteFileForDump(pMnode->pSdb));

×

761

  mInfo("dump sdb info success");

×

763

  return 0;

×

taosdata / TDengine / #3562

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

taosdata / TDengine / #3562

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