diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-09-20 10:47:27 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-09-20 10:47:27 +0200 |
commit | f99b8fc921bc0e6aa55276d8c55e43c9d7f4375a (patch) | |
tree | 2201248b8fb13ec7d2831b74b349a61fd1e07fa4 /src/app_thread.cpp | |
parent | 50a8b9ea0c4a819073b46449dee8fc839b837ae5 (diff) |
receiving side of signaler virtualised
Diffstat (limited to 'src/app_thread.cpp')
-rw-r--r-- | src/app_thread.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/app_thread.cpp b/src/app_thread.cpp index c152fc8..8c83313 100644 --- a/src/app_thread.cpp +++ b/src/app_thread.cpp @@ -84,7 +84,7 @@ bool zmq::app_thread_t::make_current () void zmq::app_thread_t::process_commands (bool block_, bool throttle_) { - ypollset_t::signals_t signals; + uint64_t signals; if (block_) signals = pollset.poll (); else { @@ -127,7 +127,7 @@ void zmq::app_thread_t::process_commands (bool block_, bool throttle_) // Traverse all the possible sources of commands and process // all the commands from all of them. for (int i = 0; i != thread_slot_count (); i++) { - if (signals & (ypollset_t::signals_t (1) << i)) { + if (signals & (uint64_t (1) << i)) { command_t cmd; while (dispatcher->read (i, get_thread_slot (), &cmd)) cmd.destination->process_command (cmd); |