From a0d548e6cdef36a8dae6e6834252475728bf8583 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Thu, 16 Feb 2012 10:28:49 +0900 Subject: ZMQ_REENTRANT functionality removed It doesn't play well with multipart messages. Signed-off-by: Martin Sustrik --- src/ctx.cpp | 21 +-------------------- 1 file changed, 1 insertion(+), 20 deletions(-) (limited to 'src/ctx.cpp') diff --git a/src/ctx.cpp b/src/ctx.cpp index 789cdc2..98d3b86 100644 --- a/src/ctx.cpp +++ b/src/ctx.cpp @@ -47,8 +47,7 @@ xs::ctx_t::ctx_t (uint32_t io_threads_) : monitor (NULL), log_socket (NULL), max_sockets (512), - io_thread_count (io_threads_), - reentrant (false) + io_thread_count (io_threads_) { } @@ -154,16 +153,6 @@ int xs::ctx_t::setctxopt (int option_, const void *optval_, size_t optvallen_) max_sockets = *((int*) optval_); opt_sync.unlock (); break; - case XS_REENTRANT: - if (optvallen_ != sizeof (int) || (*((int*) optval_) != 0 && - *((int*) optval_) != 1)) { - errno = EINVAL; - return -1; - } - opt_sync.lock (); - reentrant = (*((int*) optval_) ? true : false); - opt_sync.unlock (); - break; default: errno = EINVAL; return -1; @@ -396,14 +385,6 @@ void xs::ctx_t::publish_logs (const char *text_) log_sync.unlock (); } -bool xs::ctx_t::is_reentrant () -{ - opt_sync.lock (); - bool ret = reentrant; - opt_sync.unlock (); - return ret; -} - // The last used socket ID, or 0 if no socket was used so far. Note that this // is a global variable. Thus, even sockets created in different contexts have // unique IDs. -- cgit v1.2.3