commit
943da9bb73
|
@ -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");
|
||||
}
|
||||
|
|
|
@ -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");
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue