diff --git a/src/dnode/src/dnodeMain.c b/src/dnode/src/dnodeMain.c index f1cdf73f6bfd991643d881e7b4622bf2d891fbec..0bbb189b8038f796724c638d3ef75607b336014f 100644 --- a/src/dnode/src/dnodeMain.c +++ b/src/dnode/src/dnodeMain.c @@ -54,7 +54,7 @@ void moduleStop() {} void *tsDnodeTmr = NULL; static SRunStatus tsRunStatus = TSDB_RUN_STATUS_STOPPED; -static int32_t tsDnodeErrors; +static int32_t tsDnodeErrors = 0; static int32_t dnodeInitStorage(); static void dnodeCleanupStorage(); diff --git a/src/plugins/monitor/src/monMain.c b/src/plugins/monitor/src/monMain.c index 6ef20c94edf861c600c542b5de96dbed06680fb3..05b5652cdb2c628bbb2c0110d35c0c15f1c458d3 100644 --- a/src/plugins/monitor/src/monMain.c +++ b/src/plugins/monitor/src/monMain.c @@ -641,6 +641,10 @@ static int32_t monBuildMonIntervalSql(char *sql) { static int32_t monBuildDnodesTotalSql(char *sql) { int32_t totalDnodes = 0, totalDnodesAlive = 0; TAOS_RES *result = taos_query(tsMonitor.conn, "show dnodes"); + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show dnodes, reason:%s", tstrerror(code)); + } TAOS_ROW row; int32_t num_fields = taos_num_fields(result); @@ -666,6 +670,10 @@ static int32_t monBuildDnodesTotalSql(char *sql) { static int32_t monBuildMnodesTotalSql(char *sql) { int32_t totalMnodes = 0, totalMnodesAlive= 0; TAOS_RES *result = taos_query(tsMonitor.conn, "show mnodes"); + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show mnodes, reason:%s", tstrerror(code)); + } TAOS_ROW row; int32_t num_fields = taos_num_fields(result); @@ -696,6 +704,10 @@ static int32_t monGetVgroupsTotalStats(char *dbName, int32_t *totalVgroups, memset(subsql, 0, sizeof(subsql)); sprintf(subsql, "show %s.vgroups", dbName); TAOS_RES *result = taos_query(tsMonitor.conn, subsql); + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show %s.vgroups, reason:%s", dbName, tstrerror(code)); + } TAOS_ROW row; int32_t num_fields = taos_num_fields(result); @@ -720,6 +732,10 @@ static int32_t monGetVgroupsTotalStats(char *dbName, int32_t *totalVgroups, static int32_t monBuildVgroupsTotalSql(char *sql) { int32_t totalVgroups = 0, totalVgroupsAlive = 0; TAOS_RES *result = taos_query(tsMonitor.conn, "show databases"); + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show databases, reason:%s", tstrerror(code)); + } TAOS_ROW row; int32_t num_fields = taos_num_fields(result); @@ -745,6 +761,10 @@ static int32_t monGetVnodesTotalStats(char *ep, int32_t *totalVnodes, memset(subsql, 0, sizeof(subsql)); sprintf(subsql, "show vnodes \"%s\"", ep); TAOS_RES *result = taos_query(tsMonitor.conn, subsql); + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show vnodes \"%s\", reason:%s", ep, tstrerror(code)); + } TAOS_ROW row; int32_t num_fields = taos_num_fields(result); @@ -770,6 +790,10 @@ static int32_t monGetVnodesTotalStats(char *ep, int32_t *totalVnodes, static int32_t monBuildVnodesTotalSql(char *sql) { int32_t totalVnodes = 0, totalVnodesAlive = 0; TAOS_RES *result = taos_query(tsMonitor.conn, "show dnodes"); + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show dnodes, reason:%s", tstrerror(code)); + } TAOS_ROW row; int32_t num_fields = taos_num_fields(result); @@ -794,6 +818,11 @@ static int32_t monBuildConnsTotalSql(char *sql) { TAOS_RES *result = taos_query(tsMonitor.conn, "show connections"); TAOS_ROW row; + int32_t code = taos_errno(result); + if (code != TSDB_CODE_SUCCESS) { + monError("failed to execute cmd: show connections, reason:%s", tstrerror(code)); + } + while ((row = taos_fetch_row(result))) { totalConns++; }