From db99547e5ac10c303a175f15733036183ab8af09 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Wed, 13 Jun 2012 10:29:33 +0200 Subject: Revert "UDP support" This reverts commit 9ba8f9a503d69b891fae38628e0038f49ed5b8a4. --- src/session_base.cpp | 38 -------------------------------------- 1 file changed, 38 deletions(-) (limited to 'src/session_base.cpp') diff --git a/src/session_base.cpp b/src/session_base.cpp index 49fdce1..1ffc060 100644 --- a/src/session_base.cpp +++ b/src/session_base.cpp @@ -30,8 +30,6 @@ #include "ipc_connecter.hpp" #include "pgm_sender.hpp" #include "pgm_receiver.hpp" -#include "udp_sender.hpp" -#include "udp_receiver.hpp" #include "req.hpp" #include "xreq.hpp" @@ -486,42 +484,6 @@ void xs::session_base_t::start_connecting (bool wait_) } #endif - // UDP support. - if (protocol == "udp") { - - // At this point we'll create message pipes to the session straight - // away. There's no point in delaying it as no concept of 'connect' - // exists with UDP anyway. - if (options.type == XS_PUB || options.type == XS_XPUB) { - - // UDP sender. - udp_sender_t *udp_sender = new (std::nothrow) udp_sender_t ( - io_thread, options); - alloc_assert (udp_sender); - - int rc = udp_sender->init (address.c_str ()); - xs_assert (rc == 0); - - send_attach (this, udp_sender); - } - else if (options.type == XS_SUB || options.type == XS_XSUB) { - - // UDP receiver. - udp_receiver_t *udp_receiver = new (std::nothrow) udp_receiver_t ( - io_thread, options); - alloc_assert (udp_receiver); - - int rc = udp_receiver->init (address.c_str ()); - xs_assert (rc == 0); - - send_attach (this, udp_receiver); - } - else - xs_assert (false); - - return; - } - xs_assert (false); } -- cgit v1.2.3