summaryrefslogtreecommitdiff
path: root/src/zmq.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-09-20 10:14:21 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-09-20 10:14:21 +0200
commit50a8b9ea0c4a819073b46449dee8fc839b837ae5 (patch)
treea1effc887ebb0e824959b114dd0ed67e788d0507 /src/zmq.cpp
parentedecf75b611cf0e6b1c2658846cff013434edad4 (diff)
'flags' parameter added to zmq_init
Diffstat (limited to 'src/zmq.cpp')
-rw-r--r--src/zmq.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/zmq.cpp b/src/zmq.cpp
index c567b09..36f30eb 100644
--- a/src/zmq.cpp
+++ b/src/zmq.cpp
@@ -173,17 +173,17 @@ int zmq_msg_type (zmq_msg_t *msg_)
return (((const unsigned char*) msg_->content) - offset);
}
-void *zmq_init (int app_threads_, int io_threads_)
+void *zmq_init (int app_threads_, int io_threads_, int flags_)
{
// There should be at least a single thread managed by the dispatcher.
- if (app_threads_ < 0 || io_threads_ < 0 ||
- app_threads_ + io_threads_ == 0) {
+ if (app_threads_ <= 0 || io_threads_ <= 0 ||
+ app_threads_ > 63 || io_threads_ > 63) {
errno = EINVAL;
return NULL;
}
zmq::dispatcher_t *dispatcher = new zmq::dispatcher_t (app_threads_,
- io_threads_);
+ io_threads_, flags_);
zmq_assert (dispatcher);
return (void*) dispatcher;
}