summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/dist.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/dist.cpp b/src/dist.cpp
index 23e790d..79baf43 100644
--- a/src/dist.cpp
+++ b/src/dist.cpp
@@ -142,11 +142,9 @@ void zmq::dist_t::distribute (msg_t *msg_, int flags_)
msg_->add_refs ((int) matching - 1);
// Push copy of the message to each matching pipe.
- for (pipes_t::size_type i = 0; i < matching;) {
+ for (pipes_t::size_type i = 0; i < matching; ++i) {
if (!write (pipes [i], msg_))
msg_->rm_refs (1);
- else
- i++;
}
// Detach the original message from the data buffer. Note that we don't