2 * This program is free software; you can redistribute it and/or modify
3 * it under the terms of the GNU General Public License as published by
4 * the Free Software Foundation; either version 2 of the License, or (at
5 * your option) any later version.
7 * This program is distributed in the hope that it will be useful, but
8 * WITHOUT ANY WARRANTY; without even the implied warranty of
9 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
10 * General Public License for more details.
12 * You should have received a copy of the GNU General Public License
13 * along with this program; if not, write to the Free Software
14 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
17 * Copyright © 2006 Pierre Habouzit
20 #include <sys/epoll.h>
21 #include <sys/socket.h>
23 # include <linux/poll.h>
25 # define EPOLLRDHUP POLLRDHUP
32 #include "mutt_ssl.li"
34 DO_ARRAY_TYPE(job_t, job);
36 static int epollfd = -1;
37 static job_array jobs;
39 static int el_job_setemode(job_t *w, el_mode emode)
41 static int const evtmode_to_epoll[] = {
42 [EL_NEW] = EPOLLRDHUP,
43 [EL_READING] = EPOLLIN,
44 [EL_WRITING] = EPOLLOUT,
45 [EL_RDWR] = EPOLLIN | EPOLLOUT,
46 [EL_IDLE] = EPOLLRDHUP,
49 assert (w->mode == emode || emode == EL_WRITING || emode == EL_READING);
51 if (emode != w->emode) {
52 struct epoll_event event = {
54 .events = evtmode_to_epoll[emode],
56 int action = w->emode == EL_NEW ? EPOLL_CTL_ADD : EPOLL_CTL_MOD;
57 if (epoll_ctl(epollfd, action, w->fd, &event) < 0) {
58 return el_job_release(w, true);
65 int el_job_setmode(job_t *w, el_mode mode)
67 if (w->mode == w->emode) {
69 return el_job_setemode(w, mode);
76 void job_wipe(job_t *w)
79 gnutls_certificate_free_credentials(w->xcred);
81 gnutls_deinit(w->session);
84 static void job_arrau_dtor(job_t **j)
87 IGNORE(el_job_release(*j, EL_KILLED));
90 DO_ARRAY_FUNCS(job_t, job, job_arrau_dtor);
92 static void job_array_remove(job_array *arr, job_t *j)
94 for (int i = 0; i < arr->len; i++) {
95 if (arr->arr[i] == j) {
96 job_array_take(arr, i);
102 job_t *el_job_start(const machine_t *m, void *cfg)
104 job_t *w = job_new();
106 job_array_append(&jobs, w);
107 return m->setup(w, cfg) < 0 ? NULL : w;
110 int el_job_release(job_t *w, el_status reason)
112 w->state = EL_LLP_FINI;
113 if (w->m && w->m->finalize) {
114 w->m->finalize(w, reason);
118 gnutls_bye(w->session, GNUTLS_SHUT_RDWR);
121 job_array_remove(&jobs, w);
126 static int el_job_tlsing(job_t *w, int starttls)
128 int err = gnutls_handshake(w->session);
129 if (err < 0 && !gnutls_error_is_fatal(err)) {
130 int wr = gnutls_record_get_direction(w->session);
131 return el_job_setemode(w, wr ? EL_WRITING : EL_READING);
134 return el_job_release(w, EL_RDHUP);
137 if (!tls_check_certificate (conn))
141 /* set Security Strength Factor (SSF) for SASL */
142 /* NB: gnutls_cipher_get_key_size() returns key length in bytes */
143 w->ssf = gnutls_cipher_get_key_size(gnutls_cipher_get(w->session)) * 8;
144 w->state = EL_LLP_READY;
146 return el_job_setemode(w, w->mode);
147 return w->m->on_event(w, EL_EVT_RUNNING);
150 static int el_job_starttlsing(job_t *w)
152 return el_job_tlsing(w, true);
155 static int el_job_connecting_ssl(job_t *w)
157 return el_job_tlsing(w, false);
160 static int el_job_connecting(job_t *w)
163 socklen_t len = sizeof(err);
165 if (getsockopt(w->fd, SOL_SOCKET, SO_ERROR, (void *)&err, &len) || err)
166 return el_job_release(w, EL_ERROR);
169 w->llp = &el_job_connecting_ssl;
172 w->state = EL_LLP_READY;
173 return w->m->on_event(w, EL_EVT_RUNNING);
176 static int tls_negotiate(job_t *w)
178 static int protocol_priority[] = { GNUTLS_TLS1, GNUTLS_SSL3, 0 };
180 if (gnutls_certificate_allocate_credentials(&w->xcred) < 0)
183 /* ignore errors, maybe file doesn't exist yet */
184 gnutls_certificate_set_x509_trust_file(w->xcred, mod_ssl.cert_file,
185 GNUTLS_X509_FMT_PEM);
187 if (mod_ssl.ca_certificates_file) {
188 gnutls_certificate_set_x509_trust_file(w->xcred,
189 mod_ssl.ca_certificates_file, GNUTLS_X509_FMT_PEM);
191 gnutls_init(&w->session, GNUTLS_CLIENT);
194 gnutls_transport_set_ptr(w->session, (gnutls_transport_ptr)(intptr_t)w->fd);
196 /* disable TLS/SSL protocols as needed */
197 if (!mod_ssl.use_sslv3) {
198 protocol_priority[1] = 0;
201 /* We use default priorities (see gnutls documentation),
202 except for protocol version */
203 gnutls_set_default_priority(w->session);
204 gnutls_protocol_set_priority(w->session, protocol_priority);
205 gnutls_credentials_set(w->session, GNUTLS_CRD_CERTIFICATE, w->xcred);
209 int el_job_connect(job_t *w, struct sockaddr *addr, socklen_t len,
210 int type, int proto, int ssl)
212 int res, sock = socket(addr->sa_family, type, proto);
217 res = fcntl(sock, F_GETFL);
220 if (fcntl(sock, F_SETFL, res | O_NONBLOCK) < 0)
222 if (connect(sock, addr, len) < 0)
226 if (ssl && tls_negotiate(w) < 0)
229 w->llp = &el_job_connecting;
230 return el_job_setmode(w, EL_WRITING);
234 return el_job_release(w, EL_ERROR);
237 int el_job_starttls(job_t *w)
239 if (tls_negotiate(w) < 0)
240 return el_job_release(w, EL_RDHUP);
241 w->state = EL_LLP_INIT;
242 w->llp = &el_job_starttlsing;
246 ssize_t el_job_read(job_t *w, buffer_t *buf)
250 buffer_ensure(buf, BUFSIZ);
253 nr = gnutls_record_recv(w->session, buf->data + buf->len, BUFSIZ);
254 if (nr < 0 && !gnutls_error_is_fatal(nr)) {
255 int wr = gnutls_record_get_direction(w->session);
256 return el_job_setemode(w, wr ? EL_WRITING : EL_READING);
258 EL_JOB_CHECK(el_job_setemode(w, w->mode));
260 nr = read(w->fd, buf->data + buf->len, BUFSIZ);
261 if (nr < 0 && (errno == EINTR || errno == EAGAIN))
265 return el_job_release(w, EL_RDHUP);
266 buffer_extend(buf, nr);
270 ssize_t el_job_write(job_t *w, buffer_t *buf)
278 nr = gnutls_record_send(w->session, buf->data, buf->len);
279 if (nr < 0 && !gnutls_error_is_fatal(nr)) {
280 int wr = gnutls_record_get_direction(w->session);
281 return el_job_setemode(w, wr ? EL_WRITING : EL_READING);
283 EL_JOB_CHECK(el_job_setemode(w, w->mode));
285 nr = write(w->fd, buf->data, buf->len);
286 if (nr < 0 && (errno == EINTR || errno == EAGAIN))
290 return el_job_release(w, EL_RDHUP);
291 buffer_splice(buf, 0, nr, NULL, 0);
295 int el_dispatch(int timeout)
297 struct epoll_event events[FD_SETSIZE];
298 int count = epoll_wait(epollfd, events, countof(events), timeout);
301 if (errno == EAGAIN || errno == EINTR)
303 mutt_error("epoll_wait");
304 mutt_exit(EXIT_FAILURE);
307 while (--count >= 0) {
308 job_t *w = events[count].data.ptr;
309 int event = events[count].events;
318 if (event & EPOLLRDHUP) {
319 IGNORE(el_job_release(w, EL_RDHUP));
320 } else if (w->mode != w->emode) {
321 IGNORE(w->m->on_event(w, EL_EVT_INOUT ^ w->emode));
325 if (event & EPOLLOUT)
327 IGNORE(w->m->on_event(w, evt));
332 IGNORE(el_job_release(w, EL_ERROR));
340 void el_initialize(void)
342 gnutls_global_init();
343 epollfd = epoll_create(1024);
345 mutt_error("epoll_create");
346 mutt_exit(EXIT_FAILURE);
348 job_array_init(&jobs);
351 void el_shutdown(void)
353 job_array_wipe(&jobs);
355 gnutls_global_deinit();