[TD-335] rename some functions

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" {

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) {

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,