handle mem leak failure

This commit is contained in:
yihaoDeng 2024-11-04 13:21:15 +08:00
parent 9221bfb51e
commit 44958e3c76
1 changed files with 2 additions and 5 deletions

View File

@ -1886,12 +1886,9 @@ void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
arg->msg = *pMsg;
arg->pEpset = tEpSet;
if (0 != taosAsyncExec(doProcessMsgFromServer, arg, NULL)) {
tscError("failed to sched msg to tsc, tsc ready to quit");
rpcFreeCont(pMsg->pCont);
taosMemoryFree(arg->pEpset);
destroySendMsgInfo(pMsg->info.ahandle);
if ((code = taosAsyncExec(doProcessMsgFromServer, arg, NULL)) != 0) {
taosMemoryFree(arg);
goto _exit;
}
return;
_exit: