From ef3e2737f40fdd8d77dbf809b4678bab30e853c8 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 25 Aug 2023 17:39:31 +0800
Subject: [PATCH] fix(stream): fix syntax error.

---
 source/libs/stream/src/streamQueue.c | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/source/libs/stream/src/streamQueue.c b/source/libs/stream/src/streamQueue.c
index f4824078c4..e0b6116457 100644
--- a/source/libs/stream/src/streamQueue.c
+++ b/source/libs/stream/src/streamQueue.c
@@ -40,6 +40,13 @@ SStreamQueue* streamQueueOpen(int64_t cap) {
   return pQueue;
 }
 
+void streamQueueCleanup(SStreamQueue* pQueue) {
+  void* qItem = NULL;
+  while ((qItem = streamQueueNextItem(pQueue)) != NULL) {
+    streamFreeQitem(qItem);
+  }
+  pQueue->status = STREAM_QUEUE__SUCESS;
+}
 // void streamQueueClose(SStreamQueue* pQueue) {
 //   streamQueueCleanup(pQueue);
 
@@ -50,12 +57,8 @@ SStreamQueue* streamQueueOpen(int64_t cap) {
 
 void streamQueueClose(SStreamQueue* pQueue, int32_t taskId) {
   qDebug("s-task:0x%x free the queue:%p, items in queue:%d", taskId, pQueue->queue, taosQueueItemSize(pQueue->queue));
-  void* qItem = NULL;
-  while ((qItem = streamQueueNextItem(pQueue)) != NULL) {
-    streamFreeQitem(qItem);
-  }
+  streamQueueCleanup(pQueue);
 
-  pQueue->status = STREAM_QUEUE__SUCESS;
   taosFreeQall(pQueue->qall);
   taosCloseQueue(pQueue->queue);
   taosMemoryFree(pQueue);