Merge pull request #18777 from taosdata/fix/fixMemleakOnExit
fix: fix mem leak
This commit is contained in:
commit
960bcaa22f
|
@ -301,6 +301,7 @@ int32_t dmInitServer(SDnode *pDnode) {
|
||||||
rpcInit.connType = TAOS_CONN_SERVER;
|
rpcInit.connType = TAOS_CONN_SERVER;
|
||||||
rpcInit.idleTime = tsShellActivityTimer * 1000;
|
rpcInit.idleTime = tsShellActivityTimer * 1000;
|
||||||
rpcInit.parent = pDnode;
|
rpcInit.parent = pDnode;
|
||||||
|
rpcInit.compressSize = tsCompressMsgSize;
|
||||||
|
|
||||||
pTrans->serverRpc = rpcOpen(&rpcInit);
|
pTrans->serverRpc = rpcOpen(&rpcInit);
|
||||||
if (pTrans->serverRpc == NULL) {
|
if (pTrans->serverRpc == NULL) {
|
||||||
|
|
|
@ -1195,6 +1195,8 @@ void transCloseServer(void* arg) {
|
||||||
sendQuitToWorkThrd(srv->pThreadObj[i]);
|
sendQuitToWorkThrd(srv->pThreadObj[i]);
|
||||||
destroyWorkThrd(srv->pThreadObj[i]);
|
destroyWorkThrd(srv->pThreadObj[i]);
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
uv_loop_close(srv->loop);
|
||||||
}
|
}
|
||||||
|
|
||||||
taosMemoryFree(srv->pThreadObj);
|
taosMemoryFree(srv->pThreadObj);
|
||||||
|
|
Loading…
Reference in New Issue