From 4826b34a2bb5d06ab4f6a0f58f3592dd7c447618 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 21 Oct 2023 16:32:44 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/stream/src/streamQueue.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamQueue.c b/source/libs/stream/src/streamQueue.c index 7305e9db83..e4c13699c9 100644 --- a/source/libs/stream/src/streamQueue.c +++ b/source/libs/stream/src/streamQueue.c @@ -120,7 +120,7 @@ int32_t streamQueueGetNumOfItems(const SStreamQueue* pQueue) { } int32_t streamQueueGetItemSize(const SStreamQueue* pQueue) { - return taosQueueMemorySize(pQueue->pQueue) + taosQallMemSize(pQueue->qall); + return taosQueueMemorySize(pQueue->pQueue) + taosQallUnAccessedMemSize(pQueue->qall); } int32_t streamQueueItemGetSize(const SStreamQueueItem* pItem) {