From 7942a9bfd185aa6d50b9b4c13e480f0d464b6988 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Tue, 13 Aug 2024 14:11:10 +0800
Subject: [PATCH] change queue limit

---
 source/util/src/tqueue.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/util/src/tqueue.c b/source/util/src/tqueue.c
index 4c80540bed..9ba88b4451 100644
--- a/source/util/src/tqueue.c
+++ b/source/util/src/tqueue.c
@@ -149,8 +149,8 @@ int64_t taosQueueMemorySize(STaosQueue *queue) {
 
 int32_t taosAllocateQitem(int32_t size, EQItype itype, int64_t dataSize, void **item) {
   int64_t alloced = atomic_add_fetch_64(&tsQueueMemoryUsed, size + dataSize);
-  if (itype == RPC_QITEM) {
-    if (alloced > tsQueueMemoryAllowed) {
+  if (alloced > tsQueueMemoryAllowed) {
+    if (itype == RPC_QITEM) {
       uError("failed to alloc qitem, size:%" PRId64 " alloc:%" PRId64 " allowed:%" PRId64, size + dataSize, alloced,
              tsQueueMemoryAllowed);
       (void)atomic_sub_fetch_64(&tsQueueMemoryUsed, size + dataSize);