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/load_balancer.cpp | |
parent | 183b6887644ac05c951a3f9143248ed86e91052f (diff) |
renamed from zs to zmq
Diffstat (limited to 'src/load_balancer.cpp')
-rw-r--r-- | src/load_balancer.cpp | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/load_balancer.cpp b/src/load_balancer.cpp index 63dc15c..0d382a1 100644 --- a/src/load_balancer.cpp +++ b/src/load_balancer.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 "load_balancer.hpp" #include "pipe_writer.hpp" @@ -25,26 +25,26 @@ #include "session.hpp" #include "msg.hpp" -zs::load_balancer_t::load_balancer_t () : +zmq::load_balancer_t::load_balancer_t () : session (NULL), current (0) { } -void zs::load_balancer_t::set_session (session_t *session_) +void zmq::load_balancer_t::set_session (session_t *session_) { - zs_assert (!session); + zmq_assert (!session); session = session_; } -void zs::load_balancer_t::shutdown () +void zmq::load_balancer_t::shutdown () { // No need to deallocate pipes here. They'll be deallocated during the // shutdown of the dispatcher. delete this; } -void zs::load_balancer_t::terminate () +void zmq::load_balancer_t::terminate () { // Pipe unregisters itself during the call to terminate, so the pipes // list shinks by one in each iteration. @@ -54,11 +54,11 @@ void zs::load_balancer_t::terminate () delete this; } -zs::load_balancer_t::~load_balancer_t () +zmq::load_balancer_t::~load_balancer_t () { } -void zs::load_balancer_t::attach_pipe (pipe_writer_t *pipe_) +void zmq::load_balancer_t::attach_pipe (pipe_writer_t *pipe_) { // Associate demux with a new pipe. pipe_->set_demux (this); @@ -66,7 +66,7 @@ void zs::load_balancer_t::attach_pipe (pipe_writer_t *pipe_) pipes.push_back (pipe_); } -void zs::load_balancer_t::detach_pipe (pipe_writer_t *pipe_) +void zmq::load_balancer_t::detach_pipe (pipe_writer_t *pipe_) { // Release the reference to the pipe. int index = pipe_->get_index (); @@ -76,12 +76,12 @@ void zs::load_balancer_t::detach_pipe (pipe_writer_t *pipe_) pipes.pop_back (); } -bool zs::load_balancer_t::empty () +bool zmq::load_balancer_t::empty () { return pipes.empty (); } -bool zs::load_balancer_t::send (zs_msg *msg_) +bool zmq::load_balancer_t::send (zmq_msg *msg_) { // If there are no pipes, message cannot be sent. if (pipes.size () == 0) @@ -105,12 +105,12 @@ bool zs::load_balancer_t::send (zs_msg *msg_) current = (current + 1) % pipes.size (); // Detach the original message from the data buffer. - zs_msg_init (msg_); + zmq_msg_init (msg_); return true; } -void zs::load_balancer_t::flush () +void zmq::load_balancer_t::flush () { // Flush all pipes. If there's large number of pipes, it can be pretty // inefficient (especially if there's new message only in a single pipe). @@ -119,12 +119,12 @@ void zs::load_balancer_t::flush () (*it)->flush (); } -void zs::load_balancer_t::write_to_pipe (class pipe_writer_t *pipe_, - struct zs_msg *msg_) +void zmq::load_balancer_t::write_to_pipe (class pipe_writer_t *pipe_, + struct zmq_msg *msg_) { if (!pipe_->write (msg_)) { // TODO: Push gap notification to the pipe. - zs_assert (false); + zmq_assert (false); } } |