diff --git a/source/dnode/mnode/impl/src/mndQnode.c b/source/dnode/mnode/impl/src/mndQnode.c index 8b705946593bd57b1a38168d2492448a03378e46..3e74da00be87e36ca580d30474202a1b976940d6 100644 --- a/source/dnode/mnode/impl/src/mndQnode.c +++ b/source/dnode/mnode/impl/src/mndQnode.c @@ -36,7 +36,7 @@ static int32_t mndProcessDropQnodeRsp(SMndMsg *pRsp); static int32_t mndGetQnodeMeta(SMndMsg *pReq, SShowObj *pShow, STableMetaRsp *pMeta); static int32_t mndRetrieveQnodes(SMndMsg *pReq, SShowObj *pShow, char *data, int32_t rows); static void mndCancelGetNextQnode(SMnode *pMnode, void *pIter); -static int32_t mndProcessQnodeListReq(SMnodeMsg *pReq); +static int32_t mndProcessQnodeListReq(SMndMsg *pReq); int32_t mndInitQnode(SMnode *pMnode) { SSdbTable table = {.sdbType = SDB_QNODE, @@ -432,7 +432,7 @@ DROP_QNODE_OVER: return code; } -static int32_t mndProcessQnodeListReq(SMnodeMsg *pReq) { +static int32_t mndProcessQnodeListReq(SMndMsg *pReq) { int32_t code = -1; SQnodeListReq qlistReq = {0}; int32_t numOfRows = 0; diff --git a/source/dnode/mnode/impl/src/mndShow.c b/source/dnode/mnode/impl/src/mndShow.c index 73bf858130b0fb12bd3ad8ab29cbb46a35c058b8..e580b1e0cd9fb4c1f04eadeb120a3aaaf7d27354 100644 --- a/source/dnode/mnode/impl/src/mndShow.c +++ b/source/dnode/mnode/impl/src/mndShow.c @@ -25,7 +25,7 @@ static void mndReleaseShowObj(SShowObj *pShow, bool forceRemove); static int32_t mndProcessShowReq(SMndMsg *pReq); static int32_t mndProcessRetrieveReq(SMndMsg *pReq); static bool mndCheckRetrieveFinished(SShowObj *pShow); -static int32_t mndProcessRetrieveSysTableReq(SMnodeMsg *pReq); +static int32_t mndProcessRetrieveSysTableReq(SMndMsg *pReq); int32_t mndInitShow(SMnode *pMnode) { SShowMgmt *pMgmt = &pMnode->showMgmt; @@ -263,7 +263,7 @@ static int32_t mndProcessRetrieveReq(SMndMsg *pReq) { return TSDB_CODE_SUCCESS; } -static int32_t mndProcessRetrieveSysTableReq(SMnodeMsg *pReq) { +static int32_t mndProcessRetrieveSysTableReq(SMndMsg *pReq) { SMnode *pMnode = pReq->pMnode; SShowMgmt *pMgmt = &pMnode->showMgmt; int32_t rowsToRead = 0; diff --git a/source/util/src/tprocess.c b/source/util/src/tprocess.c index 7a1f0d790061e1e0609f384318a75a21fc7b720b..5842604d2287eb1c9240b98a39814a1aded86bdb 100644 --- a/source/util/src/tprocess.c +++ b/source/util/src/tprocess.c @@ -374,7 +374,7 @@ SProcObj *taosProcInit(const SProcCfg *pCfg) { if (!pProc->testFlag) { pProc->pid = fork(); if (pProc->pid == 0) { - tsLogInited = 0; + // tsLogInited = 0; taosInitLog("mnodelog", 1); pProc->isChild = 1; uInfo("this is child process, pid:%d", pProc->pid);