From d8d9d17b21a3ce6cd11456b64c0c843d73d2e75b Mon Sep 17 00:00:00 2001
From: Martin Hurton <hurtonm@gmail.com>
Date: Thu, 19 Feb 2015 21:38:10 +0100
Subject: [PATCH] Adjust number of sent messages on hiccups

Not adjusting the sent message count may lead to situation when SUB
socket does not forward its subscriptions.
---
 src/pipe.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/pipe.cpp b/src/pipe.cpp
index 9526dd7b..a7560351 100644
--- a/src/pipe.cpp
+++ b/src/pipe.cpp
@@ -242,6 +242,8 @@ void zmq::pipe_t::process_hiccup (void *pipe_)
     outpipe->flush ();
     msg_t msg;
     while (outpipe->read (&msg)) {
+       if (!(msg.flags () & msg_t::more))
+            msgs_written--;
        int rc = msg.close ();
        errno_assert (rc == 0);
     }