diff options
| author | Martin Sustrik <sustrik@250bpm.com> | 2010-03-27 21:25:40 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@250bpm.com> | 2010-03-27 21:25:40 +0100 |
| commit | 2f219d7c287cd518bc77b576e507d7a17c9535e9 (patch) | |
| tree | 02020070a444165da6bbc43c0ea11a8a2ee98a6b /src/pipe.cpp | |
| parent | 842b4dd2e492459cbc0cc79ffdb34ddab8f0b528 (diff) | |
ZMQ_TBC renamed to ZMQ_MORE
Diffstat (limited to 'src/pipe.cpp')
| -rw-r--r-- | src/pipe.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
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; } |