minor changes
This commit is contained in:
parent
4b5c05334f
commit
d882edd037
|
@ -139,7 +139,7 @@ static void dndConsumeChildQueue(SMgmtWrapper *pWrapper, SNodeMsg *pMsg, int32_t
|
||||||
static void dndConsumeParentQueue(SMgmtWrapper *pWrapper, SRpcMsg *pRsp, int32_t msgLen, void *pCont, int32_t contLen) {
|
static void dndConsumeParentQueue(SMgmtWrapper *pWrapper, SRpcMsg *pRsp, int32_t msgLen, void *pCont, int32_t contLen) {
|
||||||
dTrace("msg:%p, get from parent queue", pRsp);
|
dTrace("msg:%p, get from parent queue", pRsp);
|
||||||
pRsp->pCont = pCont;
|
pRsp->pCont = pCont;
|
||||||
dndSendRpcRsp(pWrapper, pRsp);
|
dndSendRsp(pWrapper, pRsp);
|
||||||
taosMemoryFree(pRsp);
|
taosMemoryFree(pRsp);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue