From 2cef05d86976784f4bc1083cb0fa548e267ac132 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Tue, 15 Dec 2009 17:49:40 +0100 Subject: reconnection mechanism added to tcp transport --- src/zmq_connecter_init.hpp | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) (limited to 'src/zmq_connecter_init.hpp') diff --git a/src/zmq_connecter_init.hpp b/src/zmq_connecter_init.hpp index 3f42fc6..03ccd24 100644 --- a/src/zmq_connecter_init.hpp +++ b/src/zmq_connecter_init.hpp @@ -40,7 +40,8 @@ namespace zmq public: zmq_connecter_init_t (class io_thread_t *parent_, socket_base_t *owner_, - fd_t fd_, const options_t &options, const char *session_name_); + fd_t fd_, const options_t &options, const char *session_name_, + const char *address_); ~zmq_connecter_init_t (); private: @@ -49,7 +50,10 @@ namespace zmq bool read (::zmq_msg_t *msg_); bool write (::zmq_msg_t *msg_); void flush (); - void detach (); + void detach (owned_t *reconnecter_); + class io_thread_t *get_io_thread (); + class socket_base_t *get_owner (); + const char *get_session_name (); // Handlers for incoming commands. void process_plug (); @@ -63,8 +67,7 @@ namespace zmq // Associated socket options. options_t options; - // Name of the session to bind new connection to. Makes sense only - // when 'connected' is true. + // Name of the session to bind new connection to. std::string session_name; zmq_connecter_init_t (const zmq_connecter_init_t&); -- cgit v1.2.3