From c80e7b80cc726ca7c29493c2553c8d19792bb6e5 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sat, 4 Dec 2010 23:14:38 +0100 Subject: XPUB and XSUB socket types added. These are just placeholders. At the moment XPUB behaves th same as PUB and XSUB as SUB. Signed-off-by: Martin Sustrik --- src/socket_base.cpp | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) (limited to 'src/socket_base.cpp') diff --git a/src/socket_base.cpp b/src/socket_base.cpp index bfaacb7..2fe7bfd 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -46,6 +46,8 @@ #include "ctx.hpp" #include "platform.hpp" #include "likely.hpp" +#include "uuid.hpp" + #include "pair.hpp" #include "pub.hpp" #include "sub.hpp" @@ -55,7 +57,8 @@ #include "push.hpp" #include "xreq.hpp" #include "xrep.hpp" -#include "uuid.hpp" +#include "xpub.hpp" +#include "xsub.hpp" zmq::socket_base_t *zmq::socket_base_t::create (int type_, class ctx_t *parent_, uint32_t tid_) @@ -90,6 +93,12 @@ zmq::socket_base_t *zmq::socket_base_t::create (int type_, class ctx_t *parent_, case ZMQ_PUSH: s = new (std::nothrow) push_t (parent_, tid_); break; + case ZMQ_XPUB: + s = new (std::nothrow) xpub_t (parent_, tid_); + break; + case ZMQ_XSUB: + s = new (std::nothrow) xsub_t (parent_, tid_); + break; default: errno = EINVAL; return NULL; -- cgit v1.2.3