diff --git a/source/dnode/mnode/impl/src/mndDnode.c b/source/dnode/mnode/impl/src/mndDnode.c index 067faba558..68d4bc36c6 100644 --- a/source/dnode/mnode/impl/src/mndDnode.c +++ b/source/dnode/mnode/impl/src/mndDnode.c @@ -91,13 +91,18 @@ static void mnodeResetDnode(SDnodeObj *pDnode) { } static int32_t mndDnodeActionInsert(SSdb *pSdb, SDnodeObj *pDnode) { + mTrace("dnode:%d, perform insert action", pDnode->id); mnodeResetDnode(pDnode); return 0; } -static int32_t mndDnodeActionDelete(SSdb *pSdb, SDnodeObj *pDnode) { return 0; } +static int32_t mndDnodeActionDelete(SSdb *pSdb, SDnodeObj *pDnode) { + mTrace("dnode:%d, perform delete action", pDnode->id); + return 0; +} static int32_t mndDnodeActionUpdate(SSdb *pSdb, SDnodeObj *pSrcDnode, SDnodeObj *pDstDnode) { + mTrace("dnode:%d, perform update action", pSrcDnode->id); pSrcDnode->id = pDstDnode->id; pSrcDnode->createdTime = pDstDnode->createdTime; pSrcDnode->updateTime = pDstDnode->updateTime; @@ -118,6 +123,7 @@ static int32_t mndCreateDefaultDnode(SMnode *pMnode) { if (pRaw == NULL) return -1; sdbSetRawStatus(pRaw, SDB_STATUS_READY); + mTrace("dnode:%d, will be created while deploy sdb", dnodeObj.id); return sdbWrite(pMnode->pSdb, pRaw); } diff --git a/source/dnode/mnode/impl/src/mndMnode.c b/source/dnode/mnode/impl/src/mndMnode.c index bbf39dcff9..2863846e87 100644 --- a/source/dnode/mnode/impl/src/mndMnode.c +++ b/source/dnode/mnode/impl/src/mndMnode.c @@ -59,6 +59,7 @@ static void mnodeResetMnode(SMnodeObj *pMnodeObj) { } static int32_t mndMnodeActionInsert(SSdb *pSdb, SMnodeObj *pMnodeObj) { + mTrace("mnode:%d, perform insert action", pMnodeObj->id); pMnodeObj->pDnode = sdbAcquire(pSdb, SDB_DNODE, &pMnodeObj->id); if (pMnodeObj->pDnode == NULL) { terrno = TSDB_CODE_MND_DNODE_NOT_EXIST; @@ -70,6 +71,7 @@ static int32_t mndMnodeActionInsert(SSdb *pSdb, SMnodeObj *pMnodeObj) { } static int32_t mndMnodeActionDelete(SSdb *pSdb, SMnodeObj *pMnodeObj) { + mTrace("mnode:%d, perform delete action", pMnodeObj->id); if (pMnodeObj->pDnode != NULL) { sdbRelease(pSdb, pMnodeObj->pDnode); pMnodeObj->pDnode = NULL; @@ -79,6 +81,7 @@ static int32_t mndMnodeActionDelete(SSdb *pSdb, SMnodeObj *pMnodeObj) { } static int32_t mndMnodeActionUpdate(SSdb *pSdb, SMnodeObj *pSrcMnode, SMnodeObj *pDstMnode) { + mTrace("mnode:%d, perform update action", pSrcMnode->id); pSrcMnode->id = pDstMnode->id; pSrcMnode->createdTime = pDstMnode->createdTime; pSrcMnode->updateTime = pDstMnode->updateTime; @@ -95,6 +98,7 @@ static int32_t mndCreateDefaultMnode(SMnode *pMnode) { if (pRaw == NULL) return -1; sdbSetRawStatus(pRaw, SDB_STATUS_READY); + mTrace("mnode:%d, will be created while deploy sdb", mnodeObj.id); return sdbWrite(pMnode->pSdb, pRaw); } diff --git a/source/dnode/mnode/impl/src/mnode.c b/source/dnode/mnode/impl/src/mnode.c index e1c7b66c36..8c206a724a 100644 --- a/source/dnode/mnode/impl/src/mnode.c +++ b/source/dnode/mnode/impl/src/mnode.c @@ -112,6 +112,7 @@ static int32_t mnodeCreateDir(SMnode *pMnode, const char *path) { static int32_t mndInitSdb(SMnode *pMnode) { SSdbOpt opt = {0}; opt.path = pMnode->path; + opt.pMnode = pMnode; pMnode->pSdb = sdbInit(&opt); if (pMnode->pSdb == NULL) {