free pReqMsg if outType is not 0

6b3d0a18 · 陶建辉(Jeff) · 0568c10c · 6b3d0a18
显示空白变更内容
内联并排

Showing with 4 addition and 1 deletion

src/rpc/src/rpcMain.c src/rpc/src/rpcMain.c +4 -1

未找到文件。
--- a/src/rpc/src/rpcMain.c
+++ b/src/rpc/src/rpcMain.c
@@ -603,6 +603,9 @@ static void rpcReleaseConn(SRpcConn *pConn) {
    rpcFreeMsg(pConn->pRspMsg); // it may have a response msg saved, but not request msg
    pConn->pRspMsg = NULL;
    if (pConn->pReqMsg) rpcFreeCont(pConn->pReqMsg);
+  } else {
+    if (pConn->outType && pConn->pReqMsg) 
+      rpcFreeCont(pConn->pReqMsg);
  }
  // memset could not be used, since lockeBy can not be reset