fix: fix memory leak during crashgen stream and subscribe

c6efc1ed · shenglian zhou · 70b937cf · c6efc1ed
显示空白变更内容
内联并排

Showing with 4 addition and 1 deletion

source/common/src/tmsg.c source/common/src/tmsg.c +4 -1

未找到文件。
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -2591,7 +2591,10 @@ int32_t tDeserializeSUseDbBatchRsp(void *buf, int32_t bufLen, SUseDbBatchRsp *pR
  for (int32_t i = 0; i < numOfBatch; ++i) {
    SUseDbRsp usedbRsp = {0};
-    if (tDeserializeSUseDbRspImp(&decoder, &usedbRsp) < 0) return -1;
+    if (tDeserializeSUseDbRspImp(&decoder, &usedbRsp) < 0) {
+      tDecoderClear(&decoder);
+      return -1;
+    }
    taosArrayPush(pRsp->pArray, &usedbRsp);
  }
  tEndDecode(&decoder);