From 2ce9d05f7526ca564b39cba5fa7143320bcfbfce Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Mon, 8 Jul 2024 15:33:04 +0800 Subject: [PATCH] fix:[TD-30915]tmq exit elegantly --- source/client/src/clientTmq.c | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index c9f567b890..1c5d085aaf 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -1065,16 +1065,13 @@ void tmqFreeImpl(void* handle) { taos_close_internal(tmq->pTscObj); if(tmq->commitTimer) { - taosTmrStopA(tmq->commitTimer); - tmq->commitTimer = NULL; + taosTmrStopA(&tmq->commitTimer); } if(tmq->epTimer) { - taosTmrStopA(tmq->epTimer); - tmq->epTimer = NULL; + taosTmrStopA(&tmq->epTimer); } if(tmq->hbLiveTimer) { - taosTmrStopA(tmq->hbLiveTimer); - tmq->hbLiveTimer = NULL; + taosTmrStopA(&tmq->hbLiveTimer); } taosMemoryFree(tmq);