This commit is contained in:
Shengliang Guan 2021-01-08 16:38:01 +08:00
parent 7f57f0e1f8
commit b9056faded
2 changed files with 6 additions and 3 deletions

View File

@ -420,9 +420,6 @@ void vnodeCleanUp(SVnodeObj *pVnode) {
vnodeSetClosingStatus(pVnode);
// release local resources only after cutting off outside connections
qQueryMgmtNotifyClosed(pVnode->qMgmt);
// stop replication module
if (pVnode->sync > 0) {
int64_t sync = pVnode->sync;

View File

@ -75,6 +75,9 @@ bool vnodeSetClosingStatus(SVnodeObj* pVnode) {
}
}
// release local resources only after cutting off outside connections
qQueryMgmtNotifyClosed(pVnode->qMgmt);
return true;
}
@ -116,6 +119,9 @@ bool vnodeSetResetStatus(SVnodeObj* pVnode) {
}
}
// release local resources only after cutting off outside connections
qQueryMgmtNotifyClosed(pVnode->qMgmt);
return true;
}