fix: invalid write in multi-process mode
This commit is contained in:
parent
ca786a9251
commit
5d4a77dc80
|
@ -192,15 +192,15 @@ void dmCloseNode(SMgmtWrapper *pWrapper) {
|
||||||
|
|
||||||
dmStopNode(pWrapper);
|
dmStopNode(pWrapper);
|
||||||
|
|
||||||
taosWLockLatch(&pWrapper->latch);
|
|
||||||
(*pWrapper->fp.closeFp)(pWrapper);
|
|
||||||
taosWUnLockLatch(&pWrapper->latch);
|
|
||||||
|
|
||||||
if (pWrapper->procObj) {
|
if (pWrapper->procObj) {
|
||||||
taosProcCleanup(pWrapper->procObj);
|
taosProcCleanup(pWrapper->procObj);
|
||||||
pWrapper->procObj = NULL;
|
pWrapper->procObj = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
taosWLockLatch(&pWrapper->latch);
|
||||||
|
(*pWrapper->fp.closeFp)(pWrapper);
|
||||||
|
taosWUnLockLatch(&pWrapper->latch);
|
||||||
|
|
||||||
dInfo("node:%s, has been closed", pWrapper->name);
|
dInfo("node:%s, has been closed", pWrapper->name);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue