[td-11818]check error in rsp.

This commit is contained in:
Haojun Liao 2021-12-30 10:38:32 +08:00
parent 7ad701cc5e
commit 6a55262ba6
1 changed files with 7 additions and 0 deletions

View File

@ -269,7 +269,14 @@ int32_t processCreateTableRsp(void* param, const SDataBuf* pMsg, int32_t code) {
int32_t processDropDbRsp(void* param, const SDataBuf* pMsg, int32_t code) {
// todo: Remove cache in catalog cache.
SRequestObj* pRequest = param;
if (code != TSDB_CODE_SUCCESS) {
setErrno(pRequest, code);
tsem_post(&pRequest->body.rspSem);
return code;
}
tsem_post(&pRequest->body.rspSem);
return code;
}
void initMsgHandleFp() {