diff --git a/source/dnode/mgmt/mgmt_snode/src/smInt.c b/source/dnode/mgmt/mgmt_snode/src/smInt.c index 3757dcd72a24d30cadb413a428738c8fed1a45c1..26300a9fe3f22eda80354ab7188b32676f7a764c 100644 --- a/source/dnode/mgmt/mgmt_snode/src/smInt.c +++ b/source/dnode/mgmt/mgmt_snode/src/smInt.c @@ -15,6 +15,7 @@ #define _DEFAULT_SOURCE #include "smInt.h" +#include "libs/function/function.h" static int32_t smRequire(SMgmtWrapper *pWrapper, bool *required) { return dmReadFile(pWrapper, required); } @@ -29,6 +30,9 @@ static void smClose(SMgmtWrapper *pWrapper) { if (pMgmt == NULL) return; dInfo("snode-mgmt start to cleanup"); + + udfcClose(); + if (pMgmt->pSnode != NULL) { smStopWorker(pMgmt); sndClose(pMgmt->pSnode); @@ -68,6 +72,10 @@ int32_t smOpen(SMgmtWrapper *pWrapper) { } dmReportStartup(pWrapper->pDnode, "snode-worker", "initialized"); + if (udfcOpen() != 0) { + dError("failed to open udfc in snode"); + } + return 0; } diff --git a/source/dnode/mgmt/mgmt_vnode/src/vmInt.c b/source/dnode/mgmt/mgmt_vnode/src/vmInt.c index 17c7563885becbdba4a589664fe9467bea3c7b53..bd282c570788960c4d1767696b58df909a016f0b 100644 --- a/source/dnode/mgmt/mgmt_vnode/src/vmInt.c +++ b/source/dnode/mgmt/mgmt_vnode/src/vmInt.c @@ -337,7 +337,7 @@ static int32_t vmInit(SMgmtWrapper *pWrapper) { dmReportStartup(pDnode, "vnode-vnodes", "initialized"); if (udfcOpen() != 0) { - dError("failed to open udfc in dnode"); + dError("failed to open udfc in vnode"); } code = 0;