From 567e7bba26bb8fe485be6c2ddfaaf8ab77eb6141 Mon Sep 17 00:00:00 2001
From: looper3339 <736321739@qq.com>
Date: 星期一, 09 八月 2021 21:46:05 +0800
Subject: [PATCH] fjt fix req-rep error
---
src/queue/shm_queue.h | 4 ----
1 files changed, 0 insertions(+), 4 deletions(-)
diff --git a/src/queue/shm_queue.h b/src/queue/shm_queue.h
index 0921af3..74b9b33 100644
--- a/src/queue/shm_queue.h
+++ b/src/queue/shm_queue.h
@@ -87,19 +87,15 @@
template <typename ELEM_T>
bool SHMQueue<ELEM_T>::bind(int key, bool force) {
-
- hashtable_lock(hashtable);
void *tmp_ptr = hashtable_get(hashtable, key);
if (tmp_ptr == NULL || tmp_ptr == (void *)1 || force) {
queue = new LockFreeQueue<ELEM_T, SHM_Allocator>(mqsize);
hashtable_put(hashtable, key, (void *)queue);
mkey = key;
owner = true;
- hashtable_unlock(hashtable);
return true;
}
- hashtable_unlock(hashtable);
return false;
}
--
Gitblit v1.8.0