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

refactor: control the memory of the rpc queue

This commit is contained in:
Shengliang Guan 2022-05-13 14:58:52 +08:00
parent 65e9e97252
commit 219e9553e7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/util/src/tqueue.c
View File

@ -28,7 +28,7 @@ typedef struct STaosQnode {
} STaosQnode; } STaosQnode;
typedef struct STaosQueue { typedef struct STaosQueue {
int32_t memOfItems; int64_t memOfItems;
int32_t numOfItems; int32_t numOfItems;
int32_t threadId; int32_t threadId;
STaosQnode *head; STaosQnode *head;
@ -125,9 +125,9 @@ int32_t taosQueueItemSize(STaosQueue *queue) {
return numOfItems; return numOfItems;
} }
int32_t taosQueueMemorySize(STaosQueue *queue) { int64_t taosQueueMemorySize(STaosQueue *queue) {
taosThreadMutexLock(&queue->mutex); taosThreadMutexLock(&queue->mutex);
int32_t memOfItems = queue->memOfItems; int64_t memOfItems = queue->memOfItems;
taosThreadMutexUnlock(&queue->mutex); taosThreadMutexUnlock(&queue->mutex);
return memOfItems; return memOfItems;
} }