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 ab4174857a13f9aa4de629ba1d186e79bb6486fc..af439fcc03f1525b62d3f0fcc21109f5b2f959f0 100644 --- a/source/dnode/mgmt/mgmt_vnode/src/vmInt.c +++ b/source/dnode/mgmt/mgmt_vnode/src/vmInt.c @@ -324,7 +324,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;