Commit f22e85f1 authored by Martin Sustrik's avatar Martin Sustrik

Reverting commit 1d431190

The patch was supposed to check that pipe writer sends messages
in atomic fashion. However, it prevented the user to read
half of a message and close the socket.
Signed-off-by: 's avatarMartin Sustrik <sustrik@250bpm.com>
parent 73e7ef37
...@@ -101,13 +101,6 @@ void zmq::xrep_t::terminated (reader_t *pipe_) ...@@ -101,13 +101,6 @@ void zmq::xrep_t::terminated (reader_t *pipe_)
for (inpipes_t::iterator it = inpipes.begin (); it != inpipes.end (); for (inpipes_t::iterator it = inpipes.begin (); it != inpipes.end ();
it++) { it++) {
if (it->reader == pipe_) { if (it->reader == pipe_) {
if (inpipes [current_in].reader == pipe_) {
// A reader is not allowed to terminate in the middle of a
// multipart message.
zmq_assert (!prefetched);
zmq_assert (!more_in);
}
inpipes.erase (it); inpipes.erase (it);
if (terminating) if (terminating)
unregister_term_ack (); unregister_term_ack ();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment