From d37ab181d06a71829ccbfa34a7ebeedb1afd871f Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Tue, 7 Jul 2020 11:23:03 +0800 Subject: [PATCH] change rpcFreeCont to rpcFreeMsg --- src/rpc/src/rpcMain.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/rpc/src/rpcMain.c b/src/rpc/src/rpcMain.c index e432e47e36..0d5b80e8f3 100644 --- a/src/rpc/src/rpcMain.c +++ b/src/rpc/src/rpcMain.c @@ -602,10 +602,13 @@ static void rpcReleaseConn(SRpcConn *pConn) { taosHashRemove(pRpc->hash, hashstr, size); rpcFreeMsg(pConn->pRspMsg); // it may have a response msg saved, but not request msg pConn->pRspMsg = NULL; - if (pConn->pReqMsg) rpcFreeCont(pConn->pReqMsg); + + // if server has ever reported progress, free content + if (pConn->pReqMsg) rpcFreeCont(pConn->pReqMsg); // do not use rpcFreeMsg } else { + // if there is an outgoing message, free it if (pConn->outType && pConn->pReqMsg) - rpcFreeCont(pConn->pReqMsg); + rpcFreeMsg(pConn->pReqMsg); } // memset could not be used, since lockeBy can not be reset -- GitLab