1 | /* |
2 | Copyright (c) 2007-2016 Contributors as noted in the AUTHORS file |
3 | |
4 | This file is part of libzmq, the ZeroMQ core engine in C++. |
5 | |
6 | libzmq is free software; you can redistribute it and/or modify it under |
7 | the terms of the GNU Lesser General Public License (LGPL) as published |
8 | by the Free Software Foundation; either version 3 of the License, or |
9 | (at your option) any later version. |
10 | |
11 | As a special exception, the Contributors give you permission to link |
12 | this library with independent modules to produce an executable, |
13 | regardless of the license terms of these independent modules, and to |
14 | copy and distribute the resulting executable under terms of your choice, |
15 | provided that you also meet, for each linked independent module, the |
16 | terms and conditions of the license of that module. An independent |
17 | module is a module which is not derived from or based on this library. |
18 | If you modify this library, you must extend this exception to your |
19 | version of the library. |
20 | |
21 | libzmq is distributed in the hope that it will be useful, but WITHOUT |
22 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
23 | FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public |
24 | License for more details. |
25 | |
26 | You should have received a copy of the GNU Lesser General Public License |
27 | along with this program. If not, see <http://www.gnu.org/licenses/>. |
28 | */ |
29 | |
30 | #include "precompiled.hpp" |
31 | #include "ipc_connecter.hpp" |
32 | |
33 | #if defined ZMQ_HAVE_IPC |
34 | |
35 | #include <new> |
36 | #include <string> |
37 | |
38 | #include "io_thread.hpp" |
39 | #include "random.hpp" |
40 | #include "err.hpp" |
41 | #include "ip.hpp" |
42 | #include "address.hpp" |
43 | #include "ipc_address.hpp" |
44 | #include "session_base.hpp" |
45 | |
46 | #ifdef _MSC_VER |
47 | #include <afunix.h> |
48 | #else |
49 | #include <unistd.h> |
50 | #include <sys/types.h> |
51 | #include <sys/socket.h> |
52 | #include <sys/un.h> |
53 | #endif |
54 | |
55 | zmq::ipc_connecter_t::ipc_connecter_t (class io_thread_t *io_thread_, |
56 | class session_base_t *session_, |
57 | const options_t &options_, |
58 | address_t *addr_, |
59 | bool delayed_start_) : |
60 | stream_connecter_base_t ( |
61 | io_thread_, session_, options_, addr_, delayed_start_) |
62 | { |
63 | zmq_assert (_addr->protocol == protocol_name::ipc); |
64 | } |
65 | |
66 | void zmq::ipc_connecter_t::out_event () |
67 | { |
68 | fd_t fd = connect (); |
69 | rm_handle (); |
70 | |
71 | // Handle the error condition by attempt to reconnect. |
72 | if (fd == retired_fd) { |
73 | close (); |
74 | add_reconnect_timer (); |
75 | return; |
76 | } |
77 | |
78 | create_engine (fd, get_socket_name<ipc_address_t> (fd, socket_end_local)); |
79 | } |
80 | |
81 | void zmq::ipc_connecter_t::start_connecting () |
82 | { |
83 | // Open the connecting socket. |
84 | int rc = open (); |
85 | |
86 | // Connect may succeed in synchronous manner. |
87 | if (rc == 0) { |
88 | _handle = add_fd (_s); |
89 | out_event (); |
90 | } |
91 | |
92 | // Connection establishment may be delayed. Poll for its completion. |
93 | else if (rc == -1 && errno == EINPROGRESS) { |
94 | _handle = add_fd (_s); |
95 | set_pollout (_handle); |
96 | _socket->event_connect_delayed ( |
97 | make_unconnected_connect_endpoint_pair (_endpoint), zmq_errno ()); |
98 | |
99 | // TODO, tcp_connecter_t adds a connect timer in this case; maybe this |
100 | // should be done here as well (and then this could be pulled up to |
101 | // stream_connecter_base_t). |
102 | } |
103 | |
104 | // Handle any other error condition by eventual reconnect. |
105 | else { |
106 | if (_s != retired_fd) |
107 | close (); |
108 | add_reconnect_timer (); |
109 | } |
110 | } |
111 | |
112 | int zmq::ipc_connecter_t::open () |
113 | { |
114 | zmq_assert (_s == retired_fd); |
115 | |
116 | // Create the socket. |
117 | _s = open_socket (AF_UNIX, SOCK_STREAM, 0); |
118 | if (_s == -1) |
119 | return -1; |
120 | |
121 | // Set the non-blocking flag. |
122 | unblock_socket (_s); |
123 | |
124 | // Connect to the remote peer. |
125 | int rc = ::connect (_s, _addr->resolved.ipc_addr->addr (), |
126 | _addr->resolved.ipc_addr->addrlen ()); |
127 | |
128 | // Connect was successful immediately. |
129 | if (rc == 0) |
130 | return 0; |
131 | |
132 | // Translate other error codes indicating asynchronous connect has been |
133 | // launched to a uniform EINPROGRESS. |
134 | #ifdef ZMQ_HAVE_WINDOWS |
135 | const int last_error = WSAGetLastError (); |
136 | if (last_error == WSAEINPROGRESS || last_error == WSAEWOULDBLOCK) |
137 | errno = EINPROGRESS; |
138 | else |
139 | errno = wsa_error_to_errno (last_error); |
140 | #else |
141 | if (rc == -1 && errno == EINTR) { |
142 | errno = EINPROGRESS; |
143 | } |
144 | #endif |
145 | |
146 | // Forward the error. |
147 | return -1; |
148 | } |
149 | |
150 | zmq::fd_t zmq::ipc_connecter_t::connect () |
151 | { |
152 | // Following code should handle both Berkeley-derived socket |
153 | // implementations and Solaris. |
154 | int err = 0; |
155 | zmq_socklen_t len = static_cast<zmq_socklen_t> (sizeof (err)); |
156 | int rc = getsockopt (_s, SOL_SOCKET, SO_ERROR, |
157 | reinterpret_cast<char *> (&err), &len); |
158 | if (rc == -1) { |
159 | if (errno == ENOPROTOOPT) |
160 | errno = 0; |
161 | err = errno; |
162 | } |
163 | if (err != 0) { |
164 | // Assert if the error was caused by 0MQ bug. |
165 | // Networking problems are OK. No need to assert. |
166 | errno = err; |
167 | errno_assert (errno == ECONNREFUSED || errno == ECONNRESET |
168 | || errno == ETIMEDOUT || errno == EHOSTUNREACH |
169 | || errno == ENETUNREACH || errno == ENETDOWN); |
170 | |
171 | return retired_fd; |
172 | } |
173 | |
174 | fd_t result = _s; |
175 | _s = retired_fd; |
176 | return result; |
177 | } |
178 | |
179 | #endif |
180 | |