提交 5ec450d0 编写于 作者: S Shengliang Guan

fix: stop sync after queue is empty

上级 8bfbc0f3
...@@ -109,11 +109,15 @@ int32_t mndInitSync(SMnode *pMnode) { ...@@ -109,11 +109,15 @@ int32_t mndInitSync(SMnode *pMnode) {
return -1; return -1;
} }
mDebug("mnode sync is opened, id:%" PRId64, pMgmt->sync);
return 0; return 0;
} }
void mndCleanupSync(SMnode *pMnode) { void mndCleanupSync(SMnode *pMnode) {
SSyncMgmt *pMgmt = &pMnode->syncMgmt; SSyncMgmt *pMgmt = &pMnode->syncMgmt;
syncStop(pMgmt->sync);
mDebug("sync:%" PRId64 " is stopped", pMgmt->sync);
tsem_destroy(&pMgmt->syncSem); tsem_destroy(&pMgmt->syncSem);
if (pMgmt->pWal != NULL) { if (pMgmt->pWal != NULL) {
walClose(pMgmt->pWal); walClose(pMgmt->pWal);
...@@ -163,9 +167,10 @@ void mndSyncStart(SMnode *pMnode) { ...@@ -163,9 +167,10 @@ void mndSyncStart(SMnode *pMnode) {
} }
pMnode->syncMgmt.restored = true; 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) { bool mndIsMaster(SMnode *pMnode) {
SSyncMgmt *pMgmt = &pMnode->syncMgmt; SSyncMgmt *pMgmt = &pMnode->syncMgmt;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册