Commit f053854e authored by Pieter Hintjens's avatar Pieter Hintjens

Merge pull request #1360 from hurtonm/master

Adjust number of sent messages on hiccups
parents b7e52755 5ed6ac60
...@@ -267,6 +267,8 @@ void zmq::pipe_t::process_hiccup (void *pipe_) ...@@ -267,6 +267,8 @@ void zmq::pipe_t::process_hiccup (void *pipe_)
outpipe->flush (); outpipe->flush ();
msg_t msg; msg_t msg;
while (outpipe->read (&msg)) { while (outpipe->read (&msg)) {
if (!(msg.flags () & msg_t::more))
msgs_written--;
int rc = msg.close (); int rc = msg.close ();
errno_assert (rc == 0); errno_assert (rc == 0);
} }
......
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