From b63ce299ddacea2ad487dc635926ed52ff422c20 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 03 八月 2020 11:40:17 +0800
Subject: [PATCH] add timeout nowait

---
 src/util/sem_util.c |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/util/sem_util.c b/src/util/sem_util.c
index 1dcf00d..c73d1e1 100644
--- a/src/util/sem_util.c
+++ b/src/util/sem_util.c
@@ -72,7 +72,7 @@
 
 /* Reserve semaphore - decrement it by 1 */
 int SemUtil::dec(int semId) {
-logger.debug("%d: SemUtil::dec\n", semId);
+// logger.debug("%d: SemUtil::dec\n", semId);
   struct sembuf sops;
 
   sops.sem_num = 0;
@@ -81,7 +81,7 @@
 
   while (semop(semId, &sops, 1) == -1)
     if (errno != EINTR) {
-      err_msg(errno, "SemUtil::dec");
+     // err_msg(errno, "SemUtil::dec");
       return -1;
     }
 
@@ -97,7 +97,7 @@
 
   while (semop(semId, &sops, 1) == -1)
     if (errno != EINTR) {
-      err_msg(errno, "SemUtil::dec_nowait");
+     // err_msg(errno, "SemUtil::dec_nowait");
       return -1;
     }
 
@@ -113,7 +113,7 @@
 
   while (semtimedop(semId, &sops, 1, timeout) == -1)
     if (errno != EINTR) {
-      err_msg(errno, "SemUtil::dec_timeout");
+      //err_msg(errno, "SemUtil::dec_timeout");
       return -1;
     }
 

--
Gitblit v1.8.0