summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-10-11 12:23:18 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-10-11 12:23:18 +0200
commitf22e85f19f2bf58285e4984e875487f17c85e791 (patch)
tree88762f9487fd09277ebec0570bf153c0ba0dd42d
parent73e7ef37c2e72dd542d20ddc5be30cedce68e329 (diff)
Reverting commit 1d431190f50c86f62460
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: Martin Sustrik <sustrik@250bpm.com>
-rw-r--r--src/xrep.cpp7
1 files changed, 0 insertions, 7 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp
index 2d538db..a9e2cc9 100644
--- a/src/xrep.cpp
+++ b/src/xrep.cpp
@@ -101,13 +101,6 @@ void zmq::xrep_t::terminated (reader_t *pipe_)
for (inpipes_t::iterator it = inpipes.begin (); it != inpipes.end ();
it++) {
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);
if (terminating)
unregister_term_ack ();