xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

handle mem leak failure

This commit is contained in:
yihaoDeng 2024-11-04 13:18:11 +08:00
parent 17077d1a32
commit 9221bfb51e
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/client/src/clientImpl.c
View File

@ -1770,7 +1770,7 @@ void updateTargetEpSet(SMsgSendInfo* pSendInfo, STscObj* pTscObj, SRpcMsg* pMsg,
} }
} }
int32_t doProcessMsFromServerImpl(SRpcMsg* pMsg, SEpSet* pEpSet) { int32_t doProcessMsgFromServerImpl(SRpcMsg* pMsg, SEpSet* pEpSet) {
SMsgSendInfo* pSendInfo = (SMsgSendInfo*)pMsg->info.ahandle; SMsgSendInfo* pSendInfo = (SMsgSendInfo*)pMsg->info.ahandle;
if (pMsg->info.ahandle == NULL) { if (pMsg->info.ahandle == NULL) {
tscError("doProcessMsgFromServer pMsg->info.ahandle == NULL"); tscError("doProcessMsgFromServer pMsg->info.ahandle == NULL");
@ -1843,7 +1843,7 @@ int32_t doProcessMsFromServerImpl(SRpcMsg* pMsg, SEpSet* pEpSet) {
} }
int32_t doProcessMsgFromServer(void* param) { int32_t doProcessMsgFromServer(void* param) {
AsyncArg* arg = (AsyncArg*)param; AsyncArg* arg = (AsyncArg*)param;
int32_t code = doProcessMsFromServerImpl(&arg->msg, arg->pEpset); int32_t code = doProcessMsgFromServerImpl(&arg->msg, arg->pEpset);
taosMemoryFree(arg); taosMemoryFree(arg);
return code; return code;
} }
@ -1881,7 +1881,6 @@ void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
code = terrno; code = terrno;
pMsg->code = code; pMsg->code = code;
goto _exit; goto _exit;
return;
} }
arg->msg = *pMsg; arg->msg = *pMsg;
@ -1897,7 +1896,7 @@ void processMsgFromServer(void* parent, SRpcMsg* pMsg, SEpSet* pEpSet) {
return; return;
_exit: _exit:
tscError("failed to sched msg to tsc since %s", tstrerror(code)); tscError("failed to sched msg to tsc since %s", tstrerror(code));
code = doProcessMsFromServerImpl(pMsg, tEpSet); code = doProcessMsgFromServerImpl(pMsg, tEpSet);
if (code != 0) { if (code != 0) {
tscError("failed to sched msg to tsc, tsc ready quit"); tscError("failed to sched msg to tsc, tsc ready quit");
} }