From f42be83400f5f863fd4906994ace025f93e2361a Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Wed, 24 Jun 2020 22:52:02 +0800
Subject: [PATCH] memory leak in sdb

---
 src/dnode/src/dnodeMPeer.c  | 2 +-
 src/dnode/src/dnodeMWrite.c | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/dnode/src/dnodeMPeer.c b/src/dnode/src/dnodeMPeer.c
index 49ba654fec..c37b2bed79 100644
--- 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");
 }
diff --git a/src/dnode/src/dnodeMWrite.c b/src/dnode/src/dnodeMWrite.c
index 03b1e4ff5d..47645ea5ea 100644
--- 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");
 }