summaryrefslogtreecommitdiff
path: root/src/io_thread.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-06 10:47:34 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-06 10:47:34 +0200
commitb8b4acef4c2ba1a169ce84c1fb4c70a5676ebba3 (patch)
treead29407ed2db35765fda969e297f7f0efd9ff39a /src/io_thread.cpp
parent43fa72b7ee6b6d97b84a555ce8902cee855aeb72 (diff)
dispatcher renamed to context
Diffstat (limited to 'src/io_thread.cpp')
-rw-r--r--src/io_thread.cpp8
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);
}
}