From 67e04c66323c54ec8cd5f9b1ec7c971feb7ad35d Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Thu, 17 Feb 2022 10:37:13 +0800 Subject: [PATCH] minor changes --- source/dnode/mnode/impl/src/mndTrans.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndTrans.c b/source/dnode/mnode/impl/src/mndTrans.c index 3230074add..5f624357e7 100644 --- a/source/dnode/mnode/impl/src/mndTrans.c +++ b/source/dnode/mnode/impl/src/mndTrans.c @@ -51,7 +51,7 @@ static bool mndTransPerfromFinishedStage(SMnode *pMnode, STrans *pTrans); static void mndTransExecute(SMnode *pMnode, STrans *pTrans); static void mndTransSendRpcRsp(STrans *pTrans); -static int32_t mndProcessTransMsg(SMnodeMsg *pMsg); +static int32_t mndProcessTransReq(SMnodeMsg *pMsg); int32_t mndInitTrans(SMnode *pMnode) { SSdbTable table = {.sdbType = SDB_TRANS, @@ -62,7 +62,7 @@ int32_t mndInitTrans(SMnode *pMnode) { .updateFp = (SdbUpdateFp)mndTransActionUpdate, .deleteFp = (SdbDeleteFp)mndTransActionDelete}; - mndSetMsgHandle(pMnode, TDMT_MND_TRANS, mndProcessTransMsg); + mndSetMsgHandle(pMnode, TDMT_MND_TRANS, mndProcessTransReq); return sdbSetTable(pMnode->pSdb, table); } @@ -941,8 +941,8 @@ static void mndTransExecute(SMnode *pMnode, STrans *pTrans) { mndTransSendRpcRsp(pTrans); } -static int32_t mndProcessTransMsg(SMnodeMsg *pMsg) { - mndTransPullup(pMsg->pMnode); +static int32_t mndProcessTransReq(SMnodeMsg *pReq) { + mndTransPullup(pReq->pMnode); return 0; }