1 /* Copyright 2011 NORDUnet A/S. All rights reserved.
2 See the file COPYING for licensing information. */
4 #if defined HAVE_CONFIG_H
9 #include <event2/event.h>
10 #include <event2/bufferevent.h>
11 #if defined (RS_ENABLE_TLS)
12 #include <event2/bufferevent_ssl.h>
13 #include <openssl/err.h>
15 #include <radsec/radsec.h>
16 #include <radsec/radsec-impl.h>
19 #if defined (RS_ENABLE_TLS)
30 extern int _event_debug_mode_on;
34 _evlog_cb (int severity, const char *msg)
39 case _EVENT_LOG_DEBUG:
40 #if !defined (DEBUG_LEVENT)
58 fprintf (stderr, "libevent: [%s] %s\n", sevstr, msg); /* FIXME: stderr? */
62 event_conn_timeout_cb (int fd, short event, void *data)
64 struct rs_connection *conn = NULL;
67 conn = (struct rs_connection *) data;
69 if (event & EV_TIMEOUT)
71 rs_debug (("%s: connection timeout on %p (fd %d) connecting to %p\n",
72 __func__, conn, conn->fd, conn->active_peer));
73 conn->is_connecting = 0;
74 rs_err_conn_push_fl (conn, RSE_TIMEOUT_CONN, __FILE__, __LINE__, NULL);
75 event_loopbreak (conn);
80 event_retransmit_timeout_cb (int fd, short event, void *data)
82 struct rs_connection *conn = NULL;
85 conn = (struct rs_connection *) data;
87 if (event & EV_TIMEOUT)
89 rs_debug (("%s: retransmission timeout on %p (fd %d) sending to %p\n",
90 __func__, conn, conn->fd, conn->active_peer));
91 rs_err_conn_push_fl (conn, RSE_TIMEOUT_IO, __FILE__, __LINE__, NULL);
92 event_loopbreak (conn);
97 event_init_socket (struct rs_connection *conn, struct rs_peer *p)
102 if (p->addr_cache == NULL)
104 struct rs_error *err =
105 rs_resolve (&p->addr_cache, p->realm->type, p->hostname, p->service);
107 return err_conn_push_err (conn, err);
110 conn->fd = socket (p->addr_cache->ai_family, p->addr_cache->ai_socktype,
111 p->addr_cache->ai_protocol);
113 return rs_err_conn_push_fl (conn, RSE_SOCKERR, __FILE__, __LINE__,
115 errno, strerror (errno));
116 if (evutil_make_socket_nonblocking (conn->fd) < 0)
118 evutil_closesocket (conn->fd);
120 return rs_err_conn_push_fl (conn, RSE_SOCKERR, __FILE__, __LINE__,
121 "evutil_make_socket_nonblocking: %d (%s)",
122 errno, strerror (errno));
128 event_init_bufferevent (struct rs_connection *conn, struct rs_peer *peer)
133 if (conn->realm->type == RS_CONN_TYPE_TCP)
135 conn->bev = bufferevent_socket_new (conn->evb, conn->fd, 0);
137 return rs_err_conn_push_fl (conn, RSE_EVENT, __FILE__, __LINE__,
138 "bufferevent_socket_new");
140 #if defined (RS_ENABLE_TLS)
141 else if (conn->realm->type == RS_CONN_TYPE_TLS)
143 if (rs_tls_init (conn))
145 /* Would be convenient to pass BEV_OPT_CLOSE_ON_FREE but things
146 seem to break when be_openssl_ctrl() (in libevent) calls
147 SSL_set_bio() after BIO_new_socket() with flag=1. */
149 bufferevent_openssl_socket_new (conn->evb, conn->fd, conn->tls_ssl,
150 BUFFEREVENT_SSL_CONNECTING, 0);
152 return rs_err_conn_push_fl (conn, RSE_EVENT, __FILE__, __LINE__,
153 "bufferevent_openssl_socket_new");
155 #endif /* RS_ENABLE_TLS */
158 return rs_err_conn_push_fl (conn, RSE_INTERNAL, __FILE__, __LINE__,
159 "%s: unknown connection type: %d", __func__,
167 event_do_connect (struct rs_connection *conn)
173 assert (conn->active_peer);
174 p = conn->active_peer;
178 char host[80], serv[80];
180 getnameinfo (p->addr_cache->ai_addr,
181 p->addr_cache->ai_addrlen,
182 host, sizeof(host), serv, sizeof(serv),
183 0 /* NI_NUMERICHOST|NI_NUMERICSERV*/);
184 rs_debug (("%s: connecting to %s:%s\n", __func__, host, serv));
188 if (p->conn->bev) /* TCP */
190 conn_activate_timeout (conn); /* Connect timeout. */
191 err = bufferevent_socket_connect (p->conn->bev, p->addr_cache->ai_addr,
192 p->addr_cache->ai_addrlen);
194 rs_err_conn_push_fl (p->conn, RSE_EVENT, __FILE__, __LINE__,
195 "bufferevent_socket_connect: %s",
196 evutil_gai_strerror (err));
198 p->conn->is_connecting = 1;
202 err = connect (p->conn->fd,
203 p->addr_cache->ai_addr,
204 p->addr_cache->ai_addrlen);
207 sockerr = evutil_socket_geterror (p->conn->fd);
208 rs_debug (("%s: %d: connect: %d (%s)\n", __func__, p->conn->fd,
209 sockerr, evutil_socket_error_to_string (sockerr)));
210 rs_err_conn_push_fl (p->conn, RSE_SOCKERR, __FILE__, __LINE__,
211 "%d: connect: %d (%s)", p->conn->fd, sockerr,
212 evutil_socket_error_to_string (sockerr));
218 event_loopbreak (struct rs_connection *conn)
220 int err = event_base_loopbreak (conn->evb);
222 rs_err_conn_push_fl (conn, RSE_EVENT, __FILE__, __LINE__,
223 "event_base_loopbreak: %s",
224 evutil_gai_strerror (err));
230 event_on_disconnect (struct rs_connection *conn)
232 conn->is_connecting = 0;
233 conn->is_connected = 0;
234 rs_debug (("%s: %p disconnected\n", __func__, conn->active_peer));
235 if (conn->callbacks.disconnected_cb)
236 conn->callbacks.disconnected_cb (conn->user_data);
240 event_on_connect (struct rs_connection *conn, struct rs_packet *pkt)
242 assert (!conn->is_connecting);
243 conn->is_connected = 1;
244 rs_debug (("%s: %p connected\n", __func__, conn->active_peer));
246 if (conn->callbacks.connected_cb)
247 conn->callbacks.connected_cb (conn->user_data);
250 packet_do_send (pkt);
254 event_init_eventbase (struct rs_connection *conn)
261 if (!_event_debug_mode_on)
262 event_enable_debug_mode ();
264 event_set_log_callback (_evlog_cb);
265 conn->evb = event_base_new ();
267 return rs_err_conn_push_fl (conn, RSE_EVENT, __FILE__, __LINE__,