diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index 99905d4ed3f2486dedb5c17ae869c3f0aeb9a5eb..ecd2ec83674b0869d2333e037192dd0ba563bbd8 100644
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -894,7 +894,7 @@ static void *rpcProcessMsgFromPeer(SRecvInfo *pRecv) {
     }
   }
 
-  if (code) tfree(pRecv->msg); // parsing failed, msg shall be freed
+  if (code) rpcFreeMsg(pRecv->msg); // parsing failed, msg shall be freed
   return pConn;
 }