From e080e3e8b620b0e7ed02c28712a0c92b08de3451 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sun, 12 Jun 2011 10:19:21 +0200 Subject: Publisher-side filtering for multi-part messages fixed Signed-off-by: Martin Sustrik --- src/dist.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'src/dist.cpp') diff --git a/src/dist.cpp b/src/dist.cpp index 707b9c1..15bd168 100644 --- a/src/dist.cpp +++ b/src/dist.cpp @@ -70,6 +70,11 @@ void zmq::dist_t::match (pipe_t *pipe_) matching++; } +void zmq::dist_t::unmatch () +{ + matching = 0; +} + void zmq::dist_t::terminated (pipe_t *pipe_) { // Remove the pipe from the list; adjust number of matching, active and/or @@ -115,9 +120,6 @@ int zmq::dist_t::send_to_matching (msg_t *msg_, int flags_) if (!msg_more) active = eligible; - // Mark all the pipes as non-matching. - matching = 0; - more = msg_more; return 0; -- cgit v1.2.3