memory leak in sdb

f42be834 · Shengliang Guan · 8017f458 · f42be834 · f42be834
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

src/dnode/src/dnodeMPeer.c src/dnode/src/dnodeMPeer.c +1 -1

src/dnode/src/dnodeMWrite.c src/dnode/src/dnodeMWrite.c +1 -1

未找到文件。
--- a/src/dnode/src/dnodeMPeer.c
+++ b/src/dnode/src/dnodeMPeer.c
@@ -71,10 +71,10 @@ void dnodeCleanupMnodePeer() {
    SMPeerWorker *pWorker = tsMPeerPool.peerWorker + i;
    if (pWorker->thread) {
      pthread_join(pWorker->thread, NULL);
-      taosCloseQset(tsMPeerQset);
    }
  }

+  taosCloseQset(tsMPeerQset);
  tfree(tsMPeerPool.peerWorker);
  dPrint("dnode mpeer is closed");
 }

--- a/src/dnode/src/dnodeMWrite.c
+++ b/src/dnode/src/dnodeMWrite.c
@@ -73,10 +73,10 @@ void dnodeCleanupMnodeWrite() {
    SMWriteWorker *pWorker = tsMWritePool.writeWorker + i;
    if (pWorker->thread) {
      pthread_join(pWorker->thread, NULL);
-      taosCloseQset(tsMWriteQset);
    }
  }

+  taosCloseQset(tsMWriteQset);
  tfree(tsMWritePool.writeWorker);
  dPrint("dnode mwrite is closed");
 }