fix indirect leak

This commit is contained in:
yihaoDeng 2024-09-06 16:14:19 +08:00
parent b6b0e266eb
commit 0973fb6eed
2 changed files with 3 additions and 3 deletions

View File

@ -2387,7 +2387,7 @@ _end:
} }
taosArrayDestroy(pThrd->timerList); taosArrayDestroy(pThrd->timerList);
destroyConnPool(pThrd); (void)destroyConnPool(pThrd);
transDQDestroy(pThrd->delayQueue, NULL); transDQDestroy(pThrd->delayQueue, NULL);
transDQDestroy(pThrd->timeoutQueue, NULL); transDQDestroy(pThrd->timeoutQueue, NULL);
transDQDestroy(pThrd->waitConnQueue, NULL); transDQDestroy(pThrd->waitConnQueue, NULL);
@ -2419,7 +2419,7 @@ static void destroyThrdObj(SCliThrd* pThrd) {
uv_timer_t* timer = taosArrayGetP(pThrd->timerList, i); uv_timer_t* timer = taosArrayGetP(pThrd->timerList, i);
taosMemoryFree(timer); taosMemoryFree(timer);
} }
uv_loop_close(pThrd->loop); (void)uv_loop_close(pThrd->loop);
taosArrayDestroy(pThrd->timerList); taosArrayDestroy(pThrd->timerList);
taosMemoryFree(pThrd->loop); taosMemoryFree(pThrd->loop);
taosHashCleanup(pThrd->fqdn2ipCache); taosHashCleanup(pThrd->fqdn2ipCache);

View File

@ -1615,7 +1615,7 @@ void destroyWorkThrdObj(SWorkThrd* pThrd) {
} }
transAsyncPoolDestroy(pThrd->asyncPool); transAsyncPoolDestroy(pThrd->asyncPool);
uvWhiteListDestroy(pThrd->pWhiteList); uvWhiteListDestroy(pThrd->pWhiteList);
uv_loop_close(pThrd->loop); (void)uv_loop_close(pThrd->loop);
taosMemoryFree(pThrd->loop); taosMemoryFree(pThrd->loop);
taosMemoryFree(pThrd); taosMemoryFree(pThrd);
} }