summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMartin Hurton <hurtonm@gmail.com>2009-08-31 11:31:32 +0200
committerMartin Hurton <hurtonm@gmail.com>2009-08-31 13:31:01 +0200
commit0aacee389fdb553ef9925d0135eefcb501a67726 (patch)
tree33e5bd2a58eabe4f5a8a2cdbe1f11b5147ef7490 /src
parent72fdf47d16c8d3ecd9da657b4649978e414d775c (diff)
POSIX threads don't use errno to report errors
Fix simple_semaphore to follow POSIX threads convention for reporting errors.
Diffstat (limited to 'src')
-rw-r--r--src/err.hpp9
-rw-r--r--src/simple_semaphore.hpp12
2 files changed, 11 insertions, 10 deletions
diff --git a/src/err.hpp b/src/err.hpp
index 3854d8a..c1b2916 100644
--- a/src/err.hpp
+++ b/src/err.hpp
@@ -22,6 +22,7 @@
#include <assert.h>
#include <errno.h>
+#include <string.h>
#include <stdlib.h>
#include <stdio.h>
@@ -81,10 +82,10 @@ namespace zmq
}} while (false)
// Provides convenient way to check for POSIX errors.
-#define posix_assert(x) do {\
-fprintf (stderr, "%s (%s:%d)\n", strerror (x), __FILE__, __LINE__);\
-abort ();\
-} while (false)
+#define posix_assert(x) do { if ((x)) {\
+ fprintf (stderr, "%s (%s:%d)\n", strerror (x), __FILE__, __LINE__);\
+ abort ();\
+}} while (false)
// Provides convenient way to check for errors from getaddrinfo.
#define gai_assert(x) do { if (x) {\
diff --git a/src/simple_semaphore.hpp b/src/simple_semaphore.hpp
index b48a7f5..209ccb4 100644
--- a/src/simple_semaphore.hpp
+++ b/src/simple_semaphore.hpp
@@ -53,32 +53,32 @@ namespace zmq
inline simple_semaphore_t ()
{
int rc = pthread_mutex_init (&mutex, NULL);
- errno_assert (rc == 0);
+ posix_assert (rc);
rc = pthread_mutex_lock (&mutex);
- errno_assert (rc == 0);
+ posix_assert (rc);
}
// Destroy the semaphore.
inline ~simple_semaphore_t ()
{
int rc = pthread_mutex_unlock (&mutex);
- errno_assert (rc == 0);
+ posix_assert (rc);
rc = pthread_mutex_destroy (&mutex);
- errno_assert (rc == 0);
+ posix_assert (rc);
}
// Wait for the semaphore.
inline void wait ()
{
int rc = pthread_mutex_lock (&mutex);
- errno_assert (rc == 0);
+ posix_assert (rc);
}
// Post the semaphore.
inline void post ()
{
int rc = pthread_mutex_unlock (&mutex);
- errno_assert (rc == 0);
+ posix_assert (rc);
}
private: