diff options
Diffstat (limited to 'src/object.hpp')
-rw-r--r-- | src/object.hpp | 8 |
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 (); |