diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-07-26 22:57:19 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-07-26 22:57:19 +0200 |
commit | d7319de3d089b7c340408cd8228825ec0f7b8df0 (patch) | |
tree | 0741c9f0dbde0119da8905b5299a8460869037f0 /src/session.cpp | |
parent | 258e7e6794928544ca7e1557840b2f5a89fe5399 (diff) |
First version of vtcp_connecter added
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/session.cpp')
-rw-r--r-- | src/session.cpp | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/src/session.cpp b/src/session.cpp index d14b58c..b857724 100644 --- a/src/session.cpp +++ b/src/session.cpp @@ -25,6 +25,7 @@ #include "pipe.hpp" #include "likely.hpp" #include "tcp_connecter.hpp" +#include "vtcp_connecter.hpp" #include "pgm_sender.hpp" #include "pgm_receiver.hpp" @@ -315,6 +316,18 @@ void zmq::session_t::start_connecting (bool wait_) return; } +#if defined ZMQ_HAVE_VTCP + if (protocol == "vtcp") { + + vtcp_connecter_t *connecter = new (std::nothrow) vtcp_connecter_t ( + io_thread, this, options, address.c_str (), + wait_); + alloc_assert (connecter); + launch_child (connecter); + return; + } +#endif + #if defined ZMQ_HAVE_OPENPGM // Both PGM and EPGM transports are using the same infrastructure. |