1 /***************************************************************************
3 * Project ___| | | | _ \| |
5 * | (__| |_| | _ <| |___
6 * \___|\___/|_| \_\_____|
8 * Copyright (C) 1998 - 2014, Daniel Stenberg, <daniel@haxx.se>, et al.
10 * This software is licensed as described in the file COPYING, which
11 * you should have received as part of this distribution. The terms
12 * are also available at http://curl.haxx.se/docs/copyright.html.
14 * You may opt to use, copy, modify, merge, publish, distribute and/or sell
15 * copies of the Software, and permit persons to whom the Software is
16 * furnished to do so, under the terms of the COPYING file.
18 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
19 * KIND, either express or implied.
21 ***************************************************************************/
24 * Source file for all GnuTLS-specific code for the TLS/SSL layer. No code
25 * but vtls.c should ever call or use these functions.
27 * Note: don't use the GnuTLS' *_t variable type names in this source code,
28 * since they were not present in 1.0.X.
31 #include "curl_setup.h"
35 #include <gnutls/gnutls.h>
36 #include <gnutls/x509.h>
38 #ifdef USE_GNUTLS_NETTLE
39 #include <gnutls/crypto.h>
40 #include <nettle/md5.h>
47 #include "inet_pton.h"
50 #include "parsedate.h"
51 #include "connect.h" /* for the connect timeout */
55 #define _MPRINTF_REPLACE /* use our functions only */
56 #include <curl/mprintf.h>
57 #include "curl_memory.h"
58 /* The last #include file should be: */
62 Some hackish cast macros based on:
63 http://library.gnome.org/devel/glib/unstable/glib-Type-Conversion-Macros.html
65 #ifndef GNUTLS_POINTER_TO_INT_CAST
66 #define GNUTLS_POINTER_TO_INT_CAST(p) ((int) (long) (p))
68 #ifndef GNUTLS_INT_TO_POINTER_CAST
69 #define GNUTLS_INT_TO_POINTER_CAST(i) ((void*) (long) (i))
72 /* Enable GnuTLS debugging by defining GTLSDEBUG */
73 /*#define GTLSDEBUG */
76 static void tls_log_func(int level, const char *str)
78 fprintf(stderr, "|<%d>| %s", level, str);
81 static bool gtls_inited = FALSE;
83 #if defined(GNUTLS_VERSION_NUMBER)
84 # if (GNUTLS_VERSION_NUMBER >= 0x020c00)
85 # undef gnutls_transport_set_lowat
86 # define gnutls_transport_set_lowat(A,B) Curl_nop_stmt
87 # define USE_GNUTLS_PRIORITY_SET_DIRECT 1
89 # if (GNUTLS_VERSION_NUMBER >= 0x020c03)
90 # define GNUTLS_MAPS_WINSOCK_ERRORS 1
95 # if (GNUTLS_VERSION_NUMBER >= 0x030200)
98 # error http2 builds require GnuTLS >= 3.2.0 for ALPN support
104 * Custom push and pull callback functions used by GNU TLS to read and write
105 * to the socket. These functions are simple wrappers to send() and recv()
106 * (although here using the sread/swrite macros as defined by
107 * curl_setup_once.h).
108 * We use custom functions rather than the GNU TLS defaults because it allows
109 * us to get specific about the fourth "flags" argument, and to use arbitrary
110 * private data with gnutls_transport_set_ptr if we wish.
112 * When these custom push and pull callbacks fail, GNU TLS checks its own
113 * session-specific error variable, and when not set also its own global
114 * errno variable, in order to take appropriate action. GNU TLS does not
115 * require that the transport is actually a socket. This implies that for
116 * Windows builds these callbacks should ideally set the session-specific
117 * error variable using function gnutls_transport_set_errno or as a last
118 * resort global errno variable using gnutls_transport_set_global_errno,
119 * with a transport agnostic error value. This implies that some winsock
120 * error translation must take place in these callbacks.
122 * Paragraph above applies to GNU TLS versions older than 2.12.3, since
123 * this version GNU TLS does its own internal winsock error translation
124 * using system_errno() function.
127 #if defined(USE_WINSOCK) && !defined(GNUTLS_MAPS_WINSOCK_ERRORS)
128 # define gtls_EINTR 4
130 # define gtls_EAGAIN 11
131 static int gtls_mapped_sockerrno(void)
145 static ssize_t Curl_gtls_push(void *s, const void *buf, size_t len)
147 ssize_t ret = swrite(GNUTLS_POINTER_TO_INT_CAST(s), buf, len);
148 #if defined(USE_WINSOCK) && !defined(GNUTLS_MAPS_WINSOCK_ERRORS)
150 gnutls_transport_set_global_errno(gtls_mapped_sockerrno());
155 static ssize_t Curl_gtls_pull(void *s, void *buf, size_t len)
157 ssize_t ret = sread(GNUTLS_POINTER_TO_INT_CAST(s), buf, len);
158 #if defined(USE_WINSOCK) && !defined(GNUTLS_MAPS_WINSOCK_ERRORS)
160 gnutls_transport_set_global_errno(gtls_mapped_sockerrno());
167 * Global GnuTLS init, called from Curl_ssl_init(). This calls functions that
168 * are not thread-safe and thus this function itself is not thread-safe and
169 * must only be called from within curl_global_init() to keep the thread
170 * situation under control!
172 int Curl_gtls_init(void)
176 ret = gnutls_global_init()?0:1;
178 gnutls_global_set_log_function(tls_log_func);
179 gnutls_global_set_log_level(2);
186 int Curl_gtls_cleanup(void)
189 gnutls_global_deinit();
195 static void showtime(struct SessionHandle *data,
200 const struct tm *tm = &buffer;
201 CURLcode result = Curl_gmtime(stamp, &buffer);
205 snprintf(data->state.buffer,
207 "\t %s: %s, %02d %s %4d %02d:%02d:%02d GMT\n",
209 Curl_wkday[tm->tm_wday?tm->tm_wday-1:6],
211 Curl_month[tm->tm_mon],
216 infof(data, "%s\n", data->state.buffer);
219 static gnutls_datum_t load_file (const char *file)
222 gnutls_datum_t loaded_file = { NULL, 0 };
226 if(!(f = fopen(file, "r")))
228 if(fseek(f, 0, SEEK_END) != 0
229 || (filelen = ftell(f)) < 0
230 || fseek(f, 0, SEEK_SET) != 0
231 || !(ptr = malloc((size_t)filelen)))
233 if(fread(ptr, 1, (size_t)filelen, f) < (size_t)filelen) {
238 loaded_file.data = ptr;
239 loaded_file.size = (unsigned int)filelen;
245 static void unload_file(gnutls_datum_t data) {
250 /* this function does a SSL/TLS (re-)handshake */
251 static CURLcode handshake(struct connectdata *conn,
256 struct SessionHandle *data = conn->data;
257 struct ssl_connect_data *connssl = &conn->ssl[sockindex];
258 gnutls_session_t session = conn->ssl[sockindex].session;
259 curl_socket_t sockfd = conn->sock[sockindex];
265 /* check allowed time left */
266 timeout_ms = Curl_timeleft(data, NULL, duringconnect);
269 /* no need to continue if time already is up */
270 failf(data, "SSL connection timeout");
271 return CURLE_OPERATION_TIMEDOUT;
274 /* if ssl is expecting something, check if it's available. */
275 if(connssl->connecting_state == ssl_connect_2_reading
276 || connssl->connecting_state == ssl_connect_2_writing) {
278 curl_socket_t writefd = ssl_connect_2_writing==
279 connssl->connecting_state?sockfd:CURL_SOCKET_BAD;
280 curl_socket_t readfd = ssl_connect_2_reading==
281 connssl->connecting_state?sockfd:CURL_SOCKET_BAD;
283 what = Curl_socket_ready(readfd, writefd,
285 timeout_ms?timeout_ms:1000);
288 failf(data, "select/poll on SSL socket, errno: %d", SOCKERRNO);
289 return CURLE_SSL_CONNECT_ERROR;
294 else if(timeout_ms) {
296 failf(data, "SSL connection timeout at %ld", timeout_ms);
297 return CURLE_OPERATION_TIMEDOUT;
300 /* socket is readable or writable */
303 rc = gnutls_handshake(session);
305 if((rc == GNUTLS_E_AGAIN) || (rc == GNUTLS_E_INTERRUPTED)) {
306 connssl->connecting_state =
307 gnutls_record_get_direction(session)?
308 ssl_connect_2_writing:ssl_connect_2_reading;
313 else if((rc < 0) && !gnutls_error_is_fatal(rc)) {
314 const char *strerr = NULL;
316 if(rc == GNUTLS_E_WARNING_ALERT_RECEIVED) {
317 int alert = gnutls_alert_get(session);
318 strerr = gnutls_alert_get_name(alert);
322 strerr = gnutls_strerror(rc);
324 failf(data, "gnutls_handshake() warning: %s", strerr);
327 const char *strerr = NULL;
329 if(rc == GNUTLS_E_FATAL_ALERT_RECEIVED) {
330 int alert = gnutls_alert_get(session);
331 strerr = gnutls_alert_get_name(alert);
335 strerr = gnutls_strerror(rc);
337 failf(data, "gnutls_handshake() failed: %s", strerr);
338 return CURLE_SSL_CONNECT_ERROR;
341 /* Reset our connect state machine */
342 connssl->connecting_state = ssl_connect_1;
347 static gnutls_x509_crt_fmt_t do_file_type(const char *type)
349 if(!type || !type[0])
350 return GNUTLS_X509_FMT_PEM;
351 if(Curl_raw_equal(type, "PEM"))
352 return GNUTLS_X509_FMT_PEM;
353 if(Curl_raw_equal(type, "DER"))
354 return GNUTLS_X509_FMT_DER;
359 gtls_connect_step1(struct connectdata *conn,
362 struct SessionHandle *data = conn->data;
363 gnutls_session_t session;
367 bool sni = TRUE; /* default is SNI enabled */
369 struct in6_addr addr;
373 #ifndef USE_GNUTLS_PRIORITY_SET_DIRECT
374 static int cipher_priority[] = { GNUTLS_CIPHER_AES_128_GCM,
375 GNUTLS_CIPHER_AES_256_GCM, GNUTLS_CIPHER_AES_128_CBC,
376 GNUTLS_CIPHER_AES_256_CBC, GNUTLS_CIPHER_CAMELLIA_128_CBC,
377 GNUTLS_CIPHER_CAMELLIA_256_CBC, GNUTLS_CIPHER_3DES_CBC,
379 static const int cert_type_priority[] = { GNUTLS_CRT_X509, 0 };
380 static int protocol_priority[] = { 0, 0, 0, 0 };
382 #define GNUTLS_CIPHERS "NORMAL:-ARCFOUR-128:-CTYPE-ALL:+CTYPE-X509"
383 const char* prioritylist;
387 int protocols_size = 2;
388 gnutls_datum_t protocols[2];
391 if(conn->ssl[sockindex].state == ssl_connection_complete)
392 /* to make us tolerant against being called more than once for the
399 /* GnuTLS only supports SSLv3 and TLSv1 */
400 if(data->set.ssl.version == CURL_SSLVERSION_SSLv2) {
401 failf(data, "GnuTLS does not support SSLv2");
402 return CURLE_SSL_CONNECT_ERROR;
404 else if(data->set.ssl.version == CURL_SSLVERSION_SSLv3)
405 sni = FALSE; /* SSLv3 has no SNI */
407 /* allocate a cred struct */
408 rc = gnutls_certificate_allocate_credentials(&conn->ssl[sockindex].cred);
409 if(rc != GNUTLS_E_SUCCESS) {
410 failf(data, "gnutls_cert_all_cred() failed: %s", gnutls_strerror(rc));
411 return CURLE_SSL_CONNECT_ERROR;
415 if(data->set.ssl.authtype == CURL_TLSAUTH_SRP) {
416 infof(data, "Using TLS-SRP username: %s\n", data->set.ssl.username);
418 rc = gnutls_srp_allocate_client_credentials(
419 &conn->ssl[sockindex].srp_client_cred);
420 if(rc != GNUTLS_E_SUCCESS) {
421 failf(data, "gnutls_srp_allocate_client_cred() failed: %s",
422 gnutls_strerror(rc));
423 return CURLE_OUT_OF_MEMORY;
426 rc = gnutls_srp_set_client_credentials(conn->ssl[sockindex].
428 data->set.ssl.username,
429 data->set.ssl.password);
430 if(rc != GNUTLS_E_SUCCESS) {
431 failf(data, "gnutls_srp_set_client_cred() failed: %s",
432 gnutls_strerror(rc));
433 return CURLE_BAD_FUNCTION_ARGUMENT;
438 if(data->set.ssl.CAfile) {
439 /* set the trusted CA cert bundle file */
440 gnutls_certificate_set_verify_flags(conn->ssl[sockindex].cred,
441 GNUTLS_VERIFY_ALLOW_X509_V1_CA_CRT);
443 rc = gnutls_certificate_set_x509_trust_file(conn->ssl[sockindex].cred,
444 data->set.ssl.CAfile,
445 GNUTLS_X509_FMT_PEM);
447 infof(data, "error reading ca cert file %s (%s)\n",
448 data->set.ssl.CAfile, gnutls_strerror(rc));
449 if(data->set.ssl.verifypeer)
450 return CURLE_SSL_CACERT_BADFILE;
453 infof(data, "found %d certificates in %s\n",
454 rc, data->set.ssl.CAfile);
457 if(data->set.ssl.CRLfile) {
458 /* set the CRL list file */
459 rc = gnutls_certificate_set_x509_crl_file(conn->ssl[sockindex].cred,
460 data->set.ssl.CRLfile,
461 GNUTLS_X509_FMT_PEM);
463 failf(data, "error reading crl file %s (%s)",
464 data->set.ssl.CRLfile, gnutls_strerror(rc));
465 return CURLE_SSL_CRL_BADFILE;
468 infof(data, "found %d CRL in %s\n",
469 rc, data->set.ssl.CRLfile);
472 /* Initialize TLS session as a client */
473 rc = gnutls_init(&conn->ssl[sockindex].session, GNUTLS_CLIENT);
474 if(rc != GNUTLS_E_SUCCESS) {
475 failf(data, "gnutls_init() failed: %d", rc);
476 return CURLE_SSL_CONNECT_ERROR;
479 /* convenient assign */
480 session = conn->ssl[sockindex].session;
482 if((0 == Curl_inet_pton(AF_INET, conn->host.name, &addr)) &&
484 (0 == Curl_inet_pton(AF_INET6, conn->host.name, &addr)) &&
487 (gnutls_server_name_set(session, GNUTLS_NAME_DNS, conn->host.name,
488 strlen(conn->host.name)) < 0))
489 infof(data, "WARNING: failed to configure server name indication (SNI) "
492 /* Use default priorities */
493 rc = gnutls_set_default_priority(session);
494 if(rc != GNUTLS_E_SUCCESS)
495 return CURLE_SSL_CONNECT_ERROR;
497 #ifndef USE_GNUTLS_PRIORITY_SET_DIRECT
498 rc = gnutls_cipher_set_priority(session, cipher_priority);
499 if(rc != GNUTLS_E_SUCCESS)
500 return CURLE_SSL_CONNECT_ERROR;
502 /* Sets the priority on the certificate types supported by gnutls. Priority
503 is higher for types specified before others. After specifying the types
504 you want, you must append a 0. */
505 rc = gnutls_certificate_type_set_priority(session, cert_type_priority);
506 if(rc != GNUTLS_E_SUCCESS)
507 return CURLE_SSL_CONNECT_ERROR;
509 if(data->set.ssl.cipher_list != NULL) {
510 failf(data, "can't pass a custom cipher list to older GnuTLS"
512 return CURLE_SSL_CONNECT_ERROR;
515 switch (data->set.ssl.version) {
516 case CURL_SSLVERSION_SSLv3:
517 protocol_priority[0] = GNUTLS_SSL3;
519 case CURL_SSLVERSION_DEFAULT:
520 case CURL_SSLVERSION_TLSv1:
521 protocol_priority[0] = GNUTLS_TLS1_0;
522 protocol_priority[1] = GNUTLS_TLS1_1;
523 protocol_priority[2] = GNUTLS_TLS1_2;
525 case CURL_SSLVERSION_TLSv1_0:
526 protocol_priority[0] = GNUTLS_TLS1_0;
528 case CURL_SSLVERSION_TLSv1_1:
529 protocol_priority[0] = GNUTLS_TLS1_1;
531 case CURL_SSLVERSION_TLSv1_2:
532 protocol_priority[0] = GNUTLS_TLS1_2;
534 case CURL_SSLVERSION_SSLv2:
536 failf(data, "GnuTLS does not support SSLv2");
537 return CURLE_SSL_CONNECT_ERROR;
540 rc = gnutls_protocol_set_priority(session, protocol_priority);
542 switch (data->set.ssl.version) {
543 case CURL_SSLVERSION_SSLv3:
544 prioritylist = GNUTLS_CIPHERS ":-VERS-TLS-ALL:+VERS-SSL3.0";
547 case CURL_SSLVERSION_DEFAULT:
548 case CURL_SSLVERSION_TLSv1:
549 prioritylist = GNUTLS_CIPHERS ":-VERS-SSL3.0";
551 case CURL_SSLVERSION_TLSv1_0:
552 prioritylist = GNUTLS_CIPHERS ":-VERS-SSL3.0:-VERS-TLS-ALL:"
555 case CURL_SSLVERSION_TLSv1_1:
556 prioritylist = GNUTLS_CIPHERS ":-VERS-SSL3.0:-VERS-TLS-ALL:"
559 case CURL_SSLVERSION_TLSv1_2:
560 prioritylist = GNUTLS_CIPHERS ":-VERS-SSL3.0:-VERS-TLS-ALL:"
563 case CURL_SSLVERSION_SSLv2:
565 failf(data, "GnuTLS does not support SSLv2");
566 return CURLE_SSL_CONNECT_ERROR;
569 rc = gnutls_priority_set_direct(session, prioritylist, &err);
573 if(data->set.httpversion == CURL_HTTP_VERSION_2_0) {
574 if(data->set.ssl_enable_alpn) {
575 protocols[0].data = NGHTTP2_PROTO_VERSION_ID;
576 protocols[0].size = NGHTTP2_PROTO_VERSION_ID_LEN;
577 protocols[1].data = ALPN_HTTP_1_1;
578 protocols[1].size = ALPN_HTTP_1_1_LENGTH;
579 gnutls_alpn_set_protocols(session, protocols, protocols_size, 0);
580 infof(data, "ALPN, offering %s, %s\n", NGHTTP2_PROTO_VERSION_ID,
584 infof(data, "SSL, can't negotiate HTTP/2.0 without ALPN\n");
589 if(rc != GNUTLS_E_SUCCESS) {
590 failf(data, "Did you pass a valid GnuTLS cipher list?");
591 return CURLE_SSL_CONNECT_ERROR;
595 if(data->set.str[STRING_CERT]) {
596 if(gnutls_certificate_set_x509_key_file(
597 conn->ssl[sockindex].cred,
598 data->set.str[STRING_CERT],
599 data->set.str[STRING_KEY] ?
600 data->set.str[STRING_KEY] : data->set.str[STRING_CERT],
601 do_file_type(data->set.str[STRING_CERT_TYPE]) ) !=
603 failf(data, "error reading X.509 key or certificate file");
604 return CURLE_SSL_CONNECT_ERROR;
609 /* put the credentials to the current session */
610 if(data->set.ssl.authtype == CURL_TLSAUTH_SRP) {
611 rc = gnutls_credentials_set(session, GNUTLS_CRD_SRP,
612 conn->ssl[sockindex].srp_client_cred);
613 if(rc != GNUTLS_E_SUCCESS)
614 failf(data, "gnutls_credentials_set() failed: %s", gnutls_strerror(rc));
618 rc = gnutls_credentials_set(session, GNUTLS_CRD_CERTIFICATE,
619 conn->ssl[sockindex].cred);
621 /* set the connection handle (file descriptor for the socket) */
622 gnutls_transport_set_ptr(session,
623 GNUTLS_INT_TO_POINTER_CAST(conn->sock[sockindex]));
625 /* register callback functions to send and receive data. */
626 gnutls_transport_set_push_function(session, Curl_gtls_push);
627 gnutls_transport_set_pull_function(session, Curl_gtls_pull);
629 /* lowat must be set to zero when using custom push and pull functions. */
630 gnutls_transport_set_lowat(session, 0);
632 /* This might be a reconnect, so we check for a session ID in the cache
633 to speed up things */
635 if(!Curl_ssl_getsessionid(conn, &ssl_sessionid, &ssl_idsize)) {
636 /* we got a session id, use it! */
637 gnutls_session_set_data(session, ssl_sessionid, ssl_idsize);
639 /* Informational message */
640 infof (data, "SSL re-using session ID\n");
646 static Curl_recv gtls_recv;
647 static Curl_send gtls_send;
650 gtls_connect_step3(struct connectdata *conn,
653 unsigned int cert_list_size;
654 const gnutls_datum_t *chainp;
655 unsigned int verify_status;
656 gnutls_x509_crt_t x509_cert,x509_issuer;
657 gnutls_datum_t issuerp;
658 char certbuf[256]; /* big enough? */
664 struct SessionHandle *data = conn->data;
665 gnutls_session_t session = conn->ssl[sockindex].session;
670 gnutls_datum_t proto;
672 CURLcode result = CURLE_OK;
674 /* This function will return the peer's raw certificate (chain) as sent by
675 the peer. These certificates are in raw format (DER encoded for
676 X.509). In case of a X.509 then a certificate list may be present. The
677 first certificate in the list is the peer's certificate, following the
678 issuer's certificate, then the issuer's issuer etc. */
680 chainp = gnutls_certificate_get_peers(session, &cert_list_size);
682 if(data->set.ssl.verifypeer ||
683 data->set.ssl.verifyhost ||
684 data->set.ssl.issuercert) {
686 if(data->set.ssl.authtype == CURL_TLSAUTH_SRP
687 && data->set.ssl.username != NULL
688 && !data->set.ssl.verifypeer
689 && gnutls_cipher_get(session)) {
690 /* no peer cert, but auth is ok if we have SRP user and cipher and no
695 failf(data, "failed to get server cert");
696 return CURLE_PEER_FAILED_VERIFICATION;
701 infof(data, "\t common name: WARNING couldn't obtain\n");
704 if(data->set.ssl.verifypeer) {
705 /* This function will try to verify the peer's certificate and return its
706 status (trusted, invalid etc.). The value of status should be one or
707 more of the gnutls_certificate_status_t enumerated elements bitwise
708 or'd. To avoid denial of service attacks some default upper limits
709 regarding the certificate key size and chain size are set. To override
710 them use gnutls_certificate_set_verify_limits(). */
712 rc = gnutls_certificate_verify_peers2(session, &verify_status);
714 failf(data, "server cert verify failed: %d", rc);
715 return CURLE_SSL_CONNECT_ERROR;
718 /* verify_status is a bitmask of gnutls_certificate_status bits */
719 if(verify_status & GNUTLS_CERT_INVALID) {
720 if(data->set.ssl.verifypeer) {
721 failf(data, "server certificate verification failed. CAfile: %s "
722 "CRLfile: %s", data->set.ssl.CAfile?data->set.ssl.CAfile:"none",
723 data->set.ssl.CRLfile?data->set.ssl.CRLfile:"none");
724 return CURLE_SSL_CACERT;
727 infof(data, "\t server certificate verification FAILED\n");
730 infof(data, "\t server certificate verification OK\n");
733 infof(data, "\t server certificate verification SKIPPED\n");
735 /* initialize an X.509 certificate structure. */
736 gnutls_x509_crt_init(&x509_cert);
739 /* convert the given DER or PEM encoded Certificate to the native
740 gnutls_x509_crt_t format */
741 gnutls_x509_crt_import(x509_cert, chainp, GNUTLS_X509_FMT_DER);
743 if(data->set.ssl.issuercert) {
744 gnutls_x509_crt_init(&x509_issuer);
745 issuerp = load_file(data->set.ssl.issuercert);
746 gnutls_x509_crt_import(x509_issuer, &issuerp, GNUTLS_X509_FMT_PEM);
747 rc = gnutls_x509_crt_check_issuer(x509_cert,x509_issuer);
748 unload_file(issuerp);
750 failf(data, "server certificate issuer check failed (IssuerCert: %s)",
751 data->set.ssl.issuercert?data->set.ssl.issuercert:"none");
752 return CURLE_SSL_ISSUER_ERROR;
754 infof(data,"\t server certificate issuer check OK (Issuer Cert: %s)\n",
755 data->set.ssl.issuercert?data->set.ssl.issuercert:"none");
758 size=sizeof(certbuf);
759 rc = gnutls_x509_crt_get_dn_by_oid(x509_cert, GNUTLS_OID_X520_COMMON_NAME,
760 0, /* the first and only one */
765 infof(data, "error fetching CN from cert:%s\n",
766 gnutls_strerror(rc));
769 /* This function will check if the given certificate's subject matches the
770 given hostname. This is a basic implementation of the matching described
771 in RFC2818 (HTTPS), which takes into account wildcards, and the subject
772 alternative name PKIX extension. Returns non zero on success, and zero on
774 rc = gnutls_x509_crt_check_hostname(x509_cert, conn->host.name);
777 if(data->set.ssl.verifyhost) {
778 failf(data, "SSL: certificate subject name (%s) does not match "
779 "target host name '%s'", certbuf, conn->host.dispname);
780 gnutls_x509_crt_deinit(x509_cert);
781 return CURLE_PEER_FAILED_VERIFICATION;
784 infof(data, "\t common name: %s (does not match '%s')\n",
785 certbuf, conn->host.dispname);
788 infof(data, "\t common name: %s (matched)\n", certbuf);
790 /* Check for time-based validity */
791 certclock = gnutls_x509_crt_get_expiration_time(x509_cert);
793 if(certclock == (time_t)-1) {
794 failf(data, "server cert expiration date verify failed");
795 return CURLE_SSL_CONNECT_ERROR;
798 if(certclock < time(NULL)) {
799 if(data->set.ssl.verifypeer) {
800 failf(data, "server certificate expiration date has passed.");
801 return CURLE_PEER_FAILED_VERIFICATION;
804 infof(data, "\t server certificate expiration date FAILED\n");
807 infof(data, "\t server certificate expiration date OK\n");
809 certclock = gnutls_x509_crt_get_activation_time(x509_cert);
811 if(certclock == (time_t)-1) {
812 failf(data, "server cert activation date verify failed");
813 return CURLE_SSL_CONNECT_ERROR;
816 if(certclock > time(NULL)) {
817 if(data->set.ssl.verifypeer) {
818 failf(data, "server certificate not activated yet.");
819 return CURLE_PEER_FAILED_VERIFICATION;
822 infof(data, "\t server certificate activation date FAILED\n");
825 infof(data, "\t server certificate activation date OK\n");
838 /* public key algorithm's parameters */
839 algo = gnutls_x509_crt_get_pk_algorithm(x509_cert, &bits);
840 infof(data, "\t certificate public key: %s\n",
841 gnutls_pk_algorithm_get_name(algo));
843 /* version of the X.509 certificate. */
844 infof(data, "\t certificate version: #%d\n",
845 gnutls_x509_crt_get_version(x509_cert));
848 size = sizeof(certbuf);
849 gnutls_x509_crt_get_dn(x509_cert, certbuf, &size);
850 infof(data, "\t subject: %s\n", certbuf);
852 certclock = gnutls_x509_crt_get_activation_time(x509_cert);
853 showtime(data, "start date", certclock);
855 certclock = gnutls_x509_crt_get_expiration_time(x509_cert);
856 showtime(data, "expire date", certclock);
858 size = sizeof(certbuf);
859 gnutls_x509_crt_get_issuer_dn(x509_cert, certbuf, &size);
860 infof(data, "\t issuer: %s\n", certbuf);
862 gnutls_x509_crt_deinit(x509_cert);
864 /* compression algorithm (if any) */
865 ptr = gnutls_compression_get_name(gnutls_compression_get(session));
866 /* the *_get_name() says "NULL" if GNUTLS_COMP_NULL is returned */
867 infof(data, "\t compression: %s\n", ptr);
869 /* the name of the cipher used. ie 3DES. */
870 ptr = gnutls_cipher_get_name(gnutls_cipher_get(session));
871 infof(data, "\t cipher: %s\n", ptr);
873 /* the MAC algorithms name. ie SHA1 */
874 ptr = gnutls_mac_get_name(gnutls_mac_get(session));
875 infof(data, "\t MAC: %s\n", ptr);
878 if(data->set.ssl_enable_alpn) {
879 rc = gnutls_alpn_get_selected_protocol(session, &proto);
881 infof(data, "ALPN, server accepted to use %.*s\n", proto.size,
884 if(proto.size == NGHTTP2_PROTO_VERSION_ID_LEN &&
885 memcmp(NGHTTP2_PROTO_VERSION_ID, proto.data,
886 NGHTTP2_PROTO_VERSION_ID_LEN) == 0) {
887 conn->negnpn = NPN_HTTP2;
889 else if(proto.size == ALPN_HTTP_1_1_LENGTH && memcmp(ALPN_HTTP_1_1,
890 proto.data, ALPN_HTTP_1_1_LENGTH) == 0) {
891 conn->negnpn = NPN_HTTP1_1;
895 infof(data, "ALPN, server did not agree to a protocol\n");
900 conn->ssl[sockindex].state = ssl_connection_complete;
901 conn->recv[sockindex] = gtls_recv;
902 conn->send[sockindex] = gtls_send;
905 /* we always unconditionally get the session id here, as even if we
906 already got it from the cache and asked to use it in the connection, it
907 might've been rejected and then a new one is in use now and we need to
909 void *connect_sessionid;
910 size_t connect_idsize;
912 /* get the session ID data size */
913 gnutls_session_get_data(session, NULL, &connect_idsize);
914 connect_sessionid = malloc(connect_idsize); /* get a buffer for it */
916 if(connect_sessionid) {
917 /* extract session ID to the allocated buffer */
918 gnutls_session_get_data(session, connect_sessionid, &connect_idsize);
920 incache = !(Curl_ssl_getsessionid(conn, &ssl_sessionid, NULL));
922 /* there was one before in the cache, so instead of risking that the
923 previous one was rejected, we just kill that and store the new */
924 Curl_ssl_delsessionid(conn, ssl_sessionid);
927 /* store this session id */
928 result = Curl_ssl_addsessionid(conn, connect_sessionid, connect_idsize);
930 free(connect_sessionid);
931 result = CURLE_OUT_OF_MEMORY;
935 result = CURLE_OUT_OF_MEMORY;
943 * This function is called after the TCP connect has completed. Setup the TLS
944 * layer and do all necessary magic.
946 /* We use connssl->connecting_state to keep track of the connection status;
947 there are three states: 'ssl_connect_1' (not started yet or complete),
948 'ssl_connect_2_reading' (waiting for data from server), and
949 'ssl_connect_2_writing' (waiting to be able to write).
952 gtls_connect_common(struct connectdata *conn,
958 struct ssl_connect_data *connssl = &conn->ssl[sockindex];
960 /* Initiate the connection, if not already done */
961 if(ssl_connect_1==connssl->connecting_state) {
962 rc = gtls_connect_step1 (conn, sockindex);
967 rc = handshake(conn, sockindex, TRUE, nonblocking);
969 /* handshake() sets its own error message with failf() */
972 /* Finish connecting once the handshake is done */
973 if(ssl_connect_1==connssl->connecting_state) {
974 rc = gtls_connect_step3(conn, sockindex);
979 *done = ssl_connect_1==connssl->connecting_state;
985 Curl_gtls_connect_nonblocking(struct connectdata *conn,
989 return gtls_connect_common(conn, sockindex, TRUE, done);
993 Curl_gtls_connect(struct connectdata *conn,
1000 retcode = gtls_connect_common(conn, sockindex, FALSE, &done);
1009 static ssize_t gtls_send(struct connectdata *conn,
1015 ssize_t rc = gnutls_record_send(conn->ssl[sockindex].session, mem, len);
1018 *curlcode = (rc == GNUTLS_E_AGAIN)
1028 void Curl_gtls_close_all(struct SessionHandle *data)
1030 /* FIX: make the OpenSSL code more generic and use parts of it here */
1034 static void close_one(struct connectdata *conn,
1037 if(conn->ssl[idx].session) {
1038 gnutls_bye(conn->ssl[idx].session, GNUTLS_SHUT_RDWR);
1039 gnutls_deinit(conn->ssl[idx].session);
1040 conn->ssl[idx].session = NULL;
1042 if(conn->ssl[idx].cred) {
1043 gnutls_certificate_free_credentials(conn->ssl[idx].cred);
1044 conn->ssl[idx].cred = NULL;
1047 if(conn->ssl[idx].srp_client_cred) {
1048 gnutls_srp_free_client_credentials(conn->ssl[idx].srp_client_cred);
1049 conn->ssl[idx].srp_client_cred = NULL;
1054 void Curl_gtls_close(struct connectdata *conn, int sockindex)
1056 close_one(conn, sockindex);
1060 * This function is called to shut down the SSL layer but keep the
1061 * socket open (CCC - Clear Command Channel)
1063 int Curl_gtls_shutdown(struct connectdata *conn, int sockindex)
1067 struct SessionHandle *data = conn->data;
1071 /* This has only been tested on the proftpd server, and the mod_tls code
1072 sends a close notify alert without waiting for a close notify alert in
1073 response. Thus we wait for a close notify alert from the server, but
1074 we do not send one. Let's hope other servers do the same... */
1076 if(data->set.ftp_ccc == CURLFTPSSL_CCC_ACTIVE)
1077 gnutls_bye(conn->ssl[sockindex].session, GNUTLS_SHUT_WR);
1079 if(conn->ssl[sockindex].session) {
1081 int what = Curl_socket_ready(conn->sock[sockindex],
1082 CURL_SOCKET_BAD, SSL_SHUTDOWN_TIMEOUT);
1084 /* Something to read, let's do it and hope that it is the close
1085 notify alert from the server */
1086 result = gnutls_record_recv(conn->ssl[sockindex].session,
1090 /* This is the expected response. There was no data but only
1091 the close notify alert */
1094 case GNUTLS_E_AGAIN:
1095 case GNUTLS_E_INTERRUPTED:
1096 infof(data, "GNUTLS_E_AGAIN || GNUTLS_E_INTERRUPTED\n");
1104 else if(0 == what) {
1106 failf(data, "SSL shutdown timeout");
1111 /* anything that gets here is fatally bad */
1112 failf(data, "select/poll on SSL socket, errno: %d", SOCKERRNO);
1117 gnutls_deinit(conn->ssl[sockindex].session);
1119 gnutls_certificate_free_credentials(conn->ssl[sockindex].cred);
1122 if(data->set.ssl.authtype == CURL_TLSAUTH_SRP
1123 && data->set.ssl.username != NULL)
1124 gnutls_srp_free_client_credentials(conn->ssl[sockindex].srp_client_cred);
1127 conn->ssl[sockindex].cred = NULL;
1128 conn->ssl[sockindex].session = NULL;
1133 static ssize_t gtls_recv(struct connectdata *conn, /* connection data */
1134 int num, /* socketindex */
1135 char *buf, /* store read data here */
1136 size_t buffersize, /* max amount to read */
1141 ret = gnutls_record_recv(conn->ssl[num].session, buf, buffersize);
1142 if((ret == GNUTLS_E_AGAIN) || (ret == GNUTLS_E_INTERRUPTED)) {
1143 *curlcode = CURLE_AGAIN;
1147 if(ret == GNUTLS_E_REHANDSHAKE) {
1148 /* BLOCKING call, this is bad but a work-around for now. Fixing this "the
1149 proper way" takes a whole lot of work. */
1150 CURLcode rc = handshake(conn, num, FALSE, FALSE);
1152 /* handshake() writes error message on its own */
1155 *curlcode = CURLE_AGAIN; /* then return as if this was a wouldblock */
1160 failf(conn->data, "GnuTLS recv error (%d): %s",
1161 (int)ret, gnutls_strerror((int)ret));
1162 *curlcode = CURLE_RECV_ERROR;
1169 void Curl_gtls_session_free(void *ptr)
1174 size_t Curl_gtls_version(char *buffer, size_t size)
1176 return snprintf(buffer, size, "GnuTLS/%s", gnutls_check_version(NULL));
1179 int Curl_gtls_seed(struct SessionHandle *data)
1181 /* we have the "SSL is seeded" boolean static to prevent multiple
1182 time-consuming seedings in vain */
1183 static bool ssl_seeded = FALSE;
1185 /* Quickly add a bit of entropy */
1186 #ifndef USE_GNUTLS_NETTLE
1187 gcry_fast_random_poll();
1190 if(!ssl_seeded || data->set.str[STRING_SSL_RANDOM_FILE] ||
1191 data->set.str[STRING_SSL_EGDSOCKET]) {
1193 /* TODO: to a good job seeding the RNG
1194 This may involve the gcry_control function and these options:
1195 GCRYCTL_SET_RANDOM_SEED_FILE
1196 GCRYCTL_SET_RNDEGD_SOCKET
1203 void Curl_gtls_random(struct SessionHandle *data,
1204 unsigned char *entropy,
1207 #if defined(USE_GNUTLS_NETTLE)
1209 gnutls_rnd(GNUTLS_RND_RANDOM, entropy, length);
1210 #elif defined(USE_GNUTLS)
1211 Curl_gtls_seed(data); /* Initiate the seed if not already done */
1212 gcry_randomize(entropy, length, GCRY_STRONG_RANDOM);
1216 void Curl_gtls_md5sum(unsigned char *tmp, /* input */
1218 unsigned char *md5sum, /* output */
1221 #if defined(USE_GNUTLS_NETTLE)
1222 struct md5_ctx MD5pw;
1224 md5_update(&MD5pw, (unsigned int)tmplen, tmp);
1225 md5_digest(&MD5pw, (unsigned int)md5len, md5sum);
1226 #elif defined(USE_GNUTLS)
1228 gcry_md_open(&MD5pw, GCRY_MD_MD5, 0);
1229 gcry_md_write(MD5pw, tmp, tmplen);
1230 memcpy(md5sum, gcry_md_read (MD5pw, 0), md5len);
1231 gcry_md_close(MD5pw);
1235 #endif /* USE_GNUTLS */