pipe deallocation added

1 files changed, 8 insertions, 0 deletions

diff --git a/src/object.hpp b/src/object.hpp
index 0dbac24..8ce569e 100644
--- a/src/object.hpp
+++ b/src/object.hpp
@@ -42,6 +42,10 @@ namespace zmq
         int get_thread_slot ();
         void process_command (struct command_t &cmd_);
 
+        //  Allow pipe to access corresponding dispatcher functions.
+        void register_pipe (class pipe_t *pipe_);
+        void unregister_pipe (class pipe_t *pipe_);
+
     protected:
 
         //  Derived object can use following functions to interact with
@@ -60,6 +64,8 @@ namespace zmq
         void send_bind (object_t *destination_, class owned_t *session_,
             class reader_t *in_pipe_, class writer_t *out_pipe_);
         void send_revive (class object_t *destination_);
+        void send_pipe_term (class writer_t *destination_);
+        void send_pipe_term_ack (class reader_t *destination_);
         void send_term_req (class socket_base_t *destination_,
             class owned_t *object_);
         void send_term (class owned_t *destination_);
@@ -74,6 +80,8 @@ namespace zmq
         virtual void process_bind (class owned_t *session_,
             class reader_t *in_pipe_, class writer_t *out_pipe_);
         virtual void process_revive ();
+        virtual void process_pipe_term ();
+        virtual void process_pipe_term_ack ();
         virtual void process_term_req (class owned_t *object_);
         virtual void process_term ();
         virtual void process_term_ack ();