summaryrefslogtreecommitdiff
path: root/src/dist.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-06-12 10:19:21 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-06-12 10:19:21 +0200
commite080e3e8b620b0e7ed02c28712a0c92b08de3451 (patch)
tree7e7aedfca8dd91e84d0825d251d122d3fe4ce7b3 /src/dist.hpp
parentbd86def1c799a35d5cef0c0a9a1347a18fea227e (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.hpp8
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 ();