fix(stream): add task status check.

623ea6df · Haojun Liao · 6fc364db · 623ea6df
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/stream.c source/libs/stream/src/stream.c +1 -1

未找到文件。
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -52,7 +52,7 @@ void streamCleanUp() {
 void streamSchedByTimer(void* param, void* tmrId) {
  SStreamTask* pTask = (void*)param;

-  if (atomic_load_8(&pTask->status.taskStatus) == TASK_STATUS__DROPPING) {
+  if (streamTaskShouldStop(&pTask->status)) {
    streamMetaReleaseTask(NULL, pTask);
    return;
  }