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

fix:[TD-31017]process return value in client for tmq

This commit is contained in:
wangmm0220 2024-07-23 14:35:40 +08:00
parent 62a781ac6e
commit 3bd21d446d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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);
}
}