diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-05-28 09:02:21 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-05-28 09:02:21 +0200 |
commit | 311fb0d852374e769d8ff791c9df38f0464960c6 (patch) | |
tree | a375bed4c85bbbdb57e7c749997b95e6062ef18c /src/xsub.hpp | |
parent | 718885fdcd7af797f940078ca8c22aebab93c8bb (diff) |
Subscription matching moved from XSUB to SUB socket
This patch will prevent duplicate matching in devices in the future.
Instead of matching in both XPUB and XSUB, it'll happen only
in XPUB. Receiver endpoint will still filter messages via SUB
socket.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/xsub.hpp')
-rw-r--r-- | src/xsub.hpp | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/src/xsub.hpp b/src/xsub.hpp index 58ddae5..ebd6259 100644 --- a/src/xsub.hpp +++ b/src/xsub.hpp @@ -21,9 +21,7 @@ #ifndef __ZMQ_XSUB_HPP_INCLUDED__ #define __ZMQ_XSUB_HPP_INCLUDED__ -#include "trie.hpp" #include "socket_base.hpp" -#include "msg.hpp" #include "fq.hpp" namespace zmq @@ -50,24 +48,9 @@ namespace zmq private: - // Check whether the message matches at least one subscription. - bool match (class msg_t *msg_); - // Fair queueing object for inbound pipes. fq_t fq; - // The repository of subscriptions. - trie_t subscriptions; - - // If true, 'message' contains a matching message to return on the - // next recv call. - bool has_message; - msg_t message; - - // If true, part of a multipart message was already received, but - // there are following parts still waiting. - bool more; - xsub_t (const xsub_t&); const xsub_t &operator = (const xsub_t&); }; |