minor changes
This commit is contained in:
parent
b77149240f
commit
4982b48f6f
|
@ -31,6 +31,13 @@ int genericRspCallback(void* param, const SDataBuf* pMsg, int32_t code) {
|
||||||
|
|
||||||
int processConnectRsp(void* param, const SDataBuf* pMsg, int32_t code) {
|
int processConnectRsp(void* param, const SDataBuf* pMsg, int32_t code) {
|
||||||
SRequestObj* pRequest = param;
|
SRequestObj* pRequest = param;
|
||||||
|
if (code != TSDB_CODE_SUCCESS) {
|
||||||
|
pRequest->code = code;
|
||||||
|
terrno = code;
|
||||||
|
|
||||||
|
sem_post(&pRequest->body.rspSem);
|
||||||
|
return code;
|
||||||
|
}
|
||||||
|
|
||||||
STscObj *pTscObj = pRequest->pTscObj;
|
STscObj *pTscObj = pRequest->pTscObj;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue