From 8df1ff06b931b0e414ed435a033f508867b345b7 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期二, 23 二月 2021 14:40:38 +0800
Subject: [PATCH] update
---
src/socket/shm_socket.cpp | 21 ++++++---------------
1 files changed, 6 insertions(+), 15 deletions(-)
diff --git a/src/socket/shm_socket.cpp b/src/socket/shm_socket.cpp
index d8304fd..f5e1388 100644
--- a/src/socket/shm_socket.cpp
+++ b/src/socket/shm_socket.cpp
@@ -537,9 +537,9 @@
if( sockt->queue != NULL)
goto LABEL_PUSH;
- if(hashtable_get_queue_count(hashtable) > QUEUE_COUNT_LIMIT) {
- return EBUS_EXCEED_LIMIT;
- }
+ // if(hashtable_get_queue_count(hashtable) > QUEUE_COUNT_LIMIT) {
+ // return EBUS_EXCEED_LIMIT;
+ // }
{
if ((rv = pthread_mutex_lock(&(sockt->mutex))) != 0)
@@ -614,9 +614,9 @@
if( sockt->queue != NULL)
goto LABEL_POP;
- if(hashtable_get_queue_count(hashtable) > QUEUE_COUNT_LIMIT) {
- return EBUS_EXCEED_LIMIT;
- }
+ // if(hashtable_get_queue_count(hashtable) > QUEUE_COUNT_LIMIT) {
+ // return EBUS_EXCEED_LIMIT;
+ // }
{
if ((rv = pthread_mutex_lock(&(sockt->mutex))) != 0)
@@ -646,15 +646,6 @@
LABEL_POP:
- // 妫�鏌ey鏍囪鐨勭姸鎬�
- // auto shmQueueMapIter = shmQueueStMap->find(sockt->key);
- // if(shmQueueMapIter != shmQueueStMap->end()) {
- // stRecord = shmQueueMapIter->second;
- // if(stRecord.status = SHM_QUEUE_ST_CLOSED) {
- // // key瀵瑰簲鐨勭姸鎬佹槸鍏抽棴鐨�
- // goto ERR_CLOSED;
- // }
- // }
rv = sockt->queue->pop(recvpak, timeout, flag);
if(rv != 0) {
--
Gitblit v1.8.0