refactor: do some internal refactor.

2024-08-15 17:11:43 +08:00 · 2024-08-15 17:11:43 +08:00 · 3274194d21
parent 761ae2ab4b
commit 3274194d21
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamDispatch.c
+++ b/source/libs/stream/src/streamDispatch.c
@ -762,6 +762,7 @@ int32_t streamDispatchStreamBlock(SStreamTask* pTask) {

  code = sendDispatchMsg(pTask, pTask->msgInfo.pData);

+  // todo: secure the timerActive and start timer in after lock pTask->lock
  streamMutexLock(&pTask->lock);
  bool shouldStop = streamTaskShouldStop(pTask);
  streamMutexLock(&pTask->lock);