diff options
| author | Martin Sustrik <sustrik@250bpm.com> | 2010-09-09 08:25:00 +0200 |
|---|---|---|
| committer | Martin Sustrik <sustrik@250bpm.com> | 2010-09-09 08:25:00 +0200 |
| commit | a68e6739f4248e25a0f9a64c89729f55dfacb842 (patch) | |
| tree | 4686061e52137cfa373587162f59536cd3f55d32 /src/ctx.hpp | |
| parent | 47e87b7e4b8dd6a0cfbc1f30ffcb06edfa83c853 (diff) | |
when no I/O threads are available error is raised instead of assertion
Diffstat (limited to 'src/ctx.hpp')
| -rw-r--r-- | src/ctx.hpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/ctx.hpp b/src/ctx.hpp index 360ca0e..98b4f81 100644 --- a/src/ctx.hpp +++ b/src/ctx.hpp @@ -65,8 +65,9 @@ namespace zmq void send_command (uint32_t slot_, const command_t &command_); // Returns the I/O thread that is the least busy at the moment. - // Taskset specifies which I/O threads are eligible (0 = all). - class io_thread_t *choose_io_thread (uint64_t taskset_); + // Affinity specifies which I/O threads are eligible (0 = all). + // Returns NULL is no I/O thread is available. + class io_thread_t *choose_io_thread (uint64_t affinity_); // Management of inproc endpoints. int register_endpoint (const char *addr_, class socket_base_t *socket_); |