Commit de383840 authored by Martin Sustrik's avatar Martin Sustrik

Testing for errors from pthread_* functions fixed

pthread_* functions return the error number rather than
setting errno. This was not accounter for till now.
Signed-off-by: 's avatarMartin Sustrik <sustrik@250bpm.com>
parent 4f4cc732
...@@ -66,7 +66,7 @@ extern "C" ...@@ -66,7 +66,7 @@ extern "C"
int rc = sigfillset (&signal_set); int rc = sigfillset (&signal_set);
errno_assert (rc == 0); errno_assert (rc == 0);
rc = pthread_sigmask (SIG_BLOCK, &signal_set, NULL); rc = pthread_sigmask (SIG_BLOCK, &signal_set, NULL);
errno_assert (rc == 0); posix_assert (rc);
#endif #endif
zmq::thread_t *self = (zmq::thread_t*) arg_; zmq::thread_t *self = (zmq::thread_t*) arg_;
...@@ -80,13 +80,13 @@ void zmq::thread_t::start (thread_fn *tfn_, void *arg_) ...@@ -80,13 +80,13 @@ void zmq::thread_t::start (thread_fn *tfn_, void *arg_)
tfn = tfn_; tfn = tfn_;
arg =arg_; arg =arg_;
int rc = pthread_create (&descriptor, NULL, thread_routine, this); int rc = pthread_create (&descriptor, NULL, thread_routine, this);
errno_assert (rc == 0); posix_assert (rc);
} }
void zmq::thread_t::stop () void zmq::thread_t::stop ()
{ {
int rc = pthread_join (descriptor, NULL); int rc = pthread_join (descriptor, NULL);
errno_assert (rc == 0); posix_assert (rc);
} }
#endif #endif
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment