diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-04-29 17:20:23 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-04-29 17:20:23 +0200 |
commit | c193fd146661b39027c5e3fa0776dcdf8c6af5e2 (patch) | |
tree | 0ec001869a7e6519cc1b910de0b26c46308eba96 /src/dispatcher.cpp | |
parent | 7cb076e56a18cb76c49f17bd34bc73c11e01b705 (diff) |
lock-free polling removed; ZMQ_POLL flag removed
Diffstat (limited to 'src/dispatcher.cpp')
-rw-r--r-- | src/dispatcher.cpp | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/dispatcher.cpp b/src/dispatcher.cpp index a1154de..1e11619 100644 --- a/src/dispatcher.cpp +++ b/src/dispatcher.cpp @@ -33,8 +33,7 @@ #include "windows.h" #endif -zmq::dispatcher_t::dispatcher_t (int app_threads_, int io_threads_, - int flags_) : +zmq::dispatcher_t::dispatcher_t (int app_threads_, int io_threads_) : sockets (0), terminated (false) { @@ -53,7 +52,7 @@ zmq::dispatcher_t::dispatcher_t (int app_threads_, int io_threads_, for (int i = 0; i != app_threads_; i++) { app_thread_info_t info; info.associated = false; - info.app_thread = new (std::nothrow) app_thread_t (this, i, flags_); + info.app_thread = new (std::nothrow) app_thread_t (this, i); zmq_assert (info.app_thread); app_threads.push_back (info); signalers.push_back (info.app_thread->get_signaler ()); @@ -62,7 +61,7 @@ zmq::dispatcher_t::dispatcher_t (int app_threads_, int io_threads_, // Create I/O thread objects. for (int i = 0; i != io_threads_; i++) { io_thread_t *io_thread = new (std::nothrow) io_thread_t (this, - i + app_threads_, flags_); + i + app_threads_); zmq_assert (io_thread); io_threads.push_back (io_thread); signalers.push_back (io_thread->get_signaler ()); |