summaryrefslogtreecommitdiff
path: root/src/object.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-20 11:32:23 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-20 11:32:23 +0200
commita801b6d8b37557ccfb53030dca22f89a3f99b59c (patch)
treed0c41834928aaf1776645e4eb2c2368b317338f6 /src/object.hpp
parent131f2e309668d1e64cfcb4aeb869665d8018bcfe (diff)
couple of bugs in shutdown mechanism fixed
Diffstat (limited to 'src/object.hpp')
-rw-r--r--src/object.hpp19
1 files changed, 12 insertions, 7 deletions
diff --git a/src/object.hpp b/src/object.hpp
index 7357549..02a071a 100644
--- a/src/object.hpp
+++ b/src/object.hpp
@@ -49,20 +49,25 @@ namespace zmq
// Derived object can use these functions to send commands
// to other objects.
void send_stop ();
- void send_plug (object_t *destination_);
- void send_own (object_t *destination_, object_t *object_);
+ void send_plug (class owned_t *destination_);
+ void send_own (class socket_base_t *destination_,
+ class owned_t *object_);
+ void send_attach (class session_t *destination_,
+ class zmq_engine_t *engine_);
void send_bind (object_t *destination_);
- void send_term_req (object_t *destination_, object_t *object_);
- void send_term (object_t *destination_);
- void send_term_ack (object_t *destination_);
+ void send_term_req (class socket_base_t *destination_,
+ class owned_t *object_);
+ void send_term (class owned_t *destination_);
+ void send_term_ack (class socket_base_t *destination_);
// These handlers can be overloaded by the derived objects. They are
// called when command arrives from another thread.
virtual void process_stop ();
virtual void process_plug ();
- virtual void process_own (object_t *object_);
+ virtual void process_own (class owned_t *object_);
+ virtual void process_attach (class zmq_engine_t *engine_);
virtual void process_bind ();
- virtual void process_term_req (object_t *object_);
+ virtual void process_term_req (class owned_t *object_);
virtual void process_term ();
virtual void process_term_ack ();