diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index e15a5e618ad0dbd3aac1751fa543c50692443f6c..1384dcecff04b197dae5bd8209cd767c2fd0d7cf 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -198,6 +198,8 @@ int tscSendMsgToServer(SSqlObj *pSql) { }; pSql->SRpcReqContext = rpcSendRequest(pObj->pDnodeConn, &pSql->ipList, &rpcMsg); + assert(pSql->SRpcReqContext != NULL); + return TSDB_CODE_SUCCESS; } @@ -412,7 +414,6 @@ void tscKillSTableQuery(SSqlObj *pSql) { for (int i = 0; i < pSql->numOfSubs; ++i) { SSqlObj *pSub = pSql->pSubs[i]; - if (pSub == NULL) { continue; } diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c index 0be7db435d679eb3ce8452975c59f754fd2e5cbf..6d4337e03276bdb51b5c93031fc2e2c52246b9b5 100644 --- a/src/client/src/tscSql.c +++ b/src/client/src/tscSql.c @@ -607,7 +607,9 @@ int* taos_fetch_lengths(TAOS_RES *res) { char *taos_get_client_info() { return version; } void taos_stop_query(TAOS_RES *res) { - if (res == NULL) return; + if (res == NULL) { + return; + } SSqlObj *pSql = (SSqlObj *)res; SSqlCmd *pCmd = &pSql->cmd;