From a3c80a2a70ce78176c574021c32c6eb798188c8d Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Fri, 13 Sep 2024 15:14:15 +0800
Subject: [PATCH] opt parameter

---
 source/libs/transport/src/transSvr.c | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c
index 30b9053979..7f22e944e0 100644
--- a/source/libs/transport/src/transSvr.c
+++ b/source/libs/transport/src/transSvr.c
@@ -443,11 +443,12 @@ static int32_t uvMayHandleReleaseReq(SSvrConn* pConn, STransMsgHead* pHead) {
       (void)taosHashRemove(pConn->pQTable, &qId, sizeof(qId));
     }
 
-    STransMsg    tmsg = {.code = code,
-                         .msgType = pHead->msgType + 1,
-                         .info.qId = qId,
-                         .info.traceId = pHead->traceId,
-                         .info.seqNum = htonl(pHead->seqNum)};
+    STransMsg tmsg = {.code = code,
+                      .msgType = pHead->msgType + 1,
+                      .info.qId = qId,
+                      .info.traceId = pHead->traceId,
+                      .info.seqNum = htonl(pHead->seqNum)};
+
     SSvrRespMsg* srvMsg = taosMemoryCalloc(1, sizeof(SSvrRespMsg));
     srvMsg->msg = tmsg;
     srvMsg->type = Normal;
@@ -456,6 +457,7 @@ static int32_t uvMayHandleReleaseReq(SSvrConn* pConn, STransMsgHead* pHead) {
     transQueuePush(&pConn->resps, &srvMsg->q);
 
     uvStartSendRespImpl(srvMsg);
+    taosMemoryFree(pHead);
     return 1;
   }
   return 0;
@@ -507,6 +509,7 @@ static bool uvHandleReq(SSvrConn* pConn) {
 
   if (transDecompressMsg((char**)&pHead, msgLen) < 0) {
     tError("%s conn %p recv invalid packet, failed to decompress", transLabel(pInst), pConn);
+    taosMemoryFree(pHead);
     return false;
   }
   pHead->code = htonl(pHead->code);