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

fix(stream): retry stop timer for trigger tmr.

This commit is contained in:
Haojun Liao 2024-04-07 10:18:01 +08:00
parent 94f703889d
commit 1b343e662c
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/libs/stream/src/streamTask.c
View File

@ -375,17 +375,22 @@ void tFreeStreamTask(SStreamTask* pTask) {
} }
if (pTask->schedInfo.pDelayTimer != NULL) { if (pTask->schedInfo.pDelayTimer != NULL) {
taosTmrStop(pTask->schedInfo.pDelayTimer); while(!taosTmrStop(pTask->schedInfo.pDelayTimer)) {
stError("failed to stop the trigger sched timer, wait for 100ms and retry");
taosMsleep(100);
}
pTask->schedInfo.pDelayTimer = NULL; pTask->schedInfo.pDelayTimer = NULL;
} }
if (pTask->hTaskInfo.pTimer != NULL) { if (pTask->hTaskInfo.pTimer != NULL) {
taosTmrStop(pTask->hTaskInfo.pTimer); bool ret = taosTmrStop(pTask->hTaskInfo.pTimer);
ASSERT(ret);
pTask->hTaskInfo.pTimer = NULL; pTask->hTaskInfo.pTimer = NULL;
} }
if (pTask->msgInfo.pTimer != NULL) { if (pTask->msgInfo.pTimer != NULL) {
taosTmrStop(pTask->msgInfo.pTimer); bool ret = taosTmrStop(pTask->msgInfo.pTimer);
ASSERT(ret);
pTask->msgInfo.pTimer = NULL; pTask->msgInfo.pTimer = NULL;
} }