summaryrefslogtreecommitdiff
path: root/src/io_thread.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-09-20 10:47:27 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-09-20 10:47:27 +0200
commitf99b8fc921bc0e6aa55276d8c55e43c9d7f4375a (patch)
tree2201248b8fb13ec7d2831b74b349a61fd1e07fa4 /src/io_thread.cpp
parent50a8b9ea0c4a819073b46449dee8fc839b837ae5 (diff)
receiving side of signaler virtualised
Diffstat (limited to 'src/io_thread.cpp')
-rw-r--r--src/io_thread.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/io_thread.cpp b/src/io_thread.cpp
index b6521e9..a90876c 100644
--- a/src/io_thread.cpp
+++ b/src/io_thread.cpp
@@ -104,7 +104,7 @@ int zmq::io_thread_t::get_load ()
void zmq::io_thread_t::in_event ()
{
// Find out which threads are sending us commands.
- fd_signaler_t::signals_t signals = signaler.check ();
+ uint64_t signals = signaler.check ();
zmq_assert (signals);
// Iterate through all the threads in the process and find out
@@ -112,7 +112,7 @@ void zmq::io_thread_t::in_event ()
int slot_count = thread_slot_count ();
for (int source_thread_slot = 0;
source_thread_slot != slot_count; source_thread_slot++) {
- if (signals & (fd_signaler_t::signals_t (1) << source_thread_slot)) {
+ if (signals & (uint64_t (1) << source_thread_slot)) {
// Read all the commands from particular thread.
command_t cmd;