free is not right

This commit is contained in:
Jeff Tao 2020-05-21 02:43:48 +00:00
parent 54f671c027
commit 70747ad1bb
1 changed files with 2 additions and 2 deletions

View File

@ -889,12 +889,12 @@ static void *rpcProcessMsgFromPeer(SRecvInfo *pRecv) {
rpcSendErrorMsgToPeer(pRecv, code);
tTrace("%s %p %p, %s is sent with error code:%x", pRpc->label, pConn, (void *)pHead->ahandle, taosMsg[pHead->msgType+1], code);
}
} else { // parsing OK
} else { // msg is passed to app only parsing is ok
rpcProcessIncomingMsg(pConn, pHead);
}
}
if (code) rpcFreeMsg(pRecv->msg);
if (code) tfree(pRecv->msg); // parsing failed, msg shall be freed
return pConn;
}