diff options
Diffstat (limited to 'src/io_thread.cpp')
| -rw-r--r-- | src/io_thread.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/io_thread.cpp b/src/io_thread.cpp index 045627c..162ed4c 100644 --- a/src/io_thread.cpp +++ b/src/io_thread.cpp @@ -29,13 +29,13 @@ #include "select.hpp" #include "devpoll.hpp" #include "kqueue.hpp" -#include "dispatcher.hpp" +#include "context.hpp" #include "session.hpp" #include "simple_semaphore.hpp" #include "session.hpp" -zmq::io_thread_t::io_thread_t (dispatcher_t *dispatcher_, int thread_slot_) : - object_t (dispatcher_, thread_slot_) +zmq::io_thread_t::io_thread_t (context_t *context_, int thread_slot_) : + object_t (context_, thread_slot_) { #if defined ZMQ_FORCE_SELECT poller = new select_t; @@ -131,7 +131,7 @@ void zmq::io_thread_t::in_event () // Read all the commands from particular thread. command_t cmd; - while (dispatcher->read (source_thread_slot, thread_slot, &cmd)) + while (context->read (source_thread_slot, thread_slot, &cmd)) cmd.destination->process_command (cmd); } } |