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

fix(stream): fix a typo

This commit is contained in:
Haojun Liao 2024-08-15 22:28:13 +08:00
parent 3274194d21
commit 44466a4bcd
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/stream/src/streamDispatch.c
View File

@ -765,7 +765,7 @@ int32_t streamDispatchStreamBlock(SStreamTask* pTask) {
// todo: secure the timerActive and start timer in after lock pTask->lock // todo: secure the timerActive and start timer in after lock pTask->lock
streamMutexLock(&pTask->lock); streamMutexLock(&pTask->lock);
bool shouldStop = streamTaskShouldStop(pTask); bool shouldStop = streamTaskShouldStop(pTask);
streamMutexLock(&pTask->lock); streamMutexUnlock(&pTask->lock);
if (shouldStop) { if (shouldStop) {
stDebug("s-task:%s in stop/dropping status, not start dispatch monitor tmr", id); stDebug("s-task:%s in stop/dropping status, not start dispatch monitor tmr", id);