shm

source/dnode/mgmt/bnode/src/bmMgmt.c

@@ -15,7 +15,6 @@
 
 #define _DEFAULT_SOURCE
 // #include "dndBnode.h"
-// #include "dmInt.h"
 // #include "dndTransport.h"
 // #include "dndWorker.h"
 

source/dnode/mgmt/container/src/dndMonitor.c

@@ -16,7 +16,7 @@
 #define _DEFAULT_SOURCE
 #include "dndInt.h"
 
-#include "dmInt.h"
+#include "dm.h"
 #include "mm.h"
 #include "vmInt.h"
 

source/dnode/mgmt/container/src/dndNode.c

@@ -17,7 +17,7 @@
 #include "dndInt.h"
 
 #include "bmInt.h"
-#include "dmInt.h"
+#include "dm.h"
 #include "mm.h"
 #include "qmInt.h"
 #include "smInt.h"
@@ -209,7 +209,7 @@ static int32_t dndRunInSingleProcess(SDnode *pDnode) {
   }
 
   SMgmtWrapper *pWrapper = dndGetWrapper(pDnode, DNODE);
-  if (dmStartWorker(pWrapper->pMgmt) != 0) {
+  if (dmStart(pWrapper) != 0) {
     dError("failed to start dnode worker since %s", terrstr());
     return -1;
   }
@@ -351,7 +351,7 @@ static int32_t dndRunInMultiProcess(SDnode *pDnode) {
   }
 
   SMgmtWrapper *pWrapper = dndGetWrapper(pDnode, DNODE);
-  if (pWrapper->procType == PROC_PARENT && dmStartWorker(pWrapper->pMgmt) != 0) {
+  if (pWrapper->procType == PROC_PARENT && dmStart(pWrapper->pMgmt) != 0) {
     dError("failed to start dnode worker since %s", terrstr());
     return -1;
   }

source/dnode/mgmt/container/src/dndTransport.c

@@ -16,7 +16,7 @@
 #define _DEFAULT_SOURCE
 #include "dndInt.h"
 
-#include "dmInt.h"
+#include "dm.h"
 #include "mm.h"
 
 #define INTERNAL_USER   "_dnd"

source/dnode/mgmt/mnode/src/mmInt.c

@@ -16,7 +16,7 @@
 #define _DEFAULT_SOURCE
 #include "mmInt.h"
 
-#include "dmInt.h"
+#include "dm.h"
 
 SMnode *mmAcquire(SMnodeMgmt *pMgmt) {
   SMnode *pMnode = NULL;

source/dnode/mgmt/mnode/src/mmMsg.c

@@ -15,7 +15,7 @@
 
 #define _DEFAULT_SOURCE
 #include "mmInt.h"
-#include "dmInt.h"
+#include "dm.h"
 
 int32_t mmProcessCreateReq(SMnodeMgmt *pMgmt, SNodeMsg *pMsg) {
   SDnode  *pDnode = pMgmt->pDnode;

source/dnode/mgmt/mnode/src/mmWorker.c

@@ -16,7 +16,7 @@
 #define _DEFAULT_SOURCE
 #include "mmInt.h"
 
-#include "dmInt.h"
+#include "dm.h"
 
 static void mmProcessQueue(SMnodeMgmt *pMgmt, SNodeMsg *pMsg) {
   dTrace("msg:%p, will be processed", pMsg);

source/dnode/mgmt/qnode/src/qmMgmt.c

@@ -15,7 +15,7 @@
 
 #define _DEFAULT_SOURCE
 // #include "dndQnode.h"
-// #include "dmInt.h"
+// #include "dm.h"
 // #include "dndTransport.h"
 // #include "dndWorker.h"
 

source/dnode/mgmt/snode/src/smMgmt.c

@@ -15,7 +15,7 @@
 
 #define _DEFAULT_SOURCE
 // #include "dndSnode.h"
-// #include "dmInt.h"
+// #include "dm.h"
 // #include "dndTransport.h"
 // #include "dndWorker.h"
 

source/dnode/mgmt/vnode/src/vmMsg.c

@@ -17,7 +17,7 @@
 #include "vmMsg.h"
 #include "vmFile.h"
 #include "vmWorker.h"
-#include "dmInt.h"
+#include "dm.h"
 
 static void vmGenerateVnodeCfg(SCreateVnodeReq *pCreate, SVnodeCfg *pCfg) {
   pCfg->vgId = pCreate->vgId;