fix memory leak when read failed

Signed-off-by: siddontang <siddontang@gmail.com>
This commit is contained in:
siddontang 2019-07-12 22:00:01 +08:00
parent 28b27619c9
commit 74d44497d8
1 changed files with 2 additions and 0 deletions

View File

@ -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;
}