diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-08-18 17:40:42 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-08-18 17:40:42 +0200 |
commit | b6ecb00d23af3611da98d98f28e1c2583d428e00 (patch) | |
tree | 7130ed6e4c2d62fc151170f465c5245d5072b062 /src/vtcp_connecter.cpp | |
parent | 4a8dd1e404c78fb403763d830190755d2ac83228 (diff) |
TCP address related functionality moved to tcp_address_t
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/vtcp_connecter.cpp')
-rw-r--r-- | src/vtcp_connecter.cpp | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/src/vtcp_connecter.cpp b/src/vtcp_connecter.cpp index 61e7e84..3d2900e 100644 --- a/src/vtcp_connecter.cpp +++ b/src/vtcp_connecter.cpp @@ -60,8 +60,6 @@ zmq::vtcp_connecter_t::vtcp_connecter_t (class io_thread_t *io_thread_, session (session_), current_reconnect_ivl(options.reconnect_ivl) { - memset (&addr, 0, sizeof (addr)); - addr_len = 0; subport = 0; int rc = set_address (address_); @@ -92,8 +90,7 @@ int zmq::vtcp_connecter_t::set_address (const char *addr_) addr_str += ":9220"; std::string subport_str (delimiter + 1); subport = (vtcp_subport_t) atoi (subport_str.c_str ()); - int rc = resolve_ip_hostname (&addr, &addr_len, addr_str.c_str (), - true); + int rc = address.resolve (addr_str.c_str (), false, true); if (rc != 0) return -1; } @@ -101,8 +98,7 @@ int zmq::vtcp_connecter_t::set_address (const char *addr_) std::string addr_str (addr_, delimiter - addr_); std::string subport_str (delimiter + 1); subport = (vtcp_subport_t) atoi (subport_str.c_str ()); - int rc = resolve_ip_hostname (&addr, &addr_len, addr_str.c_str (), - true); + int rc = address.resolve (addr_str.c_str (), false, true); if (rc != 0) return -1; } @@ -207,7 +203,7 @@ int zmq::vtcp_connecter_t::open () zmq_assert (s == retired_fd); // Start the connection procedure. - sockaddr_in *paddr = (sockaddr_in*) &addr; + sockaddr_in *paddr = (sockaddr_in*) address.addr (); s = vtcp_connect (paddr->sin_addr.s_addr, ntohs (paddr->sin_port)); // Connect was successfull immediately. |