From 2f219d7c287cd518bc77b576e507d7a17c9535e9 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sat, 27 Mar 2010 21:25:40 +0100 Subject: ZMQ_TBC renamed to ZMQ_MORE --- src/pipe.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/pipe.cpp') diff --git a/src/pipe.cpp b/src/pipe.cpp index e844865..61ddf38 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -77,7 +77,7 @@ bool zmq::reader_t::read (zmq_msg_t *msg_) return false; } - if (!(msg_->flags & ZMQ_MSG_TBC)) + if (!(msg_->flags & ZMQ_MSG_MORE)) msgs_read++; if (lwm > 0 && msgs_read % lwm == 0) @@ -163,7 +163,7 @@ bool zmq::writer_t::write (zmq_msg_t *msg_) } pipe->write (*msg_); - if (!(msg_->flags & ZMQ_MSG_TBC)) + if (!(msg_->flags & ZMQ_MSG_MORE)) msgs_written++; return true; } @@ -173,7 +173,7 @@ void zmq::writer_t::rollback () zmq_msg_t msg; while (pipe->unwrite (&msg)) { - if (!(msg.flags & ZMQ_MSG_TBC)) { + if (!(msg.flags & ZMQ_MSG_MORE)) { pipe->write (msg); break; } -- cgit v1.2.3