diff --git a/source/client/src/clientMsgHandler.c b/source/client/src/clientMsgHandler.c index 79d61423a76a0d1fc6b8223ec16603a7ba7ef658..448bf156f077ea3e02e09d8a3d5bb54006ef9777 100644 --- a/source/client/src/clientMsgHandler.c +++ b/source/client/src/clientMsgHandler.c @@ -31,6 +31,13 @@ int genericRspCallback(void* param, const SDataBuf* pMsg, int32_t code) { int processConnectRsp(void* param, const SDataBuf* pMsg, int32_t code) { SRequestObj* pRequest = param; + if (code != TSDB_CODE_SUCCESS) { + pRequest->code = code; + terrno = code; + + sem_post(&pRequest->body.rspSem); + return code; + } STscObj *pTscObj = pRequest->pTscObj;