提交 5e11ec05 编写于 作者: 陶建辉(Jeff)'s avatar 陶建辉(Jeff)

memory leaking for Qset

上级 b38a6ff3
......@@ -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");
}
......
......@@ -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");
}
......
......@@ -851,6 +851,7 @@ void sdbCleanupWriteWorker() {
}
sdbFreeWritequeue();
tfree(tsSdbPool.writeWorker);
mPrint("sdb write is closed");
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册