3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-10 07:56:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

choose_io_thread: do not assert when no I/O thread was chosen

Browse Source
This commit is contained in:
Martin Hurton 2012-03-22 06:55:12 +01:00
parent f944336ee0
commit e56f698023
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/ctx.cpp
View File

@ -278,18 +278,17 @@ zmq::io_thread_t *zmq::ctx_t::choose_io_thread (uint64_t affinity_)
// Find the I/O thread with minimum load. // Find the I/O thread with minimum load.
int min_load = -1; int min_load = -1;
io_threads_t::size_type result = 0; io_thread_t *selected_io_thread = NULL;
for (io_threads_t::size_type i = 0; i != io_threads.size (); i++) { for (io_threads_t::size_type i = 0; i != io_threads.size (); i++) {
if (!affinity_ || (affinity_ & (uint64_t (1) << i))) { if (!affinity_ || (affinity_ & (uint64_t (1) << i))) {
int load = io_threads [i]->get_load (); int load = io_threads [i]->get_load ();
if (min_load == -1 || load < min_load) { if (selected_io_thread == NULL || load < min_load) {
min_load = load; min_load = load;
result = i; selected_io_thread = io_threads [i];
} }
} }
} }
zmq_assert (min_load != -1); return selected_io_thread;
return io_threads [result];
} }
int zmq::ctx_t::register_endpoint (const char *addr_, endpoint_t &endpoint_) int zmq::ctx_t::register_endpoint (const char *addr_, endpoint_t &endpoint_)