From 219e9553e7050cc14a6314d8a9fa6220d5f2ba9e Mon Sep 17 00:00:00 2001
From: Shengliang Guan <slguan@taosdata.com>
Date: Fri, 13 May 2022 14:58:52 +0800
Subject: [PATCH] refactor: control the memory of the rpc queue

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

diff --git a/source/util/src/tqueue.c b/source/util/src/tqueue.c
index 0d96dcda0a..d4c5a08011 100644
--- a/source/util/src/tqueue.c
+++ b/source/util/src/tqueue.c
@@ -28,7 +28,7 @@ typedef struct STaosQnode {
 } STaosQnode;
 
 typedef struct STaosQueue {
-  int32_t       memOfItems;
+  int64_t       memOfItems;
   int32_t       numOfItems;
   int32_t       threadId;
   STaosQnode   *head;
@@ -125,9 +125,9 @@ int32_t taosQueueItemSize(STaosQueue *queue) {
   return numOfItems;
 }
 
-int32_t taosQueueMemorySize(STaosQueue *queue) {
+int64_t taosQueueMemorySize(STaosQueue *queue) {
   taosThreadMutexLock(&queue->mutex);
-  int32_t memOfItems = queue->memOfItems;
+  int64_t memOfItems = queue->memOfItems;
   taosThreadMutexUnlock(&queue->mutex);
   return memOfItems;
 }