diff --git a/src/dnode/inc/dnodeMPeer.h b/src/dnode/inc/dnodeMPeer.h
index cdbb4a210c959698b7e25aaaa7385b33c2556a08..9a48703110c389f10ac623ccaeaa85420a32817f 100644
--- a/src/dnode/inc/dnodeMPeer.h
+++ b/src/dnode/inc/dnodeMPeer.h
@@ -13,8 +13,8 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef TDENGINE_DNODE_MMGMT_H
-#define TDENGINE_DNODE_MMGMT_H
+#ifndef TDENGINE_DNODE_MPEER_H
+#define TDENGINE_DNODE_MPEER_H
 
 #ifdef __cplusplus
 extern "C" {
diff --git a/src/dnode/src/dnodeMPeer.c b/src/dnode/src/dnodeMPeer.c
index da1910a691cbb6e44696f015bc4e0d02ca22e265..e3ba5fcf017cb51bd6eef69d45350ddaf03b490c 100644
--- a/src/dnode/src/dnodeMPeer.c
+++ b/src/dnode/src/dnodeMPeer.c
@@ -119,7 +119,7 @@ void dnodeDispatchToMnodePeerQueue(SRpcMsg *pMsg) {
   taosWriteQitem(tsMPeerQueue, TAOS_QTYPE_RPC, pPeer);
 }
 
-static void dnodeFreeMnodePeadMsg(SMnodeMsg *pPeer) {
+static void dnodeFreeMnodePeerMsg(SMnodeMsg *pPeer) {
   mnodeCleanupMsg(pPeer);
   taosFreeQitem(pPeer);
 }
@@ -135,7 +135,7 @@ static void dnodeSendRpcMnodePeerRsp(SMnodeMsg *pPeer, int32_t code) {
   };
 
   rpcSendResponse(&rpcRsp);
-  dnodeFreeMnodePeadMsg(pPeer);
+  dnodeFreeMnodePeerMsg(pPeer);
 }
 
 static void *dnodeProcessMnodePeerQueue(void *param) {
diff --git a/src/dnode/src/dnodeVRead.c b/src/dnode/src/dnodeVRead.c
index 4b1ff84bec0e92d450f2c62b599279bfd7f7bc2e..1ff868d0ff5e7ae341579265d52f1deec020a5a7 100644
--- a/src/dnode/src/dnodeVRead.c
+++ b/src/dnode/src/dnodeVRead.c
@@ -92,7 +92,7 @@ void dnodeCleanupVnodeRead() {
 }
 
 void dnodeDispatchToVnodeReadQueue(SRpcMsg *pMsg) {
-  int32_t     mnodeMsgNum = 0;
+  int32_t     queuedMsgNum = 0;
   int32_t     leftLen      = pMsg->contLen;
   char        *pCont       = (char *) pMsg->pCont;
   void        *pVnode;  
@@ -124,12 +124,12 @@ void dnodeDispatchToVnodeReadQueue(SRpcMsg *pMsg) {
     // next vnode
     leftLen -= pHead->contLen;
     pCont -= pHead->contLen;
-    mnodeMsgNum++;
+    queuedMsgNum++;
 
     taosWriteQitem(queue, TAOS_QTYPE_RPC, pRead);
   }
 
-  if (mnodeMsgNum == 0) {
+  if (queuedMsgNum == 0) {
     SRpcMsg rpcRsp = {
         .handle  = pMsg->handle,
         .pCont   = NULL,