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

Merge pull request #29721 from taosdata/fix/TD-33556-main 

fix:do not release tmq to avoid invalid read/write when process quit
This commit is contained in:
Pan Wei 2025-02-11 09:11:32 +08:00 committed by GitHub
parent 66ef32f5e5 b53290c919
commit 6429eae87c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1639,11 +1639,6 @@ void tmqMgmtClose(void) {
break; break;
} }
atomic_store_8(&tmq->status, TMQ_CONSUMER_STATUS__CLOSED); atomic_store_8(&tmq->status, TMQ_CONSUMER_STATUS__CLOSED);
if (taosRemoveRef(tmqMgmt.rsetId, tmq->refId) != 0) {
qWarn("taosRemoveRef tmq refId:%" PRId64 " failed, error:%s", refId, tstrerror(terrno));
}
tmq = taosIterateRef(tmqMgmt.rsetId, refId); tmq = taosIterateRef(tmqMgmt.rsetId, refId);
} }
taosCloseRef(tmqMgmt.rsetId); taosCloseRef(tmqMgmt.rsetId);