diff options
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 (); |