From 2bb57ac57ace37203c505ff17147210feca34d73 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Fri, 15 Jan 2010 14:11:39 +0100 Subject: ZMQII-39: Implement IPC transport --- src/zmq_engine.cpp | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) (limited to 'src/zmq_engine.cpp') diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp index a79c0bd..dace6ae 100644 --- a/src/zmq_engine.cpp +++ b/src/zmq_engine.cpp @@ -27,7 +27,8 @@ #include "err.hpp" zmq::zmq_engine_t::zmq_engine_t (io_thread_t *parent_, fd_t fd_, - const options_t &options_, bool reconnect_, const char *address_) : + const options_t &options_, bool reconnect_, + const char *protocol_, const char *address_) : io_object_t (parent_), inpos (NULL), insize (0), @@ -39,8 +40,10 @@ zmq::zmq_engine_t::zmq_engine_t (io_thread_t *parent_, fd_t fd_, options (options_), reconnect (reconnect_) { - if (reconnect) + if (reconnect) { + protocol = protocol_; address = address_; + } // Initialise the underlying socket. int rc = tcp_socket.open (fd_, options.sndbuf, options.rcvbuf); @@ -166,7 +169,7 @@ void zmq::zmq_engine_t::error () inout->get_io_thread (), inout->get_owner (), options, inout->get_ordinal (), true); zmq_assert (reconnecter); - reconnecter->set_address (address.c_str ()); + reconnecter->set_address (protocol.c_str(), address.c_str ()); } inout->detach (reconnecter); -- cgit v1.2.3