Added parameter to set the max number of sockets.

This commit is contained in:
evgeny 2014-03-03 19:21:18 +04:00
parent 2358037407
commit 1b7948c6d9

View File

@ -254,7 +254,7 @@ namespace zmq
} }
inline explicit context_t (int io_threads_) inline explicit context_t (int io_threads_, int max_sockets_ = 1024)
{ {
ptr = zmq_ctx_new (); ptr = zmq_ctx_new ();
if (ptr == NULL) if (ptr == NULL)
@ -262,6 +262,9 @@ namespace zmq
int rc = zmq_ctx_set (ptr, ZMQ_IO_THREADS, io_threads_); int rc = zmq_ctx_set (ptr, ZMQ_IO_THREADS, io_threads_);
ZMQ_ASSERT (rc == 0); ZMQ_ASSERT (rc == 0);
rc = zmq_ctx_set (ptr, ZMQ_MAX_SOCKETS, max_sockets_);
ZMQ_ASSERT (rc == 0);
} }
#ifdef ZMQ_HAS_RVALUE_REFS #ifdef ZMQ_HAS_RVALUE_REFS