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/pipe.cpp | |
parent | 183b6887644ac05c951a3f9143248ed86e91052f (diff) |
renamed from zs to zmq
Diffstat (limited to 'src/pipe.cpp')
-rw-r--r-- | src/pipe.cpp | 14 |
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; } |