summaryrefslogtreecommitdiff
path: root/src/pipe.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/pipe.cpp
parent183b6887644ac05c951a3f9143248ed86e91052f (diff)
renamed from zs to zmq
Diffstat (limited to 'src/pipe.cpp')
-rw-r--r--src/pipe.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/pipe.cpp b/src/pipe.cpp
index 26042ae..bf761b4 100644
--- a/src/pipe.cpp
+++ b/src/pipe.cpp
@@ -19,29 +19,29 @@
#include "pipe.hpp"
-zs::pipe_t::pipe_t () :
- ypipe_t <zs_msg, false, message_pipe_granularity> (false),
+zmq::pipe_t::pipe_t () :
+ ypipe_t <zmq_msg, false, message_pipe_granularity> (false),
index (-1)
{
}
-zs::pipe_t::~pipe_t ()
+zmq::pipe_t::~pipe_t ()
{
// Flush any outstanding messages to the pipe.
flush ();
// Deallocate all the messages in the pipe.
- zs_msg msg;
+ zmq_msg msg;
while (read (&msg))
- zs_msg_close (&msg);
+ zmq_msg_close (&msg);
}
-void zs::pipe_t::set_index (int index_)
+void zmq::pipe_t::set_index (int index_)
{
index = index_;
}
-int zs::pipe_t::get_index ()
+int zmq::pipe_t::get_index ()
{
return index;
}