summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-03-09 17:34:28 +0100
committerMartin Sustrik <sustrik@250bpm.com>2010-03-09 17:34:28 +0100
commit5a776f5597cac632ca507e2d80ca0de064bba1d6 (patch)
treeaee8ed8b4c9384f8a33e5c6c22e63b2146321f2a
parent0f891e091cc46775226ee1fe28784876395a7b92 (diff)
PGM late joiners would start receiving a complete message rather than a message part
-rw-r--r--src/zmq_encoder.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/zmq_encoder.cpp b/src/zmq_encoder.cpp
index d78d04f..774532d 100644
--- a/src/zmq_encoder.cpp
+++ b/src/zmq_encoder.cpp
@@ -98,13 +98,15 @@ bool zmq::zmq_encoder_t::message_ready ()
if (size < 255) {
tmpbuf [0] = (unsigned char) size;
tmpbuf [1] = (in_progress.flags & ~ZMQ_MSG_SHARED);
- next_step (tmpbuf, 2, &zmq_encoder_t::size_ready, true);
+ next_step (tmpbuf, 2, &zmq_encoder_t::size_ready,
+ !(in_progress.flags & ZMQ_MSG_TBC));
}
else {
tmpbuf [0] = 0xff;
put_uint64 (tmpbuf + 1, size);
tmpbuf [9] = (in_progress.flags & ~ZMQ_MSG_SHARED);
- next_step (tmpbuf, 10, &zmq_encoder_t::size_ready, true);
+ next_step (tmpbuf, 10, &zmq_encoder_t::size_ready,
+ !(in_progress.flags & ZMQ_MSG_TBC));
}
return true;
}