summaryrefslogtreecommitdiff
path: root/src/dummy_distributor.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/dummy_distributor.cpp')
-rw-r--r--src/dummy_distributor.cpp28
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 ();