From dc1a0821a7c06495e1dc91db5f1b095c8623cad3 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 13 Jan 2024 00:19:46 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/stream/src/streamStart.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/source/libs/stream/src/streamStart.c b/source/libs/stream/src/streamStart.c index 53c40e5b5c..84f1dbb4d7 100644 --- a/source/libs/stream/src/streamStart.c +++ b/source/libs/stream/src/streamStart.c @@ -828,12 +828,12 @@ static void tryLaunchHistoryTask(void* param, void* tmrId) { } else { checkFillhistoryTaskStatus(pTask, pHTask); streamMetaReleaseTask(pMeta, pHTask); - } - // not in timer anymore - int32_t ref = atomic_sub_fetch_32(&pTask->status.timerActive, 1); - stDebug("s-task:0x%x fill-history task launch completed, retry times:%d, ref:%d", (int32_t)pInfo->id.taskId, - pHTaskInfo->retryTimes, ref); + // not in timer anymore + int32_t ref = atomic_sub_fetch_32(&pTask->status.timerActive, 1); + stDebug("s-task:0x%x fill-history task launch completed, retry times:%d, ref:%d", (int32_t)pInfo->id.taskId, + pHTaskInfo->retryTimes, ref); + } } streamMetaReleaseTask(pMeta, pTask);