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

fix(stream): check the status before exec stream task when handling the dispatch requests.

This commit is contained in:
Haojun Liao 2023-09-20 16:32:27 +08:00
parent 02610f5546
commit c403a15f36
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/stream.c
View File

@ -255,10 +255,14 @@ int32_t streamProcessDispatchMsg(SStreamTask* pTask, SStreamDispatchReq* pReq, S
tDeleteStreamDispatchReq(pReq); tDeleteStreamDispatchReq(pReq);
int8_t st = pTask->status.taskStatus;
if (st == TASK_STATUS__NORMAL || st == TASK_STATUS__SCAN_HISTORY || st == TASK_STATUS__CK) {
int8_t schedStatus = streamTaskSetSchedStatusWait(pTask); int8_t schedStatus = streamTaskSetSchedStatusWait(pTask);
if (schedStatus == TASK_SCHED_STATUS__INACTIVE) { if (schedStatus == TASK_SCHED_STATUS__INACTIVE) {
streamTryExec(pTask); streamTryExec(pTask);
} }
}
return 0; return 0;
} }