fix memory leak when read failed

Signed-off-by: siddontang <[email protected]>
boshengchen · Jul 12, 2019 · 74d4449 · 74d4449
1 parent 28b2761
commit 74d4449
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/rpc/src/ttcpserver.c b/src/rpc/src/ttcpserver.c
@@ -199,6 +199,7 @@ static void taosProcessTcpData(void *param) {
       if (headLen != sizeof(STaosHeader)) {
         tError("%s read error, headLen:%d", pThreadObj->label, headLen);
         taosCleanUpFdObj(pFdObj);
+        free(buffer);
         continue;
       }
 
@@ -214,6 +215,7 @@ static void taosProcessTcpData(void *param) {
       if (leftLen != retLen) {
         tError("%s read error, leftLen:%d retLen:%d", pThreadObj->label, leftLen, retLen);
         taosCleanUpFdObj(pFdObj);
+        free(buffer);
         continue;
       }