ZMQ_REENTRANT functionality removed

It doesn't play well with multipart messages.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

1 files changed, 1 insertions, 20 deletions

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.