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.hpp | |
parent | 7cb076e56a18cb76c49f17bd34bc73c11e01b705 (diff) |
lock-free polling removed; ZMQ_POLL flag removed
Diffstat (limited to 'src/dispatcher.hpp')
-rw-r--r-- | src/dispatcher.hpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/dispatcher.hpp b/src/dispatcher.hpp index 1cd5207..6648f5d 100644 --- a/src/dispatcher.hpp +++ b/src/dispatcher.hpp @@ -25,7 +25,7 @@ #include <map> #include <string> -#include "i_signaler.hpp" +#include "fd_signaler.hpp" #include "ypipe.hpp" #include "command.hpp" #include "config.hpp" @@ -51,7 +51,7 @@ namespace zmq // Create the dispatcher object. Matrix of pipes to communicate between // each socket and each I/O thread is created along with appropriate // signalers. - dispatcher_t (int app_threads_, int io_threads_, int flags_); + dispatcher_t (int app_threads_, int io_threads_); // This function is called when user invokes zmq_term. If there are // no more sockets open it'll cause all the infrastructure to be shut @@ -125,7 +125,7 @@ namespace zmq io_threads_t io_threads; // Signalers for both application and I/O threads. - std::vector <i_signaler*> signalers; + std::vector <fd_signaler_t*> signalers; // Pipe to hold the commands. typedef ypipe_t <command_t, true, |