summaryrefslogtreecommitdiff
path: root/src/lb.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-03-27 21:25:40 +0100
committerMartin Sustrik <sustrik@250bpm.com>2010-03-27 21:25:40 +0100
commit2f219d7c287cd518bc77b576e507d7a17c9535e9 (patch)
tree02020070a444165da6bbc43c0ea11a8a2ee98a6b /src/lb.cpp
parent842b4dd2e492459cbc0cc79ffdb34ddab8f0b528 (diff)
ZMQ_TBC renamed to ZMQ_MORE
Diffstat (limited to 'src/lb.cpp')
-rw-r--r--src/lb.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/lb.cpp b/src/lb.cpp
index b497b11..ca93ba2 100644
--- a/src/lb.cpp
+++ b/src/lb.cpp
@@ -26,7 +26,7 @@
zmq::lb_t::lb_t () :
active (0),
current (0),
- tbc (false)
+ more (false)
{
}
@@ -45,7 +45,7 @@ void zmq::lb_t::attach (writer_t *pipe_)
void zmq::lb_t::detach (writer_t *pipe_)
{
- zmq_assert (!tbc || pipes [current] != pipe_);
+ zmq_assert (!more || pipes [current] != pipe_);
// Remove the pipe from the list; adjust number of active pipes
// accordingly.
@@ -68,11 +68,11 @@ int zmq::lb_t::send (zmq_msg_t *msg_, int flags_)
{
while (active > 0) {
if (pipes [current]->write (msg_)) {
- tbc = msg_->flags & ZMQ_MSG_TBC;
+ more = msg_->flags & ZMQ_MSG_MORE;
break;
}
- zmq_assert (!tbc);
+ zmq_assert (!more);
active--;
if (current < active)
pipes.swap (current, active);
@@ -88,7 +88,7 @@ int zmq::lb_t::send (zmq_msg_t *msg_, int flags_)
// If it's final part of the message we can fluch it downstream and
// continue round-robinning (load balance).
- if (!tbc) {
+ if (!more) {
pipes [current]->flush ();
current = (current + 1) % active;
}
@@ -104,7 +104,7 @@ bool zmq::lb_t::has_out ()
{
// If one part of the message was already written we can definitely
// write the rest of the message.
- if (tbc)
+ if (more)
return true;
while (active > 0) {