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

fix(stream): remove invalid assert.

This commit is contained in:
Haojun Liao 2025-02-09 22:29:41 +08:00
parent 732a9d4b32
commit e60321196b
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -119,13 +119,11 @@ void streamQueueNextItemInSourceQ(SStreamQueue* pQueue, SStreamQueueItem** pItem
if (flag == STREAM_QUEUE__CHKPTFAILED) { if (flag == STREAM_QUEUE__CHKPTFAILED) {
*pItem = pQueue->qChkptItem; *pItem = pQueue->qChkptItem;
ASSERT(status != TASK_STATUS__CK && pQueue->qItem == NULL);
return; return;
} }
if (flag == STREAM_QUEUE__FAILED) { if (flag == STREAM_QUEUE__FAILED) {
*pItem = pQueue->qItem; *pItem = pQueue->qItem;
ASSERT(status != TASK_STATUS__CK && pQueue->qChkptItem == NULL);
return; return;
} }