summaryrefslogtreecommitdiff
path: root/src/dummy_distributor.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-03 11:30:13 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-03 11:30:13 +0200
commitcc3755a16f00026af882ed14d122cc8aa6d50e82 (patch)
tree33a2197bab1bd6068dbfcc446fe70aaa07808fa9 /src/dummy_distributor.cpp
parent183b6887644ac05c951a3f9143248ed86e91052f (diff)
renamed from zs to zmq
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 ();