diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-09-02 10:22:23 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-09-02 10:22:23 +0200 |
commit | 6a5120b1f1c48d19b777f76ac756b00fb624d110 (patch) | |
tree | 33853b4f9aaaf88bcb82a53fe3607d91d7a06ab1 /src/session.hpp | |
parent | 72fdf47d16c8d3ecd9da657b4649978e414d775c (diff) |
python extension & perf tests
Diffstat (limited to 'src/session.hpp')
-rw-r--r-- | src/session.hpp | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/session.hpp b/src/session.hpp index 46699cf..195bdca 100644 --- a/src/session.hpp +++ b/src/session.hpp @@ -37,13 +37,6 @@ namespace zmq session_t (object_t *parent_, socket_base_t *owner_, const char *name_, const options_t &options_); - void set_inbound_pipe (class reader_t *pipe_); - void set_outbound_pipe (class writer_t *pipe_); - - private: - - ~session_t (); - // i_inout interface implementation. bool read (::zmq_msg_t *msg_); bool write (::zmq_msg_t *msg_); @@ -51,10 +44,16 @@ namespace zmq void detach (); // i_endpoint interface implementation. + void attach_inpipe (class reader_t *pipe_); + void attach_outpipe (class writer_t *pipe_); void revive (class reader_t *pipe_); void detach_inpipe (class reader_t *pipe_); void detach_outpipe (class writer_t *pipe_); + private: + + ~session_t (); + // Handlers for incoming commands. void process_plug (); void process_unplug (); |