summaryrefslogtreecommitdiff
path: root/src/xsub.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-05-28 09:02:21 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-05-28 09:02:21 +0200
commit311fb0d852374e769d8ff791c9df38f0464960c6 (patch)
treea375bed4c85bbbdb57e7c749997b95e6062ef18c /src/xsub.hpp
parent718885fdcd7af797f940078ca8c22aebab93c8bb (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.hpp17
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&);
};