fix mem leak
This commit is contained in:
parent
eafdaac3e5
commit
132500a102
|
@ -1629,6 +1629,7 @@ static void cliHandleFreeById(SCliMsg* pMsg, SCliThrd* pThrd) {
|
||||||
_exception:
|
_exception:
|
||||||
tDebug("already free conn %p by id %" PRId64"", conn, refId);
|
tDebug("already free conn %p by id %" PRId64"", conn, refId);
|
||||||
|
|
||||||
|
(void)transReleaseExHandle(transGetRefMgt(), refId);
|
||||||
(void)transReleaseExHandle(transGetRefMgt(), refId);
|
(void)transReleaseExHandle(transGetRefMgt(), refId);
|
||||||
(void)transRemoveExHandle(transGetRefMgt(), refId);
|
(void)transRemoveExHandle(transGetRefMgt(), refId);
|
||||||
destroyCmsg(pMsg);
|
destroyCmsg(pMsg);
|
||||||
|
@ -2228,6 +2229,7 @@ static FORCE_INLINE void destroyCmsgAndAhandle(void* param) {
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pMsg->msg.info.handle !=0) {
|
if (pMsg->msg.info.handle !=0) {
|
||||||
|
(void)transReleaseExHandle(transGetRefMgt(), (int64_t)pMsg->msg.info.handle);
|
||||||
(void)transRemoveExHandle(transGetRefMgt(), (int64_t)pMsg->msg.info.handle);
|
(void)transRemoveExHandle(transGetRefMgt(), (int64_t)pMsg->msg.info.handle);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue