Merge pull request #2446 from taosdata/hotfix/leak

memory leaking for Qset

src/dnode/src/dnodeMPeer.c

@@ -71,9 +71,11 @@ void dnodeCleanupMnodePeer() {
     SMPeerWorker *pWorker = tsMPeerPool.peerWorker + i;
     if (pWorker->thread) {
       pthread_join(pWorker->thread, NULL);
+      taosCloseQset(tsMPeerQset);
     }
   }
 
+  tfree(tsMPeerPool.peerWorker);
   dPrint("dnode mpeer is closed");
 }
 

src/dnode/src/dnodeMWrite.c

@@ -73,9 +73,11 @@ void dnodeCleanupMnodeWrite() {
     SMWriteWorker *pWorker = tsMWritePool.writeWorker + i;
     if (pWorker->thread) {
       pthread_join(pWorker->thread, NULL);
+      taosCloseQset(tsMWriteQset);
     }
   }
 
+  tfree(tsMWritePool.writeWorker);
   dPrint("dnode mwrite is closed");
 }
 
@@ -194,4 +196,4 @@ void dnodeDelayReprocessMnodeWriteMsg(void *pMsg) {
   SMnodeMsg *mnodeMsg = pMsg;
   void *unUsed = NULL;
   taosTmrReset(dnodeDoDelayReprocessMnodeWriteMsg, 300, mnodeMsg, tsDnodeTmr, &unUsed);
-}
\ No newline at end of file
+}

src/mnode/src/mnodeSdb.c

@@ -851,6 +851,7 @@ void sdbCleanupWriteWorker() {
   }
 
   sdbFreeWritequeue();
+  tfree(tsSdbPool.writeWorker);
 
   mPrint("sdb write is closed");
 }