From b99ad70c7cbcbe12c26c1d889a4198c6d57d5523 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 29 Oct 2020 15:20:19 +0000 Subject: [PATCH] TD-1611 --- src/client/src/tscAsync.c | 4 ++-- src/client/src/tscServer.c | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/client/src/tscAsync.c b/src/client/src/tscAsync.c index 57e05dbcf4..72e8a4121a 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 54f8b63328..d24b98fe08 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; -- GitLab