diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-06-12 10:19:21 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-06-12 10:19:21 +0200 |
commit | e080e3e8b620b0e7ed02c28712a0c92b08de3451 (patch) | |
tree | 7e7aedfca8dd91e84d0825d251d122d3fe4ce7b3 /src/dist.hpp | |
parent | bd86def1c799a35d5cef0c0a9a1347a18fea227e (diff) |
Publisher-side filtering for multi-part messages fixed
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/dist.hpp')
-rw-r--r-- | src/dist.hpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/dist.hpp b/src/dist.hpp index 005bb60..c8d121c 100644 --- a/src/dist.hpp +++ b/src/dist.hpp @@ -48,14 +48,16 @@ namespace zmq // will send message also to this pipe. void match (class pipe_t *pipe_); + // Mark all pipes as non-matching. + void unmatch (); + // Removes the pipe from the distributor object. void terminated (class pipe_t *pipe_); - // Send the message to all the outbound pipes. After the call all the - // pipes are marked as non-matching. + // Send the message to the matching outbound pipes. int send_to_matching (class msg_t *msg_, int flags_); - // Send the message to the matching outbound pipes. + // Send the message to all the outbound pipes. int send_to_all (class msg_t *msg_, int flags_); bool has_out (); |