xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:[TD-30915]tmq exit elegantly

This commit is contained in:
wangmm0220 2024-07-08 15:33:04 +08:00
parent e14d11c78a
commit 2ce9d05f75
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
source/client/src/clientTmq.c
View File

@ -1065,16 +1065,13 @@ void tmqFreeImpl(void* handle) {
taos_close_internal(tmq->pTscObj); taos_close_internal(tmq->pTscObj);
if(tmq->commitTimer) { if(tmq->commitTimer) {
taosTmrStopA(tmq->commitTimer); taosTmrStopA(&tmq->commitTimer);
tmq->commitTimer = NULL;
} }
if(tmq->epTimer) { if(tmq->epTimer) {
taosTmrStopA(tmq->epTimer); taosTmrStopA(&tmq->epTimer);
tmq->epTimer = NULL;
} }
if(tmq->hbLiveTimer) { if(tmq->hbLiveTimer) {
taosTmrStopA(tmq->hbLiveTimer); taosTmrStopA(&tmq->hbLiveTimer);
tmq->hbLiveTimer = NULL;
} }
taosMemoryFree(tmq); taosMemoryFree(tmq);