summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-05-31 09:28:36 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-05-31 09:28:36 +0200
commitbe6019abd1ac6fe11c9c51dbadf9c72b37349c2a (patch)
tree551cff45778f5c15666dfd0aad4a0fe9f1b8a25e
parent2e9be56a4059cf230f6aa92eb1c71db5f1200b8e (diff)
issue 28. - SNDMORE/ RCVMORE is dropping every other message
-rw-r--r--src/req.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/req.cpp b/src/req.cpp
index 9db7b60..f3695a2 100644
--- a/src/req.cpp
+++ b/src/req.cpp
@@ -226,11 +226,11 @@ int zmq::req_t::xrecv (zmq_msg_t *msg_, int flags_)
zmq_assert (zmq_msg_size (msg_) == 0);
rc = zmq_msg_close (msg_);
zmq_assert (rc == 0);
- }
- // Get the actual reply.
- bool recvd = reply_pipe->read (msg_);
- zmq_assert (recvd);
+ // Get the actual reply.
+ bool recvd = reply_pipe->read (msg_);
+ zmq_assert (recvd);
+ }
// If this was last part of the reply, switch to request phase.
more = msg_->flags & ZMQ_MSG_MORE;