From 21234a33dc5010ea430b509615dd2739a3df0acf Mon Sep 17 00:00:00 2001 From: cyang Date: Fri, 24 Feb 2023 17:02:30 +0800 Subject: [PATCH] fix:converity scan error --- source/dnode/vnode/src/tq/tq.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 4281aa0df6..9bdd8f4bdf 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1335,8 +1335,12 @@ int32_t tqProcessDelReq(STQ* pTq, void* pReq, int32_t len, int64_t ver) { } } - blockDataDestroy(pDelBlock); - taosMemoryFree(pRef); + int32_t ref = atomic_sub_fetch_32(pRef, 1); + /*A(ref >= 0);*/ + if (ref == 0) { + blockDataDestroy(pDelBlock); + taosMemoryFree(pRef); + } #if 0 SStreamDataBlock* pStreamBlock = taosAllocateQitem(sizeof(SStreamDataBlock), DEF_QITEM, 0);