WIP: Socket migration between threads, new zmq_close() semantics

Sockets may now be migrated between OS threads; sockets may not be used by
more than one thread at any time. To migrate a socket to another thread the
caller must ensure that a full memory barrier is called before using the
socket from the target thread.

The new zmq_close() semantics implement the behaviour discussed at:

http://lists.zeromq.org/pipermail/zeromq-dev/2010-July/004244.html

Specifically, zmq_close() is now deterministic and while it still returns
immediately, it does not discard any data that may still be queued for
sending. Further, zmq_term() will now block until all outstanding data has
been sent.

TODO: Many bugs have been introduced, needs testing. Further, SO_LINGER or
an equivalent mechanism (possibly a configurable timeout to zmq_term())
needs to be implemented.

1 files changed, 7 insertions, 7 deletions

diff --git a/src/object.hpp b/src/object.hpp
index a38b0a6..c75a95a 100644
--- a/src/object.hpp
+++ b/src/object.hpp
@@ -32,18 +32,14 @@ namespace zmq
     {
     public:
 
-        object_t (class ctx_t *ctx_, uint32_t thread_slot_);
+        object_t (class ctx_t *ctx_, uint32_t slot_);
         object_t (object_t *parent_);
         virtual ~object_t ();
 
-        uint32_t get_thread_slot ();
+        uint32_t get_slot ();
         ctx_t *get_ctx ();
         void process_command (struct command_t &cmd_);
 
-        //  Allow pipe to access corresponding context functions.
-        void register_pipe (class pipe_t *pipe_);
-        void unregister_pipe (class pipe_t *pipe_);
-
     protected:
 
         //  Using following function, socket is able to access global
@@ -55,6 +51,10 @@ namespace zmq
         //  Chooses least loaded I/O thread.
         class io_thread_t *choose_io_thread (uint64_t taskset_);
 
+        //  Zombify particular socket. In other words, pass the ownership to
+        //  the context.
+        void zombify (class socket_base_t *socket_);
+
         //  Derived object can use these functions to send commands
         //  to other objects.
         void send_stop ();
@@ -105,7 +105,7 @@ namespace zmq
         class ctx_t *ctx;
 
         //  Slot ID of the thread the object belongs to.
-        uint32_t thread_slot;
+        uint32_t slot;
 
         void send_command (command_t &cmd_);