From 3710dbe2e024285b0b735248f019e7699a7162ed Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 7 Dec 2022 16:57:45 +0800 Subject: [PATCH 1/2] fix mem leak --- source/libs/transport/src/transSvr.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index 73c6dc4011..2b1f68d5f6 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -1195,6 +1195,8 @@ void transCloseServer(void* arg) { sendQuitToWorkThrd(srv->pThreadObj[i]); destroyWorkThrd(srv->pThreadObj[i]); } + } else { + uv_loop_close(srv->loop); } taosMemoryFree(srv->pThreadObj); From b3d1204e864f9c2e10e0422e66f8ae4fb2a7a6a8 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 7 Dec 2022 18:04:35 +0800 Subject: [PATCH 2/2] error config --- source/dnode/mgmt/node_mgmt/src/dmTransport.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/mgmt/node_mgmt/src/dmTransport.c b/source/dnode/mgmt/node_mgmt/src/dmTransport.c index 2383a09343..99f8bd002a 100644 --- a/source/dnode/mgmt/node_mgmt/src/dmTransport.c +++ b/source/dnode/mgmt/node_mgmt/src/dmTransport.c @@ -301,6 +301,7 @@ int32_t dmInitServer(SDnode *pDnode) { rpcInit.connType = TAOS_CONN_SERVER; rpcInit.idleTime = tsShellActivityTimer * 1000; rpcInit.parent = pDnode; + rpcInit.compressSize = tsCompressMsgSize; pTrans->serverRpc = rpcOpen(&rpcInit); if (pTrans->serverRpc == NULL) {