diff --git a/include/common/tmsg.h b/include/common/tmsg.h
index 413658524169aa4e77bd4abe14482f7766f73d58..6dda3b195e98c8a95de5bb1e4997dc49185f6233 100644
--- a/include/common/tmsg.h
+++ b/include/common/tmsg.h
@@ -42,13 +42,15 @@ extern "C" {
 #undef TD_MSG_SEG_CODE_
 #include "tmsgdef.h"
 
-extern char *tMsgInfo[];
+extern char* tMsgInfo[];
 extern int   tMsgDict[];
 
 #define TMSG_SEG_CODE(TYPE) (((TYPE)&0xff00) >> 8)
 #define TMSG_SEG_SEQ(TYPE) ((TYPE)&0xff)
 #define TMSG_INFO(TYPE) tMsgInfo[tMsgDict[TMSG_SEG_CODE(TYPE)] + TMSG_SEG_SEQ(TYPE)]
 
+typedef uint16_t tmsg_t;
+
 // IE type
 #define TSDB_IE_TYPE_SEC 1
 #define TSDB_IE_TYPE_META 2
@@ -122,7 +124,7 @@ typedef enum _mgmt_table {
 
 typedef struct SBuildTableMetaInput {
   int32_t vgId;
-  char *  tableFullName;
+  char*   tableFullName;
 } SBuildTableMetaInput;
 
 typedef struct SBuildUseDBInput {
@@ -395,7 +397,7 @@ typedef struct SColumnFilterList {
   int16_t numOfFilters;
   union {
     int64_t            placeholder;
-    SColumnFilterInfo *filterInfo;
+    SColumnFilterInfo* filterInfo;
   };
 } SColumnFilterList;
 /*
@@ -784,7 +786,7 @@ typedef struct SMultiTableMeta {
 typedef struct {
   int32_t dataLen;
   char    name[TSDB_TABLE_FNAME_LEN];
-  char *  data;
+  char*   data;
 } STagData;
 
 typedef struct {
diff --git a/include/libs/transport/trpc.h b/include/libs/transport/trpc.h
index 976c0b8bb482fcd9bbaf882319f1362bca390a70..b88d45fbd661fd4c1fce9c71abcabacb9b007404 100644
--- a/include/libs/transport/trpc.h
+++ b/include/libs/transport/trpc.h
@@ -24,41 +24,41 @@ extern "C" {
 #include "taosdef.h"
 #include "tmsg.h"
 
-#define TAOS_CONN_SERVER   0
-#define TAOS_CONN_CLIENT   1
+#define TAOS_CONN_SERVER 0
+#define TAOS_CONN_CLIENT 1
 
 extern int tsRpcHeadSize;
 
 typedef struct SRpcConnInfo {
-  uint32_t  clientIp;
-  uint16_t  clientPort;
-  uint32_t  serverIp;
-  char      user[TSDB_USER_LEN];
+  uint32_t clientIp;
+  uint16_t clientPort;
+  uint32_t serverIp;
+  char     user[TSDB_USER_LEN];
 } SRpcConnInfo;
 
 typedef struct SRpcMsg {
-  uint8_t msgType;
-  void   *pCont;
+  tmsg_t  msgType;
+  void *  pCont;
   int     contLen;
   int32_t code;
-  void   *handle;   // rpc handle returned to app
-  void   *ahandle;  // app handle set by client
+  void *  handle;   // rpc handle returned to app
+  void *  ahandle;  // app handle set by client
 } SRpcMsg;
 
 typedef struct SRpcInit {
- uint16_t localPort; // local port
-  char  *label;        // for debug purpose
-  int    numOfThreads; // number of threads to handle connections
-  int    sessions;     // number of sessions allowed
-  int8_t connType;     // TAOS_CONN_UDP, TAOS_CONN_TCPC, TAOS_CONN_TCPS
-  int    idleTime;     // milliseconds, 0 means idle timer is disabled
+  uint16_t localPort;     // local port
+  char *   label;         // for debug purpose
+  int      numOfThreads;  // number of threads to handle connections
+  int      sessions;      // number of sessions allowed
+  int8_t   connType;      // TAOS_CONN_UDP, TAOS_CONN_TCPC, TAOS_CONN_TCPS
+  int      idleTime;      // milliseconds, 0 means idle timer is disabled
 
   // the following is for client app ecurity only
-  char *user;         // user name
-  char  spi;          // security parameter index
-  char  encrypt;      // encrypt algorithm
-  char *secret;       // key for authentication
-  char *ckey;         // ciphering key
+  char *user;     // user name
+  char  spi;      // security parameter index
+  char  encrypt;  // encrypt algorithm
+  char *secret;   // key for authentication
+  char *ckey;     // ciphering key
 
   // call back to process incoming msg, code shall be ignored by server app
   void (*cfp)(void *parent, SRpcMsg *, SEpSet *);
@@ -70,19 +70,19 @@ typedef struct SRpcInit {
 } SRpcInit;
 
 int32_t rpcInit();
-void  rpcCleanup();
-void *rpcOpen(const SRpcInit *pRpc);
-void  rpcClose(void *);
-void *rpcMallocCont(int contLen);
-void  rpcFreeCont(void *pCont);
-void *rpcReallocCont(void *ptr, int contLen);
-void  rpcSendRequest(void *thandle, const SEpSet *pEpSet, SRpcMsg *pMsg, int64_t *rid);
-void  rpcSendResponse(const SRpcMsg *pMsg);
-void  rpcSendRedirectRsp(void *pConn, const SEpSet *pEpSet); 
-int   rpcGetConnInfo(void *thandle, SRpcConnInfo *pInfo);
-void  rpcSendRecv(void *shandle, SEpSet *pEpSet, SRpcMsg *pReq, SRpcMsg *pRsp);
-int   rpcReportProgress(void *pConn, char *pCont, int contLen);
-void  rpcCancelRequest(int64_t rid);
+void    rpcCleanup();
+void *  rpcOpen(const SRpcInit *pRpc);
+void    rpcClose(void *);
+void *  rpcMallocCont(int contLen);
+void    rpcFreeCont(void *pCont);
+void *  rpcReallocCont(void *ptr, int contLen);
+void    rpcSendRequest(void *thandle, const SEpSet *pEpSet, SRpcMsg *pMsg, int64_t *rid);
+void    rpcSendResponse(const SRpcMsg *pMsg);
+void    rpcSendRedirectRsp(void *pConn, const SEpSet *pEpSet);
+int     rpcGetConnInfo(void *thandle, SRpcConnInfo *pInfo);
+void    rpcSendRecv(void *shandle, SEpSet *pEpSet, SRpcMsg *pReq, SRpcMsg *pRsp);
+int     rpcReportProgress(void *pConn, char *pCont, int contLen);
+void    rpcCancelRequest(int64_t rid);
 
 #ifdef __cplusplus
 }