commit
1e14f7222f
|
@ -97,7 +97,7 @@ void dnodeCleanupModules() {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (tsModule[TSDB_MOD_MNODE].enable && tsModule[TSDB_MOD_MNODE].cleanUpFp) {
|
if (tsModule[TSDB_MOD_MNODE].cleanUpFp) {
|
||||||
(*tsModule[TSDB_MOD_MNODE].cleanUpFp)();
|
(*tsModule[TSDB_MOD_MNODE].cleanUpFp)();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -123,16 +123,18 @@ int32_t mnodeInitSystem() {
|
||||||
}
|
}
|
||||||
|
|
||||||
void mnodeCleanupSystem() {
|
void mnodeCleanupSystem() {
|
||||||
mInfo("starting to clean up mnode");
|
if (tsMgmtIsRunning) {
|
||||||
tsMgmtIsRunning = false;
|
mInfo("starting to clean up mnode");
|
||||||
|
tsMgmtIsRunning = false;
|
||||||
|
|
||||||
dnodeFreeMnodeWqueue();
|
dnodeFreeMnodeWqueue();
|
||||||
dnodeFreeMnodeRqueue();
|
dnodeFreeMnodeRqueue();
|
||||||
dnodeFreeMnodePqueue();
|
dnodeFreeMnodePqueue();
|
||||||
mnodeCleanupTimer();
|
mnodeCleanupTimer();
|
||||||
mnodeCleanupComponents(sizeof(tsMnodeComponents) / sizeof(tsMnodeComponents[0]) - 1);
|
mnodeCleanupComponents(sizeof(tsMnodeComponents) / sizeof(tsMnodeComponents[0]) - 1);
|
||||||
|
|
||||||
mInfo("mnode is cleaned up");
|
mInfo("mnode is cleaned up");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void mnodeStopSystem() {
|
void mnodeStopSystem() {
|
||||||
|
|
Loading…
Reference in New Issue