From aa2f3b2a9968bb4928463bdae05fb026d16b60bb Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 04 十二月 2020 19:07:01 +0800
Subject: [PATCH] 固定bus key
---
src/queue/hashtable.c | 12 +++++-------
1 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/src/queue/hashtable.c b/src/queue/hashtable.c
index ed3fe34..03b64b6 100755
--- a/src/queue/hashtable.c
+++ b/src/queue/hashtable.c
@@ -23,6 +23,8 @@
static size_t hashcode(int key);
+static struct timespec TIMEOUT = {1, 0};
+
void hashtable_init(hashtable_t *hashtable )
{
@@ -179,12 +181,9 @@
/*printf("hashfun = %ld\n", code);*/
}
-
-
-
void *hashtable_get(hashtable_t *hashtable, int key) {
- struct timespec timeout = {1, 0};
- if (SemUtil::dec_timeout(hashtable->mutex, &timeout) != 0) {
+
+ if (SemUtil::dec_timeout(hashtable->mutex, &TIMEOUT) != 0) {
SemUtil::inc(hashtable->mutex);
SemUtil::dec(hashtable->mutex);
}
@@ -317,8 +316,7 @@
int hashtable_alloc_key(hashtable_t *hashtable) {
int key = START_KEY;
- struct timespec timeout = {1, 0};
- if (SemUtil::dec_timeout(hashtable->wlock, &timeout) != 0) {
+ if (SemUtil::dec_timeout(hashtable->wlock, &TIMEOUT) != 0) {
SemUtil::inc(hashtable->wlock);
SemUtil::dec(hashtable->wlock);
}
--
Gitblit v1.8.0