diff --git a/src/client/src/tscAsync.c b/src/client/src/tscAsync.c index 57e05dbcf490468a0222ff65a42d752ad6e5ec45..72e8a4121ab72895e4c473378398a5059bdf8b5c 100644 --- a/src/client/src/tscAsync.c +++ b/src/client/src/tscAsync.c @@ -478,9 +478,9 @@ void tscTableMetaCallBack(void *param, TAOS_RES *res, int code) { } else if (pCmd->command == TSDB_SQL_SELECT) { // in case of other query type, continue tscProcessSql(pSql); } else if (pCmd->command == TSDB_SQL_DELETE) { - // handle delete + tscProcessSql(pSql); } - }else { // in all other cases, simple retry + } else { // in all other cases, simple retry tscProcessSql(pSql); } diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 54f8b63328670cfe7a4407f44f0a0539f5f348cf..d24b98fe0830ef5c8d623ec4ac92a03b8ad9be10 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -363,7 +363,7 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) { } /* - * There is not response callback function for submit response. + * There is not response callback function for submit|delete response. * The actual inserted number of points is the first number. */ if (rpcMsg->msgType == TSDB_MSG_TYPE_SUBMIT_RSP && pRes->pRsp != NULL) { @@ -380,8 +380,8 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) { } else if (rpcMsg->msgType == TSDB_MSG_TYPE_DELETE_RSP && pRes->pRsp != NULL) { SShellSubmitRspMsg *pMsg = (SShellSubmitRspMsg*)pRes->pRsp; pMsg->code = htonl(pMsg->code); - pMsg->numOfRows = 10; //htonl(pMsg->numOfRows); - pMsg->affectedRows = 10; //htonl(pMsg->affectedRows); + pMsg->numOfRows = htonl(pMsg->numOfRows); + pMsg->affectedRows = htonl(pMsg->affectedRows); pMsg->failedRows = htonl(pMsg->failedRows); pMsg->numOfFailedBlocks = htonl(pMsg->numOfFailedBlocks); pRes->numOfRows += pMsg->affectedRows;