From 71bdfdc3f74592a3997256e3d81b21d75d6d6ffd Mon Sep 17 00:00:00 2001 From: xiao-77 Date: Fri, 29 Nov 2024 11:09:31 +0800 Subject: [PATCH] Revert changes in transCli. --- source/libs/transport/src/transCli.c | 5 ----- 1 file changed, 5 deletions(-) diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index 9e9e874bf7..fffcd316f6 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -652,7 +652,6 @@ void cliHandleResp(SCliConn* conn) { } if ((code = transDecompressMsg((char**)&pHead, &msgLen)) < 0) { - taosMemoryFree(pHead); tDebug("%s conn %p recv invalid packet, failed to decompress", CONN_GET_INST_LABEL(conn), conn); // TODO: notify cb return; @@ -665,10 +664,8 @@ void cliHandleResp(SCliConn* conn) { if (cliHandleState_mayHandleReleaseResp(conn, pHead)) { if (cliMayRecycleConn(conn)) { - taosMemoryFree(pHead); return; } - taosMemoryFree(pHead); return; } code = cliGetReqBySeq(conn, seq, pHead->msgType, &pReq); @@ -677,7 +674,6 @@ void cliHandleResp(SCliConn* conn) { if (code == 0) { code = cliBuildRespFromCont(NULL, &resp, pHead); code = cliNotifyCb(conn, NULL, &resp); - taosMemoryFree(pHead); return; } if (code != 0) { @@ -705,7 +701,6 @@ void cliHandleResp(SCliConn* conn) { tGDebug("%s conn %p %s received from %s, local info:%s, len:%d, seq:%" PRId64 ", sid:%" PRId64 ", code:%s", CONN_GET_INST_LABEL(conn), conn, TMSG_INFO(resp.msgType), conn->dst, conn->src, pHead->msgLen, seq, qId, tstrerror(pHead->code)); - taosMemoryFree(pHead); code = cliNotifyCb(conn, pReq, &resp); if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) { tGWarn("%s msg need retry", CONN_GET_INST_LABEL(conn));