diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c
index ecd2ec83674b0869d2333e037192dd0ba563bbd8..0410281f0dee3c7f685417b08620aa8d2c9aec49 100644
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -869,7 +869,7 @@ static void *rpcProcessMsgFromPeer(SRecvInfo *pRecv) {
 
   if (pRecv->ip==0 && pConn) {
     rpcProcessBrokenLink(pConn); 
-    tfree(pRecv->msg);
+    rpcFreeMsg(pRecv->msg);
     return NULL;
   }