refactor: node mgmt

source/dnode/mgmt/mgmt_vnode/src/vmInt.c

@@ -272,8 +272,8 @@ static int32_t vmInit(const SMgmtInputOpt *pInput, SMgmtOutputOpt *pOutput) {
   tstrncpy(dCfg.dir, pInput->dataDir, TSDB_FILENAME_LEN);
   dCfg.level = 0;
   dCfg.primary = 1;
-  SDiskCfg *pDisks = tsDiskCfg;
-  int32_t   numOfDisks = tsDiskCfgNum;
+  SDiskCfg *pDisks = pInput->disks;
+  int32_t   numOfDisks = pInput->numOfDisks;
   if (numOfDisks <= 0 || pDisks == NULL) {
     pDisks = &dCfg;
     numOfDisks = 1;

source/dnode/mgmt/node_common/inc/dmInt.h

@@ -87,12 +87,14 @@ typedef struct {
   SMsgCb      msgCb;
   int32_t     dnodeId;
   int64_t     clusterId;
-  const char *dataDir;
   const char *localEp;
   const char *firstEp;
   const char *localFqdn;
   uint16_t    serverPort;
   int32_t     supportVnodes;
+  int32_t     numOfDisks;
+  SDiskCfg   *disks;
+  const char *dataDir;
 } SMgmtInputOpt;
 
 typedef struct {
@@ -133,7 +135,7 @@ const char *dmNodeLogName(EDndNodeType ntype);
 const char *dmNodeProcName(EDndNodeType ntype);
 const char *dmEventStr(EDndEvent etype);
 const char *dmProcStr(EDndProcType ptype);
-void       *dmSetMgmtHandle(SArray *pArray, tmsg_t msgType, NodeMsgFp nodeMsgFp, bool needCheckVgId);
+void       *dmSetMgmtHandle(SArray *pArray, tmsg_t msgType, void *nodeMsgFp, bool needCheckVgId);
 void        dmGetSystemInfo(SMonSysInfo *pInfo);
 
 // dmFile.c

source/dnode/mgmt/node_common/src/dmUtil.c

@@ -92,10 +92,10 @@ const char *dmProcStr(EDndProcType etype) {
   }
 }
 
-void *dmSetMgmtHandle(SArray *pArray, tmsg_t msgType, NodeMsgFp nodeMsgFp, bool needCheckVgId) {
+void *dmSetMgmtHandle(SArray *pArray, tmsg_t msgType, void *nodeMsgFp, bool needCheckVgId) {
   SMgmtHandle handle = {
       .msgType = msgType,
-      .msgFp = nodeMsgFp,
+      .msgFp = (NodeMsgFp)nodeMsgFp,
       .needCheckVgId = needCheckVgId,
   };