generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-29 20:59:47 +01:00
Code Issues 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
parent e05c805688
commit 5ed6ac60e2
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipe.cpp
View File

@@ -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);
} }