diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-03 11:30:13 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-03 11:30:13 +0200 |
commit | cc3755a16f00026af882ed14d122cc8aa6d50e82 (patch) | |
tree | 33a2197bab1bd6068dbfcc446fe70aaa07808fa9 /src/dummy_distributor.cpp | |
parent | 183b6887644ac05c951a3f9143248ed86e91052f (diff) |
renamed from zs to zmq
Diffstat (limited to 'src/dummy_distributor.cpp')
-rw-r--r-- | src/dummy_distributor.cpp | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/dummy_distributor.cpp b/src/dummy_distributor.cpp index 58cadfe..62e2b88 100644 --- a/src/dummy_distributor.cpp +++ b/src/dummy_distributor.cpp @@ -17,7 +17,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>. */ -#include "../include/zs.h" +#include "../include/zmq.h" #include "dummy_distributor.hpp" #include "pipe_writer.hpp" @@ -25,25 +25,25 @@ #include "session.hpp" #include "msg.hpp" -zs::dummy_distributor_t::dummy_distributor_t () : +zmq::dummy_distributor_t::dummy_distributor_t () : session (NULL) { } -void zs::dummy_distributor_t::set_session (session_t *session_) +void zmq::dummy_distributor_t::set_session (session_t *session_) { - zs_assert (!session); + zmq_assert (!session); session = session_; } -void zs::dummy_distributor_t::shutdown () +void zmq::dummy_distributor_t::shutdown () { // No need to deallocate pipe here. It'll be deallocated during the // shutdown of the dispatcher. delete this; } -void zs::dummy_distributor_t::terminate () +void zmq::dummy_distributor_t::terminate () { if (pipe) pipe->terminate (); @@ -51,33 +51,33 @@ void zs::dummy_distributor_t::terminate () delete this; } -zs::dummy_distributor_t::~dummy_distributor_t () +zmq::dummy_distributor_t::~dummy_distributor_t () { } -void zs::dummy_distributor_t::attach_pipe (pipe_writer_t *pipe_) +void zmq::dummy_distributor_t::attach_pipe (pipe_writer_t *pipe_) { - zs_assert (!pipe); + zmq_assert (!pipe); pipe = pipe_; } -void zs::dummy_distributor_t::detach_pipe (pipe_writer_t *pipe_) +void zmq::dummy_distributor_t::detach_pipe (pipe_writer_t *pipe_) { - zs_assert (pipe == pipe_); + zmq_assert (pipe == pipe_); pipe = NULL; } -bool zs::dummy_distributor_t::empty () +bool zmq::dummy_distributor_t::empty () { return pipe == NULL; } -bool zs::dummy_distributor_t::send (zs_msg *msg_) +bool zmq::dummy_distributor_t::send (zmq_msg *msg_) { return pipe && pipe->write (msg_); } -void zs::dummy_distributor_t::flush () +void zmq::dummy_distributor_t::flush () { if (pipe) pipe->flush (); |