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.cpp | |
parent | 72fdf47d16c8d3ecd9da657b4649978e414d775c (diff) |
python extension & perf tests
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_); |