diff options
Diffstat (limited to 'src/session.cpp')
-rw-r--r-- | src/session.cpp | 29 |
1 files changed, 14 insertions, 15 deletions
diff --git a/src/session.cpp b/src/session.cpp index f562bd5..ef17d6d 100644 --- a/src/session.cpp +++ b/src/session.cpp @@ -43,21 +43,6 @@ zmq::session_t::~session_t () out_pipe->term (); } -void zmq::session_t::set_inbound_pipe (reader_t *pipe_) -{ - zmq_assert (!in_pipe); - in_pipe = pipe_; - active = true; - in_pipe->set_endpoint (this); -} -void zmq::session_t::set_outbound_pipe (writer_t *pipe_) -{ - zmq_assert (!out_pipe); - out_pipe = pipe_; - out_pipe->set_endpoint (this); -} - - bool zmq::session_t::read (::zmq_msg_t *msg_) { if (!active) @@ -90,6 +75,20 @@ void zmq::session_t::detach () // term (); } +void zmq::session_t::attach_inpipe (reader_t *pipe_) +{ + zmq_assert (!in_pipe); + in_pipe = pipe_; + active = true; + in_pipe->set_endpoint (this); +} +void zmq::session_t::attach_outpipe (writer_t *pipe_) +{ + zmq_assert (!out_pipe); + out_pipe = pipe_; + out_pipe->set_endpoint (this); +} + void zmq::session_t::revive (reader_t *pipe_) { zmq_assert (in_pipe == pipe_); |