summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-04-30 04:53:41 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-04-30 04:53:41 +0200
commitacfd0f8ca2d15111f35ae0034ed3ce130c96b910 (patch)
tree45f256d4831694ddd74145a4cc8f58e7fa310cc1
parentae93ed318a450d6d763a5f629d478467f7362b07 (diff)
prefix in XREP recv'd message misses MORE flag
-rw-r--r--src/xrep.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp
index 051a5ce..4e8d18a 100644
--- a/src/xrep.cpp
+++ b/src/xrep.cpp
@@ -220,6 +220,7 @@ int zmq::xrep_t::xrecv (zmq_msg_t *msg_, int flags_)
zmq_assert (rc == 0);
memcpy (zmq_msg_data (msg_), inpipes [current_in].identity.data (),
zmq_msg_size (msg_));
+ msg_->flags = ZMQ_MSG_MORE;
more_in = true;
return 0;
}