generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-30 05:29:43 +01:00
Code Issues Projects Releases Wiki Activity

issue 28. - SNDMORE/ RCVMORE is dropping every other message

Browse Source
This commit is contained in:
Martin Sustrik
2010-05-31 09:28:36 +02:00
parent 2e9be56a40
commit be6019abd1
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/req.cpp
View File

@@ -226,11 +226,11 @@ int zmq::req_t::xrecv (zmq_msg_t *msg_, int flags_)
zmq_assert (zmq_msg_size (msg_) == 0); zmq_assert (zmq_msg_size (msg_) == 0);
rc = zmq_msg_close (msg_); rc = zmq_msg_close (msg_);
zmq_assert (rc == 0); zmq_assert (rc == 0);
}
// Get the actual reply. // Get the actual reply.
bool recvd = reply_pipe->read (msg_); bool recvd = reply_pipe->read (msg_);
zmq_assert (recvd); zmq_assert (recvd);
}
// If this was last part of the reply, switch to request phase. // If this was last part of the reply, switch to request phase.
more = msg_->flags & ZMQ_MSG_MORE; more = msg_->flags & ZMQ_MSG_MORE;