summaryrefslogtreecommitdiff
path: root/src/app_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/app_thread.cpp
parent43fa72b7ee6b6d97b84a555ce8902cee855aeb72 (diff)
dispatcher renamed to context
Diffstat (limited to 'src/app_thread.cpp')
-rw-r--r--src/app_thread.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/app_thread.cpp b/src/app_thread.cpp
index 2406dbd..9cc61c7 100644
--- a/src/app_thread.cpp
+++ b/src/app_thread.cpp
@@ -26,7 +26,7 @@
#endif
#include "app_thread.hpp"
-#include "dispatcher.hpp"
+#include "context.hpp"
#include "err.hpp"
#include "session.hpp"
#include "pipe.hpp"
@@ -51,8 +51,8 @@
#define ZMQ_DELAY_COMMANDS
#endif
-zmq::app_thread_t::app_thread_t (dispatcher_t *dispatcher_, int thread_slot_) :
- object_t (dispatcher_, thread_slot_),
+zmq::app_thread_t::app_thread_t (context_t *context_, int thread_slot_) :
+ object_t (context_, thread_slot_),
tid (0),
last_processing_time (0)
{
@@ -213,7 +213,7 @@ void zmq::app_thread_t::process_commands (bool block_)
for (int i = 0; i != thread_slot_count (); i++) {
if (signals & (ypollset_t::signals_t (1) << i)) {
command_t cmd;
- while (dispatcher->read (i, get_thread_slot (), &cmd))
+ while (context->read (i, get_thread_slot (), &cmd))
cmd.destination->process_command (cmd);
}
}