From 5ec450d01cac6888af809566c356ce7ab6a547ef Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Mon, 23 May 2022 18:15:31 +0800
Subject: [PATCH] fix: stop sync after queue is empty

---
 source/dnode/mnode/impl/src/mndSync.c | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndSync.c b/source/dnode/mnode/impl/src/mndSync.c
index 28b8382e7c..68f1d0cd8e 100644
--- a/source/dnode/mnode/impl/src/mndSync.c
+++ b/source/dnode/mnode/impl/src/mndSync.c
@@ -109,11 +109,15 @@ int32_t mndInitSync(SMnode *pMnode) {
     return -1;
   }
 
+  mDebug("mnode sync is opened, id:%" PRId64, pMgmt->sync);
   return 0;
 }
 
 void mndCleanupSync(SMnode *pMnode) {
   SSyncMgmt *pMgmt = &pMnode->syncMgmt;
+  syncStop(pMgmt->sync);
+  mDebug("sync:%" PRId64 " is stopped", pMgmt->sync);
+
   tsem_destroy(&pMgmt->syncSem);
   if (pMgmt->pWal != NULL) {
     walClose(pMgmt->pWal);
@@ -163,9 +167,10 @@ void mndSyncStart(SMnode *pMnode) {
   }
 
   pMnode->syncMgmt.restored = true;
+  mDebug("sync:%" PRId64 " is started", pMnode->syncMgmt.sync);
 }
 
-void mndSyncStop(SMnode *pMnode) { syncStop(pMnode->syncMgmt.sync); }
+void mndSyncStop(SMnode *pMnode) {}
 
 bool mndIsMaster(SMnode *pMnode) {
   SSyncMgmt *pMgmt = &pMnode->syncMgmt;