refactor: node mgmt
This commit is contained in:
parent
47970ff8a4
commit
7e207e16e3
|
@ -195,6 +195,8 @@ static int32_t dmRunDnode() {
|
||||||
int32_t code = dmRun(pDnode);
|
int32_t code = dmRun(pDnode);
|
||||||
dInfo("start shutting down the service");
|
dInfo("start shutting down the service");
|
||||||
|
|
||||||
|
global.pDnode = NULL;
|
||||||
|
dmClose(pDnode);
|
||||||
dmCleanup();
|
dmCleanup();
|
||||||
taosCloseLog();
|
taosCloseLog();
|
||||||
taosCleanupCfg();
|
taosCleanupCfg();
|
||||||
|
|
|
@ -337,7 +337,6 @@ int32_t dmRun(SDnode *pDnode) {
|
||||||
dmSetStatus(pDnode, DND_STAT_STOPPED);
|
dmSetStatus(pDnode, DND_STAT_STOPPED);
|
||||||
dmStopNodes(pDnode);
|
dmStopNodes(pDnode);
|
||||||
dmCloseNodes(pDnode);
|
dmCloseNodes(pDnode);
|
||||||
dmClose(pDnode);
|
|
||||||
return 0;
|
return 0;
|
||||||
} else {
|
} else {
|
||||||
dmWatchNodes(pDnode);
|
dmWatchNodes(pDnode);
|
||||||
|
|
Loading…
Reference in New Issue