xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Revert changes in transCli.

This commit is contained in:
xiao-77 2024-11-29 11:09:31 +08:00
parent bf6361ac93
commit 71bdfdc3f7
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/transport/src/transCli.c
View File

@ -652,7 +652,6 @@ void cliHandleResp(SCliConn* conn) {
} }
if ((code = transDecompressMsg((char**)&pHead, &msgLen)) < 0) { 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); tDebug("%s conn %p recv invalid packet, failed to decompress", CONN_GET_INST_LABEL(conn), conn);
// TODO: notify cb // TODO: notify cb
return; return;
@ -665,10 +664,8 @@ void cliHandleResp(SCliConn* conn) {
if (cliHandleState_mayHandleReleaseResp(conn, pHead)) { if (cliHandleState_mayHandleReleaseResp(conn, pHead)) {
if (cliMayRecycleConn(conn)) { if (cliMayRecycleConn(conn)) {
taosMemoryFree(pHead);
return; return;
} }
taosMemoryFree(pHead);
return; return;
} }
code = cliGetReqBySeq(conn, seq, pHead->msgType, &pReq); code = cliGetReqBySeq(conn, seq, pHead->msgType, &pReq);
@ -677,7 +674,6 @@ void cliHandleResp(SCliConn* conn) {
if (code == 0) { if (code == 0) {
code = cliBuildRespFromCont(NULL, &resp, pHead); code = cliBuildRespFromCont(NULL, &resp, pHead);
code = cliNotifyCb(conn, NULL, &resp); code = cliNotifyCb(conn, NULL, &resp);
taosMemoryFree(pHead);
return; return;
} }
if (code != 0) { 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", 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, CONN_GET_INST_LABEL(conn), conn, TMSG_INFO(resp.msgType), conn->dst, conn->src, pHead->msgLen, seq, qId,
tstrerror(pHead->code)); tstrerror(pHead->code));
taosMemoryFree(pHead);
code = cliNotifyCb(conn, pReq, &resp); code = cliNotifyCb(conn, pReq, &resp);
if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) { if (code == TSDB_CODE_RPC_ASYNC_IN_PROCESS) {
tGWarn("%s msg need retry", CONN_GET_INST_LABEL(conn)); tGWarn("%s msg need retry", CONN_GET_INST_LABEL(conn));