From 7032fedd41386f8a0b779d234620b473d978f889 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 17 七月 2020 17:43:18 +0800
Subject: [PATCH] req_rep finished
---
queue/sem_util.c | 18 ++++++++++++++----
1 files changed, 14 insertions(+), 4 deletions(-)
diff --git a/queue/sem_util.c b/queue/sem_util.c
index 6ed43fa..ceedac3 100644
--- a/queue/sem_util.c
+++ b/queue/sem_util.c
@@ -79,8 +79,10 @@
sops.sem_flg = 0;
while (semop(semId, &sops, 1) == -1)
- if (errno != EINTR )
+ if (errno != EINTR ) {
+ err_msg(errno, "SemUtil::dec");
return -1;
+ }
return 0;
}
@@ -94,8 +96,10 @@
sops.sem_flg = IPC_NOWAIT;
while (semop(semId, &sops, 1) == -1)
- if (errno != EINTR )
+ if (errno != EINTR ) {
+ err_msg(errno, "SemUtil::dec_nowait");
return -1;
+ }
return 0;
}
@@ -109,8 +113,10 @@
sops.sem_flg = 0;
while ( semtimedop(semId, &sops, 1, timeout) == -1)
- if (errno != EINTR )
+ if (errno != EINTR ) {
+ err_msg(errno, "SemUtil::dec_timeout");
return -1;
+ }
return 0;
}
@@ -126,7 +132,11 @@
sops.sem_op = 1;
sops.sem_flg = 0;
- return semop(semId, &sops, 1);
+ int rv = semop(semId, &sops, 1);
+ if(rv == -1) {
+ err_msg(errno, "SemUtil::inc");
+ }
+ return rv;
}
void SemUtil::remove(int semid) {
--
Gitblit v1.8.0