summaryrefslogtreecommitdiff
path: root/src/xrep.cpp
diff options
context:
space:
mode:
authorMartin Lucina <martin@lucina.net>2012-02-16 10:05:18 +0900
committerMartin Sustrik <sustrik@250bpm.com>2012-02-16 10:05:18 +0900
commit858b8ad76757624464c139be2367f0dce53f8c3b (patch)
treebf174496a722d151d33e861f9bdd43a199007b1d /src/xrep.cpp
parentcfba1f07987434263843f4aaee11ec088ec6ced3 (diff)
Fix data loss for PUB/SUB and unidirectional transports (LIBZMQ-268)
With the introduction of subscription forwarding, the first message sent on a PUB socket using a unidirectional transport (e.g. PGM) is always lost due to the "subscribe to all" being done asynchronously. This patch fixes the problem and also refactors the code to have a single point where the "subscribe to all" is performed. Signed-off-by: Martin Lucina <martin@lucina.net>
Diffstat (limited to 'src/xrep.cpp')
-rw-r--r--src/xrep.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/xrep.cpp b/src/xrep.cpp
index d65f21b..051159d 100644
--- a/src/xrep.cpp
+++ b/src/xrep.cpp
@@ -55,7 +55,7 @@ xs::xrep_t::~xrep_t ()
prefetched_msg.close ();
}
-void xs::xrep_t::xattach_pipe (pipe_t *pipe_)
+void xs::xrep_t::xattach_pipe (pipe_t *pipe_, bool icanhasall_)
{
xs_assert (pipe_);