diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-04-29 20:34:48 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-04-29 20:34:48 +0200 |
commit | ae93ed318a450d6d763a5f629d478467f7362b07 (patch) | |
tree | 096abe5592237e31ab4d85d71b567e42d44889d4 /src/object.hpp | |
parent | 1ffc6dd41f2e2ce45c67f3fe08780c5a09cf667d (diff) |
signaler rewritten in such a way that any number (>64) of threads can be used
Diffstat (limited to 'src/object.hpp')
-rw-r--r-- | src/object.hpp | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/object.hpp b/src/object.hpp index f29342e..b29c6b8 100644 --- a/src/object.hpp +++ b/src/object.hpp @@ -32,11 +32,11 @@ namespace zmq { public: - object_t (class dispatcher_t *dispatcher_, int thread_slot_); + object_t (class dispatcher_t *dispatcher_, uint32_t thread_slot_); object_t (object_t *parent_); virtual ~object_t (); - int get_thread_slot (); + uint32_t get_thread_slot (); dispatcher_t *get_dispatcher (); void process_command (struct command_t &cmd_); @@ -52,9 +52,6 @@ namespace zmq void unregister_endpoints (class socket_base_t *socket_); class socket_base_t *find_endpoint (const char *addr_); - // Returns number of thead slots in the dispatcher. - int thread_slot_count (); - // Chooses least loaded I/O thread. class io_thread_t *choose_io_thread (uint64_t taskset_); @@ -106,7 +103,7 @@ namespace zmq class dispatcher_t *dispatcher; // Slot ID of the thread the object belongs to. - int thread_slot; + uint32_t thread_slot; private: |