3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-17 08:34:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adjust number of sent messages on hiccups

Browse Source 
Not adjusting the sent message count may lead to situation when SUB
socket does not forward its subscriptions.
This commit is contained in:
Martin Hurton 2015-02-19 21:38:10 +01:00 committed by Pieter Hintjens
parent 77ef79e3b5
commit d8d9d17b21
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipe.cpp
View File

@ -242,6 +242,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);
} }