From 3bd21d446d6875a1e9bcbe345a02004bc727735c Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Tue, 23 Jul 2024 14:35:40 +0800 Subject: [PATCH] fix:[TD-31017]process return value in client for tmq --- source/client/src/clientTmq.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index 3f578648fa..65e0d5fe91 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -780,7 +780,7 @@ static void generateTimedTask(int64_t refId, int32_t type) { } } - taosReleaseRef(tmqMgmt.rsetId, refId); + (void)taosReleaseRef(tmqMgmt.rsetId, refId); } void tmqAssignAskEpTask(void* param, void* tmrId) { @@ -2466,7 +2466,7 @@ int32_t tmq_consumer_close(tmq_t* tmq) { code = innerClose(tmq); if(code == 0){ atomic_store_8(&tmq->status, TMQ_CONSUMER_STATUS__CLOSED); - taosRemoveRef(tmqMgmt.rsetId, tmq->refId); + (void)taosRemoveRef(tmqMgmt.rsetId, tmq->refId); } }