generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-26 02:18:06 +01:00
Code Issues Projects Releases Wiki Activity

receiving side of signaler virtualised

Browse Source
This commit is contained in:
Martin Sustrik
2009-09-20 10:47:27 +02:00
parent 50a8b9ea0c
commit f99b8fc921
7 changed files with 70 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/io_thread.cpp
View File

@@ -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;