Index: net/third_party/nss/ssl/ssl3ext.c |
diff --git a/net/third_party/nss/ssl/ssl3ext.c b/net/third_party/nss/ssl/ssl3ext.c |
new file mode 100644 |
index 0000000000000000000000000000000000000000..21bb818598cdc55c84f34e1aa7a3b58e1967a4e1 |
--- /dev/null |
+++ b/net/third_party/nss/ssl/ssl3ext.c |
@@ -0,0 +1,1268 @@ |
+/* |
+ * SSL3 Protocol |
+ * |
+ * ***** BEGIN LICENSE BLOCK ***** |
+ * Version: MPL 1.1/GPL 2.0/LGPL 2.1 |
+ * |
+ * The contents of this file are subject to the Mozilla Public License Version |
+ * 1.1 (the "License"); you may not use this file except in compliance with |
+ * the License. You may obtain a copy of the License at |
+ * http://www.mozilla.org/MPL/ |
+ * |
+ * Software distributed under the License is distributed on an "AS IS" basis, |
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License |
+ * for the specific language governing rights and limitations under the |
+ * License. |
+ * |
+ * The Original Code is the Netscape security libraries. |
+ * |
+ * The Initial Developer of the Original Code is |
+ * Netscape Communications Corporation. |
+ * Portions created by the Initial Developer are Copyright (C) 1994-2000 |
+ * the Initial Developer. All Rights Reserved. |
+ * |
+ * Contributor(s): |
+ * Dr Vipul Gupta <vipul.gupta@sun.com> and |
+ * Douglas Stebila <douglas@stebila.ca>, Sun Microsystems Laboratories |
+ * Nagendra Modadugu <ngm@google.com>, Google Inc. |
+ * |
+ * Alternatively, the contents of this file may be used under the terms of |
+ * either the GNU General Public License Version 2 or later (the "GPL"), or |
+ * the GNU Lesser General Public License Version 2.1 or later (the "LGPL"), |
+ * in which case the provisions of the GPL or the LGPL are applicable instead |
+ * of those above. If you wish to allow use of your version of this file only |
+ * under the terms of either the GPL or the LGPL, and not to allow others to |
+ * use your version of this file under the terms of the MPL, indicate your |
+ * decision by deleting the provisions above and replace them with the notice |
+ * and other provisions required by the GPL or the LGPL. If you do not delete |
+ * the provisions above, a recipient may use your version of this file under |
+ * the terms of any one of the MPL, the GPL or the LGPL. |
+ * |
+ * ***** END LICENSE BLOCK ***** */ |
+ |
+/* TLS extension code moved here from ssl3ecc.c */ |
+/* $Id: ssl3ext.c,v 1.5 2009/11/07 18:23:06 wtc%google.com Exp $ */ |
+ |
+#include "nssrenam.h" |
+#include "nss.h" |
+#include "ssl.h" |
+#include "sslimpl.h" |
+#include "pk11pub.h" |
+#include "blapi.h" |
+#include "prinit.h" |
+ |
+static unsigned char key_name[SESS_TICKET_KEY_NAME_LEN]; |
+static PK11SymKey *session_ticket_enc_key_pkcs11 = NULL; |
+static PK11SymKey *session_ticket_mac_key_pkcs11 = NULL; |
+ |
+static unsigned char session_ticket_enc_key[32]; |
+static unsigned char session_ticket_mac_key[SHA256_LENGTH]; |
+ |
+static PRBool session_ticket_keys_initialized = PR_FALSE; |
+static PRCallOnceType generate_session_keys_once; |
+ |
+static PRInt32 ssl3_SendServerNameXtn(sslSocket * ss, |
+ PRBool append, PRUint32 maxBytes); |
+static SECStatus ssl3_ParseEncryptedSessionTicket(sslSocket *ss, |
+ SECItem *data, EncryptedSessionTicket *enc_session_ticket); |
+static SECStatus ssl3_AppendToItem(SECItem *item, const unsigned char *buf, |
+ PRUint32 bytes); |
+static SECStatus ssl3_AppendNumberToItem(SECItem *item, PRUint32 num, |
+ PRInt32 lenSize); |
+static SECStatus ssl3_GetSessionTicketKeysPKCS11(sslSocket *ss, |
+ PK11SymKey **aes_key, PK11SymKey **mac_key); |
+static SECStatus ssl3_GetSessionTicketKeys(const unsigned char **aes_key, |
+ PRUint32 *aes_key_length, const unsigned char **mac_key, |
+ PRUint32 *mac_key_length); |
+ |
+/* |
+ * Write bytes. Using this function means the SECItem structure |
+ * cannot be freed. The caller is expected to call this function |
+ * on a shallow copy of the structure. |
+ */ |
+static SECStatus |
+ssl3_AppendToItem(SECItem *item, const unsigned char *buf, PRUint32 bytes) |
+{ |
+ if (bytes > item->len) |
+ return SECFailure; |
+ |
+ PORT_Memcpy(item->data, buf, bytes); |
+ item->data += bytes; |
+ item->len -= bytes; |
+ return SECSuccess; |
+} |
+ |
+/* |
+ * Write a number in network byte order. Using this function means the |
+ * SECItem structure cannot be freed. The caller is expected to call |
+ * this function on a shallow copy of the structure. |
+ */ |
+static SECStatus |
+ssl3_AppendNumberToItem(SECItem *item, PRUint32 num, PRInt32 lenSize) |
+{ |
+ SECStatus rv; |
+ uint8 b[4]; |
+ uint8 * p = b; |
+ |
+ switch (lenSize) { |
+ case 4: |
+ *p++ = (uint8) (num >> 24); |
+ case 3: |
+ *p++ = (uint8) (num >> 16); |
+ case 2: |
+ *p++ = (uint8) (num >> 8); |
+ case 1: |
+ *p = (uint8) num; |
+ } |
+ rv = ssl3_AppendToItem(item, &b[0], lenSize); |
+ return rv; |
+} |
+ |
+static SECStatus ssl3_SessionTicketShutdown(void* appData, void* nssData) |
+{ |
+ if (session_ticket_enc_key_pkcs11) { |
+ PK11_FreeSymKey(session_ticket_enc_key_pkcs11); |
+ session_ticket_enc_key_pkcs11 = NULL; |
+ } |
+ if (session_ticket_mac_key_pkcs11) { |
+ PK11_FreeSymKey(session_ticket_mac_key_pkcs11); |
+ session_ticket_mac_key_pkcs11 = NULL; |
+ } |
+ PORT_Memset(&generate_session_keys_once, 0, |
+ sizeof(generate_session_keys_once)); |
+ return SECSuccess; |
+} |
+ |
+ |
+static PRStatus |
+ssl3_GenerateSessionTicketKeysPKCS11(void *data) |
+{ |
+ SECStatus rv; |
+ sslSocket *ss = (sslSocket *)data; |
+ SECKEYPrivateKey *svrPrivKey = ss->serverCerts[kt_rsa].SERVERKEY; |
+ SECKEYPublicKey *svrPubKey = ss->serverCerts[kt_rsa].serverKeyPair->pubKey; |
+ |
+ if (svrPrivKey == NULL || svrPubKey == NULL) { |
+ SSL_DBG(("%d: SSL[%d]: Pub or priv key(s) is NULL.", |
+ SSL_GETPID(), ss->fd)); |
+ goto loser; |
+ } |
+ |
+ /* Get a copy of the session keys from shared memory. */ |
+ PORT_Memcpy(key_name, SESS_TICKET_KEY_NAME_PREFIX, |
+ sizeof(SESS_TICKET_KEY_NAME_PREFIX)); |
+ if (!ssl_GetSessionTicketKeysPKCS11(svrPrivKey, svrPubKey, |
+ ss->pkcs11PinArg, &key_name[SESS_TICKET_KEY_NAME_PREFIX_LEN], |
+ &session_ticket_enc_key_pkcs11, &session_ticket_mac_key_pkcs11)) |
+ return PR_FAILURE; |
+ |
+ rv = NSS_RegisterShutdown(ssl3_SessionTicketShutdown, NULL); |
+ if (rv != SECSuccess) |
+ goto loser; |
+ |
+ return PR_SUCCESS; |
+ |
+loser: |
+ ssl3_SessionTicketShutdown(NULL, NULL); |
+ return PR_FAILURE; |
+} |
+ |
+static SECStatus |
+ssl3_GetSessionTicketKeysPKCS11(sslSocket *ss, PK11SymKey **aes_key, |
+ PK11SymKey **mac_key) |
+{ |
+ if (PR_CallOnceWithArg(&generate_session_keys_once, |
+ ssl3_GenerateSessionTicketKeysPKCS11, ss) != PR_SUCCESS) |
+ return SECFailure; |
+ |
+ if (session_ticket_enc_key_pkcs11 == NULL || |
+ session_ticket_mac_key_pkcs11 == NULL) |
+ return SECFailure; |
+ |
+ *aes_key = session_ticket_enc_key_pkcs11; |
+ *mac_key = session_ticket_mac_key_pkcs11; |
+ return SECSuccess; |
+} |
+ |
+static PRStatus |
+ssl3_GenerateSessionTicketKeys(void) |
+{ |
+ PORT_Memcpy(key_name, SESS_TICKET_KEY_NAME_PREFIX, |
+ sizeof(SESS_TICKET_KEY_NAME_PREFIX)); |
+ |
+ if (!ssl_GetSessionTicketKeys(&key_name[SESS_TICKET_KEY_NAME_PREFIX_LEN], |
+ session_ticket_enc_key, session_ticket_mac_key)) |
+ return PR_FAILURE; |
+ |
+ session_ticket_keys_initialized = PR_TRUE; |
+ return PR_SUCCESS; |
+} |
+ |
+static SECStatus |
+ssl3_GetSessionTicketKeys(const unsigned char **aes_key, |
+ PRUint32 *aes_key_length, const unsigned char **mac_key, |
+ PRUint32 *mac_key_length) |
+{ |
+ if (PR_CallOnce(&generate_session_keys_once, |
+ ssl3_GenerateSessionTicketKeys) != SECSuccess) |
+ return SECFailure; |
+ |
+ if (!session_ticket_keys_initialized) |
+ return SECFailure; |
+ |
+ *aes_key = session_ticket_enc_key; |
+ *aes_key_length = sizeof(session_ticket_enc_key); |
+ *mac_key = session_ticket_mac_key; |
+ *mac_key_length = sizeof(session_ticket_mac_key); |
+ |
+ return SECSuccess; |
+} |
+ |
+/* Table of handlers for received TLS hello extensions, one per extension. |
+ * In the second generation, this table will be dynamic, and functions |
+ * will be registered here. |
+ */ |
+static const ssl3HelloExtensionHandler clientHelloHandlers[] = { |
+ { server_name_xtn, &ssl3_HandleServerNameXtn }, |
+#ifdef NSS_ENABLE_ECC |
+ { elliptic_curves_xtn, &ssl3_HandleSupportedCurvesXtn }, |
+ { ec_point_formats_xtn, &ssl3_HandleSupportedPointFormatsXtn }, |
+#endif |
+ { session_ticket_xtn, &ssl3_ServerHandleSessionTicketXtn }, |
+ { -1, NULL } |
+}; |
+ |
+static const ssl3HelloExtensionHandler serverHelloHandlers[] = { |
+ { server_name_xtn, &ssl3_HandleServerNameXtn }, |
+ /* TODO: add a handler for ec_point_formats_xtn */ |
+ { session_ticket_xtn, &ssl3_ClientHandleSessionTicketXtn }, |
+ { -1, NULL } |
+}; |
+ |
+/* Table of functions to format TLS hello extensions, one per extension. |
+ * This static table is for the formatting of client hello extensions. |
+ * The server's table of hello senders is dynamic, in the socket struct, |
+ * and sender functions are registered there. |
+ */ |
+static const |
+ssl3HelloExtensionSender clientHelloSenders[MAX_EXTENSIONS] = { |
+ { server_name_xtn, &ssl3_SendServerNameXtn }, |
+#ifdef NSS_ENABLE_ECC |
+ { elliptic_curves_xtn, &ssl3_SendSupportedCurvesXtn }, |
+ { ec_point_formats_xtn, &ssl3_SendSupportedPointFormatsXtn }, |
+#else |
+ { -1, NULL }, |
+ { -1, NULL }, |
+#endif |
+ { session_ticket_xtn, ssl3_SendSessionTicketXtn } |
+}; |
+ |
+static PRBool |
+arrayContainsExtension(const PRUint16 *array, PRUint32 len, PRUint16 ex_type) |
+{ |
+ int i; |
+ for (i = 0; i < len; i++) { |
+ if (ex_type == array[i]) |
+ return PR_TRUE; |
+ } |
+ return PR_FALSE; |
+} |
+ |
+PRBool |
+ssl3_ExtensionNegotiated(sslSocket *ss, PRUint16 ex_type) { |
+ TLSExtensionData *xtnData = &ss->xtnData; |
+ return arrayContainsExtension(xtnData->negotiated, |
+ xtnData->numNegotiated, ex_type); |
+} |
+ |
+static PRBool |
+ssl3_ClientExtensionAdvertised(sslSocket *ss, PRUint16 ex_type) { |
+ TLSExtensionData *xtnData = &ss->xtnData; |
+ return arrayContainsExtension(xtnData->advertised, |
+ xtnData->numAdvertised, ex_type); |
+} |
+ |
+/* Format an SNI extension, using the name from the socket's URL, |
+ * unless that name is a dotted decimal string. |
+ */ |
+static PRInt32 |
+ssl3_SendServerNameXtn( |
+ sslSocket * ss, |
+ PRBool append, |
+ PRUint32 maxBytes) |
+{ |
+ PRUint32 len; |
+ PRNetAddr netAddr; |
+ |
+ /* must have a hostname */ |
+ if (!ss || !ss->url || !ss->url[0]) |
+ return 0; |
+ /* must not be an IPv4 or IPv6 address */ |
+ if (PR_SUCCESS == PR_StringToNetAddr(ss->url, &netAddr)) { |
+ /* is an IP address (v4 or v6) */ |
+ return 0; |
+ } |
+ len = PORT_Strlen(ss->url); |
+ if (append && maxBytes >= len + 9) { |
+ SECStatus rv; |
+ /* extension_type */ |
+ rv = ssl3_AppendHandshakeNumber(ss, server_name_xtn, 2); |
+ if (rv != SECSuccess) return -1; |
+ /* length of extension_data */ |
+ rv = ssl3_AppendHandshakeNumber(ss, len + 5, 2); |
+ if (rv != SECSuccess) return -1; |
+ /* length of server_name_list */ |
+ rv = ssl3_AppendHandshakeNumber(ss, len + 3, 2); |
+ if (rv != SECSuccess) return -1; |
+ /* Name Type (host_name) */ |
+ rv = ssl3_AppendHandshake(ss, "\0", 1); |
+ if (rv != SECSuccess) return -1; |
+ /* HostName (length and value) */ |
+ rv = ssl3_AppendHandshakeVariable(ss, (unsigned char *)ss->url, len, 2); |
+ if (rv != SECSuccess) return -1; |
+ if (!ss->sec.isServer) { |
+ TLSExtensionData *xtnData = &ss->xtnData; |
+ xtnData->advertised[xtnData->numAdvertised++] = server_name_xtn; |
+ } |
+ } |
+ return len + 9; |
+} |
+ |
+/* handle an incoming SNI extension, by ignoring it. */ |
+SECStatus |
+ssl3_HandleServerNameXtn(sslSocket * ss, PRUint16 ex_type, SECItem *data) |
+{ |
+ /* TODO: if client, should verify extension_data is empty. */ |
+ /* TODO: if server, should send empty extension_data. */ |
+ /* For now, we ignore this, as if we didn't understand it. :-) */ |
+ return SECSuccess; |
+} |
+ |
+/* Called by both clients and servers. |
+ * Clients sends a filled in session ticket if one is available, and otherwise |
+ * sends an empty ticket. Servers always send empty tickets. |
+ */ |
+PRInt32 |
+ssl3_SendSessionTicketXtn( |
+ sslSocket * ss, |
+ PRBool append, |
+ PRUint32 maxBytes) |
+{ |
+ PRInt32 extension_length; |
+ NewSessionTicket *session_ticket = NULL; |
+ |
+ /* Ignore the SessionTicket extension if processing is disabled. */ |
+ if (!ss->opt.enableSessionTickets) |
+ return 0; |
+ |
+ /* Empty extension length = extension_type (2-bytes) + |
+ * length(extension_data) (2-bytes) |
+ */ |
+ extension_length = 4; |
+ |
+ /* If we are a client then send a session ticket if one is availble. |
+ * Servers that support the extension and are willing to negotiate the |
+ * the extension always respond with an empty extension. |
+ */ |
+ if (!ss->sec.isServer) { |
+ sslSessionID *sid = ss->sec.ci.sid; |
+ session_ticket = &sid->u.ssl3.sessionTicket; |
+ if (session_ticket->ticket.data) { |
+ if (ss->xtnData.ticketTimestampVerified) { |
+ extension_length += session_ticket->ticket.len; |
+ } else if (!append && |
+ (session_ticket->ticket_lifetime_hint == 0 || |
+ (session_ticket->ticket_lifetime_hint + |
+ session_ticket->received_timestamp > ssl_Time()))) { |
+ extension_length += session_ticket->ticket.len; |
+ ss->xtnData.ticketTimestampVerified = PR_TRUE; |
+ } |
+ } |
+ } |
+ |
+ if (append && maxBytes >= extension_length) { |
+ SECStatus rv; |
+ /* extension_type */ |
+ rv = ssl3_AppendHandshakeNumber(ss, session_ticket_xtn, 2); |
+ if (rv != SECSuccess) |
+ goto loser; |
+ if (session_ticket && session_ticket->ticket.data && |
+ ss->xtnData.ticketTimestampVerified) { |
+ rv = ssl3_AppendHandshakeVariable(ss, session_ticket->ticket.data, |
+ session_ticket->ticket.len, 2); |
+ ss->xtnData.ticketTimestampVerified = PR_FALSE; |
+ } else { |
+ rv = ssl3_AppendHandshakeNumber(ss, 0, 2); |
+ } |
+ if (rv != SECSuccess) |
+ goto loser; |
+ |
+ if (!ss->sec.isServer) { |
+ TLSExtensionData *xtnData = &ss->xtnData; |
+ xtnData->advertised[xtnData->numAdvertised++] = session_ticket_xtn; |
+ } |
+ } else if (maxBytes < extension_length) { |
+ PORT_Assert(0); |
+ return 0; |
+ } |
+ return extension_length; |
+ |
+ loser: |
+ ss->xtnData.ticketTimestampVerified = PR_FALSE; |
+ return -1; |
+} |
+ |
+/* |
+ * NewSessionTicket |
+ * Called from ssl3_HandleFinished |
+ */ |
+SECStatus |
+ssl3_SendNewSessionTicket(sslSocket *ss) |
+{ |
+ int i; |
+ SECStatus rv; |
+ NewSessionTicket ticket; |
+ SECItem plaintext; |
+ SECItem plaintext_item = {0, NULL, 0}; |
+ SECItem ciphertext = {0, NULL, 0}; |
+ PRUint32 ciphertext_length; |
+ PRBool ms_is_wrapped; |
+ unsigned char wrapped_ms[SSL3_MASTER_SECRET_LENGTH]; |
+ SECItem ms_item = {0, NULL, 0}; |
+ SSL3KEAType effectiveExchKeyType = ssl_kea_null; |
+ PRUint32 padding_length; |
+ PRUint32 message_length; |
+ PRUint32 cert_length; |
+ uint8 length_buf[4]; |
+ PRUint32 now; |
+ PK11SymKey *aes_key_pkcs11; |
+ PK11SymKey *mac_key_pkcs11; |
+ const unsigned char *aes_key; |
+ const unsigned char *mac_key; |
+ PRUint32 aes_key_length; |
+ PRUint32 mac_key_length; |
+ PRUint64 aes_ctx_buf[MAX_CIPHER_CONTEXT_LLONGS]; |
+ AESContext *aes_ctx; |
+ CK_MECHANISM_TYPE cipherMech = CKM_AES_CBC; |
+ PK11Context *aes_ctx_pkcs11; |
+ const SECHashObject *hashObj = NULL; |
+ PRUint64 hmac_ctx_buf[MAX_MAC_CONTEXT_LLONGS]; |
+ HMACContext *hmac_ctx; |
+ CK_MECHANISM_TYPE macMech = CKM_SHA256_HMAC; |
+ PK11Context *hmac_ctx_pkcs11; |
+ unsigned char computed_mac[TLS_EX_SESS_TICKET_MAC_LENGTH]; |
+ unsigned int computed_mac_length; |
+ unsigned char iv[AES_BLOCK_SIZE]; |
+ SECItem ivItem; |
+ CK_MECHANISM_TYPE msWrapMech = 0; /* dummy default value, |
+ * must be >= 0 */ |
+ |
+ SSL_TRC(3, ("%d: SSL3[%d]: send session_ticket handshake", |
+ SSL_GETPID(), ss->fd)); |
+ |
+ PORT_Assert( ss->opt.noLocks || ssl_HaveXmitBufLock(ss)); |
+ PORT_Assert( ss->opt.noLocks || ssl_HaveSSL3HandshakeLock(ss)); |
+ |
+ ticket.ticket_lifetime_hint = TLS_EX_SESS_TICKET_LIFETIME_HINT; |
+ cert_length = (ss->opt.requestCertificate && ss->sec.ci.sid->peerCert) ? |
+ 3 + ss->sec.ci.sid->peerCert->derCert.len : 0; |
+ |
+ /* Get IV and encryption keys */ |
+ ivItem.data = iv; |
+ ivItem.len = sizeof(iv); |
+ rv = PK11_GenerateRandom(iv, sizeof(iv)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ if (ss->opt.bypassPKCS11) { |
+ rv = ssl3_GetSessionTicketKeys(&aes_key, &aes_key_length, |
+ &mac_key, &mac_key_length); |
+ } else { |
+ rv = ssl3_GetSessionTicketKeysPKCS11(ss, &aes_key_pkcs11, |
+ &mac_key_pkcs11); |
+ } |
+ if (rv != SECSuccess) goto loser; |
+ |
+ if (ss->ssl3.pwSpec->msItem.len && ss->ssl3.pwSpec->msItem.data) { |
+ /* The master secret is available unwrapped. */ |
+ ms_item.data = ss->ssl3.pwSpec->msItem.data; |
+ ms_item.len = ss->ssl3.pwSpec->msItem.len; |
+ ms_is_wrapped = PR_FALSE; |
+ } else { |
+ /* Extract the master secret wrapped. */ |
+ sslSessionID sid; |
+ PORT_Memset(&sid, 0, sizeof(sslSessionID)); |
+ |
+ if (ss->ssl3.hs.kea_def->kea == kea_ecdhe_rsa) { |
+ effectiveExchKeyType = kt_rsa; |
+ } else { |
+ effectiveExchKeyType = ss->ssl3.hs.kea_def->exchKeyType; |
+ } |
+ |
+ rv = ssl3_CacheWrappedMasterSecret(ss, &sid, ss->ssl3.pwSpec, |
+ effectiveExchKeyType); |
+ if (rv == SECSuccess) { |
+ if (sid.u.ssl3.keys.wrapped_master_secret_len > sizeof(wrapped_ms)) |
+ goto loser; |
+ memcpy(wrapped_ms, sid.u.ssl3.keys.wrapped_master_secret, |
+ sid.u.ssl3.keys.wrapped_master_secret_len); |
+ ms_item.data = wrapped_ms; |
+ ms_item.len = sid.u.ssl3.keys.wrapped_master_secret_len; |
+ msWrapMech = sid.u.ssl3.masterWrapMech; |
+ } else { |
+ /* TODO: else send an empty ticket. */ |
+ goto loser; |
+ } |
+ ms_is_wrapped = PR_TRUE; |
+ } |
+ |
+ ciphertext_length = |
+ sizeof(PRUint16) /* ticket_version */ |
+ + sizeof(SSL3ProtocolVersion) /* ssl_version */ |
+ + sizeof(ssl3CipherSuite) /* ciphersuite */ |
+ + 1 /* compression */ |
+ + 10 /* cipher spec parameters */ |
+ + 1 /* SessionTicket.ms_is_wrapped */ |
+ + 1 /* effectiveExchKeyType */ |
+ + 4 /* msWrapMech */ |
+ + 2 /* master_secret.length */ |
+ + ms_item.len /* master_secret */ |
+ + 1 /* client_auth_type */ |
+ + cert_length /* cert */ |
+ + sizeof(ticket.ticket_lifetime_hint); |
+ padding_length = AES_BLOCK_SIZE - |
+ (ciphertext_length % AES_BLOCK_SIZE); |
+ ciphertext_length += padding_length; |
+ |
+ message_length = |
+ sizeof(ticket.ticket_lifetime_hint) /* ticket_lifetime_hint */ |
+ + 2 /* length field for NewSessionTicket.ticket */ |
+ + SESS_TICKET_KEY_NAME_LEN /* key_name */ |
+ + AES_BLOCK_SIZE /* iv */ |
+ + 2 /* length field for NewSessionTicket.ticket.encrypted_state */ |
+ + ciphertext_length /* encrypted_state */ |
+ + TLS_EX_SESS_TICKET_MAC_LENGTH; /* mac */ |
+ |
+ if (SECITEM_AllocItem(NULL, &plaintext_item, ciphertext_length) == NULL) |
+ goto loser; |
+ |
+ plaintext = plaintext_item; |
+ |
+ /* ticket_version */ |
+ rv = ssl3_AppendNumberToItem(&plaintext, TLS_EX_SESS_TICKET_VERSION, |
+ sizeof(PRUint16)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ /* ssl_version */ |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->version, |
+ sizeof(SSL3ProtocolVersion)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ /* ciphersuite */ |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->ssl3.hs.cipher_suite, |
+ sizeof(ssl3CipherSuite)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ /* compression */ |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->ssl3.hs.compression, 1); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ /* cipher spec parameters */ |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->sec.authAlgorithm, 1); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->sec.authKeyBits, 4); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->sec.keaType, 1); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, ss->sec.keaKeyBits, 4); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ /* master_secret */ |
+ rv = ssl3_AppendNumberToItem(&plaintext, ms_is_wrapped, 1); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, effectiveExchKeyType, 1); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, msWrapMech, 4); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, ms_item.len, 2); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendToItem(&plaintext, ms_item.data, ms_item.len); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ /* client_identity */ |
+ if (ss->opt.requestCertificate && ss->sec.ci.sid->peerCert) { |
+ rv = ssl3_AppendNumberToItem(&plaintext, CLIENT_AUTH_CERTIFICATE, 1); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendNumberToItem(&plaintext, |
+ ss->sec.ci.sid->peerCert->derCert.len, 3); |
+ if (rv != SECSuccess) goto loser; |
+ rv = ssl3_AppendToItem(&plaintext, |
+ ss->sec.ci.sid->peerCert->derCert.data, |
+ ss->sec.ci.sid->peerCert->derCert.len); |
+ if (rv != SECSuccess) goto loser; |
+ } else { |
+ rv = ssl3_AppendNumberToItem(&plaintext, 0, 1); |
+ if (rv != SECSuccess) goto loser; |
+ } |
+ |
+ /* timestamp */ |
+ now = ssl_Time(); |
+ rv = ssl3_AppendNumberToItem(&plaintext, now, |
+ sizeof(ticket.ticket_lifetime_hint)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ PORT_Assert(plaintext.len == padding_length); |
+ for (i = 0; i < padding_length; i++) |
+ plaintext.data[i] = (unsigned char)padding_length; |
+ |
+ if (SECITEM_AllocItem(NULL, &ciphertext, ciphertext_length) == NULL) { |
+ rv = SECFailure; |
+ goto loser; |
+ } |
+ |
+ /* Generate encrypted portion of ticket. */ |
+ if (ss->opt.bypassPKCS11) { |
+ aes_ctx = (AESContext *)aes_ctx_buf; |
+ rv = AES_InitContext(aes_ctx, aes_key, aes_key_length, iv, |
+ NSS_AES_CBC, 1, AES_BLOCK_SIZE); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = AES_Encrypt(aes_ctx, ciphertext.data, &ciphertext.len, |
+ ciphertext.len, plaintext_item.data, |
+ plaintext_item.len); |
+ if (rv != SECSuccess) goto loser; |
+ } else { |
+ aes_ctx_pkcs11 = PK11_CreateContextBySymKey(cipherMech, |
+ CKA_ENCRYPT, aes_key_pkcs11, &ivItem); |
+ if (!aes_ctx_pkcs11) |
+ goto loser; |
+ |
+ rv = PK11_CipherOp(aes_ctx_pkcs11, ciphertext.data, |
+ (int *)&ciphertext.len, ciphertext.len, |
+ plaintext_item.data, plaintext_item.len); |
+ PK11_Finalize(aes_ctx_pkcs11); |
+ PK11_DestroyContext(aes_ctx_pkcs11, PR_TRUE); |
+ if (rv != SECSuccess) goto loser; |
+ } |
+ |
+ /* Convert ciphertext length to network order. */ |
+ length_buf[0] = (ciphertext.len >> 8) & 0xff; |
+ length_buf[1] = (ciphertext.len ) & 0xff; |
+ |
+ /* Compute MAC. */ |
+ if (ss->opt.bypassPKCS11) { |
+ hmac_ctx = (HMACContext *)hmac_ctx_buf; |
+ hashObj = HASH_GetRawHashObject(HASH_AlgSHA256); |
+ if (HMAC_Init(hmac_ctx, hashObj, mac_key, |
+ mac_key_length, PR_FALSE) != SECSuccess) |
+ goto loser; |
+ |
+ HMAC_Begin(hmac_ctx); |
+ HMAC_Update(hmac_ctx, key_name, SESS_TICKET_KEY_NAME_LEN); |
+ HMAC_Update(hmac_ctx, iv, sizeof(iv)); |
+ HMAC_Update(hmac_ctx, (unsigned char *)length_buf, 2); |
+ HMAC_Update(hmac_ctx, ciphertext.data, ciphertext.len); |
+ HMAC_Finish(hmac_ctx, computed_mac, &computed_mac_length, |
+ sizeof(computed_mac)); |
+ } else { |
+ SECItem macParam; |
+ macParam.data = NULL; |
+ macParam.len = 0; |
+ hmac_ctx_pkcs11 = PK11_CreateContextBySymKey(macMech, |
+ CKA_SIGN, mac_key_pkcs11, &macParam); |
+ if (!hmac_ctx_pkcs11) |
+ goto loser; |
+ |
+ rv = PK11_DigestBegin(hmac_ctx_pkcs11); |
+ rv = PK11_DigestOp(hmac_ctx_pkcs11, key_name, |
+ SESS_TICKET_KEY_NAME_LEN); |
+ rv = PK11_DigestOp(hmac_ctx_pkcs11, iv, sizeof(iv)); |
+ rv = PK11_DigestOp(hmac_ctx_pkcs11, (unsigned char *)length_buf, 2); |
+ rv = PK11_DigestOp(hmac_ctx_pkcs11, ciphertext.data, ciphertext.len); |
+ rv = PK11_DigestFinal(hmac_ctx_pkcs11, computed_mac, |
+ &computed_mac_length, sizeof(computed_mac)); |
+ PK11_DestroyContext(hmac_ctx_pkcs11, PR_TRUE); |
+ if (rv != SECSuccess) goto loser; |
+ } |
+ |
+ /* Serialize the handshake message. */ |
+ rv = ssl3_AppendHandshakeHeader(ss, new_session_ticket, message_length); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = ssl3_AppendHandshakeNumber(ss, ticket.ticket_lifetime_hint, |
+ sizeof(ticket.ticket_lifetime_hint)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = ssl3_AppendHandshakeNumber(ss, |
+ message_length - sizeof(ticket.ticket_lifetime_hint) - 2, 2); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = ssl3_AppendHandshake(ss, key_name, SESS_TICKET_KEY_NAME_LEN); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = ssl3_AppendHandshake(ss, iv, sizeof(iv)); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = ssl3_AppendHandshakeVariable(ss, ciphertext.data, ciphertext.len, 2); |
+ if (rv != SECSuccess) goto loser; |
+ |
+ rv = ssl3_AppendHandshake(ss, computed_mac, computed_mac_length); |
+ if (rv != SECSuccess) goto loser; |
+ |
+loser: |
+ if (plaintext_item.data) |
+ SECITEM_FreeItem(&plaintext_item, PR_FALSE); |
+ if (ciphertext.data) |
+ SECITEM_FreeItem(&ciphertext, PR_FALSE); |
+ |
+ return rv; |
+} |
+ |
+/* When a client receives a SessionTicket extension a NewSessionTicket |
+ * message is expected during the handshake. |
+ */ |
+SECStatus |
+ssl3_ClientHandleSessionTicketXtn(sslSocket *ss, PRUint16 ex_type, |
+ SECItem *data) |
+{ |
+ if (data->len != 0) |
+ return SECFailure; |
+ |
+ /* Keep track of negotiated extensions. */ |
+ ss->xtnData.negotiated[ss->xtnData.numNegotiated++] = ex_type; |
+ return SECSuccess; |
+} |
+ |
+SECStatus |
+ssl3_ServerHandleSessionTicketXtn(sslSocket *ss, PRUint16 ex_type, |
+ SECItem *data) |
+{ |
+ SECStatus rv; |
+ SECItem *decrypted_state = NULL; |
+ SessionTicket *parsed_session_ticket = NULL; |
+ sslSessionID *sid = NULL; |
+ SSL3Statistics *ssl3stats; |
+ |
+ /* Ignore the SessionTicket extension if processing is disabled. */ |
+ if (!ss->opt.enableSessionTickets) |
+ return SECSuccess; |
+ |
+ /* Keep track of negotiated extensions. */ |
+ ss->xtnData.negotiated[ss->xtnData.numNegotiated++] = ex_type; |
+ |
+ /* Parse the received ticket sent in by the client. We are |
+ * lenient about some parse errors, falling back to a fullshake |
+ * instead of terminating the current connection. |
+ */ |
+ if (data->len == 0) { |
+ ss->xtnData.emptySessionTicket = PR_TRUE; |
+ } else { |
+ int i; |
+ SECItem extension_data; |
+ EncryptedSessionTicket enc_session_ticket; |
+ unsigned char computed_mac[TLS_EX_SESS_TICKET_MAC_LENGTH]; |
+ unsigned int computed_mac_length; |
+ const SECHashObject *hashObj; |
+ const unsigned char *aes_key; |
+ const unsigned char *mac_key; |
+ PK11SymKey *aes_key_pkcs11; |
+ PK11SymKey *mac_key_pkcs11; |
+ PRUint32 aes_key_length; |
+ PRUint32 mac_key_length; |
+ PRUint64 hmac_ctx_buf[MAX_MAC_CONTEXT_LLONGS]; |
+ HMACContext *hmac_ctx; |
+ PK11Context *hmac_ctx_pkcs11; |
+ CK_MECHANISM_TYPE macMech = CKM_SHA256_HMAC; |
+ PRUint64 aes_ctx_buf[MAX_CIPHER_CONTEXT_LLONGS]; |
+ AESContext *aes_ctx; |
+ PK11Context *aes_ctx_pkcs11; |
+ CK_MECHANISM_TYPE cipherMech = CKM_AES_CBC; |
+ unsigned char * padding; |
+ PRUint32 padding_length; |
+ unsigned char *buffer; |
+ unsigned int buffer_len; |
+ PRInt32 temp; |
+ SECItem cert_item; |
+ |
+ /* Turn off stateless session resumption if the client sends a |
+ * SessionTicket extension, even if the extension turns out to be |
+ * malformed (ss->sec.ci.sid is non-NULL when doing session |
+ * renegotiation.) |
+ */ |
+ if (ss->sec.ci.sid != NULL) { |
+ ss->sec.uncache(ss->sec.ci.sid); |
+ ssl_FreeSID(ss->sec.ci.sid); |
+ ss->sec.ci.sid = NULL; |
+ } |
+ |
+ extension_data.data = data->data; /* Keep a copy for future use. */ |
+ extension_data.len = data->len; |
+ |
+ if (ssl3_ParseEncryptedSessionTicket(ss, data, &enc_session_ticket) |
+ != SECSuccess) |
+ return SECFailure; |
+ |
+ /* Get session ticket keys. */ |
+ if (ss->opt.bypassPKCS11) { |
+ rv = ssl3_GetSessionTicketKeys(&aes_key, &aes_key_length, |
+ &mac_key, &mac_key_length); |
+ } else { |
+ rv = ssl3_GetSessionTicketKeysPKCS11(ss, &aes_key_pkcs11, |
+ &mac_key_pkcs11); |
+ } |
+ if (rv != SECSuccess) { |
+ SSL_DBG(("%d: SSL[%d]: Unable to get/generate session ticket keys.", |
+ SSL_GETPID(), ss->fd)); |
+ goto loser; |
+ } |
+ |
+ /* If the ticket sent by the client was generated under a key different |
+ * from the one we have, bypass ticket processing. |
+ */ |
+ if (PORT_Memcmp(enc_session_ticket.key_name, key_name, |
+ SESS_TICKET_KEY_NAME_LEN) != 0) { |
+ SSL_DBG(("%d: SSL[%d]: Session ticket key_name sent mismatch.", |
+ SSL_GETPID(), ss->fd)); |
+ goto no_ticket; |
+ } |
+ |
+ /* Verify the MAC on the ticket. MAC verification may also |
+ * fail if the MAC key has been recently refreshed. |
+ */ |
+ if (ss->opt.bypassPKCS11) { |
+ hmac_ctx = (HMACContext *)hmac_ctx_buf; |
+ hashObj = HASH_GetRawHashObject(HASH_AlgSHA256); |
+ if (HMAC_Init(hmac_ctx, hashObj, mac_key, |
+ sizeof(session_ticket_mac_key), PR_FALSE) != SECSuccess) |
+ goto no_ticket; |
+ HMAC_Begin(hmac_ctx); |
+ HMAC_Update(hmac_ctx, extension_data.data, |
+ extension_data.len - TLS_EX_SESS_TICKET_MAC_LENGTH); |
+ if (HMAC_Finish(hmac_ctx, computed_mac, &computed_mac_length, |
+ sizeof(computed_mac)) != SECSuccess) |
+ goto no_ticket; |
+ } else { |
+ SECItem macParam; |
+ macParam.data = NULL; |
+ macParam.len = 0; |
+ hmac_ctx_pkcs11 = PK11_CreateContextBySymKey(macMech, |
+ CKA_SIGN, mac_key_pkcs11, &macParam); |
+ if (!hmac_ctx_pkcs11) { |
+ SSL_DBG(("%d: SSL[%d]: Unable to create HMAC context: %d.", |
+ SSL_GETPID(), ss->fd, PORT_GetError())); |
+ goto no_ticket; |
+ } else { |
+ SSL_DBG(("%d: SSL[%d]: Successfully created HMAC context.", |
+ SSL_GETPID(), ss->fd)); |
+ } |
+ rv = PK11_DigestBegin(hmac_ctx_pkcs11); |
+ rv = PK11_DigestOp(hmac_ctx_pkcs11, extension_data.data, |
+ extension_data.len - TLS_EX_SESS_TICKET_MAC_LENGTH); |
+ if (rv != SECSuccess) { |
+ PK11_DestroyContext(hmac_ctx_pkcs11, PR_TRUE); |
+ goto no_ticket; |
+ } |
+ rv = PK11_DigestFinal(hmac_ctx_pkcs11, computed_mac, |
+ &computed_mac_length, sizeof(computed_mac)); |
+ PK11_DestroyContext(hmac_ctx_pkcs11, PR_TRUE); |
+ if (rv != SECSuccess) |
+ goto no_ticket; |
+ } |
+ if (NSS_SecureMemcmp(computed_mac, enc_session_ticket.mac, |
+ computed_mac_length) != 0) { |
+ SSL_DBG(("%d: SSL[%d]: Session ticket MAC mismatch.", |
+ SSL_GETPID(), ss->fd)); |
+ goto no_ticket; |
+ } |
+ |
+ /* We ignore key_name for now. |
+ * This is ok as MAC verification succeeded. |
+ */ |
+ |
+ /* Decrypt the ticket. */ |
+ |
+ /* Plaintext is shorter than the ciphertext due to padding. */ |
+ decrypted_state = SECITEM_AllocItem(NULL, NULL, |
+ enc_session_ticket.encrypted_state.len); |
+ |
+ if (ss->opt.bypassPKCS11) { |
+ aes_ctx = (AESContext *)aes_ctx_buf; |
+ rv = AES_InitContext(aes_ctx, aes_key, |
+ sizeof(session_ticket_enc_key), enc_session_ticket.iv, |
+ NSS_AES_CBC, 0,AES_BLOCK_SIZE); |
+ if (rv != SECSuccess) { |
+ SSL_DBG(("%d: SSL[%d]: Unable to create AES context.", |
+ SSL_GETPID(), ss->fd)); |
+ goto no_ticket; |
+ } |
+ |
+ rv = AES_Decrypt(aes_ctx, decrypted_state->data, |
+ &decrypted_state->len, decrypted_state->len, |
+ enc_session_ticket.encrypted_state.data, |
+ enc_session_ticket.encrypted_state.len); |
+ if (rv != SECSuccess) |
+ goto no_ticket; |
+ } else { |
+ SECItem ivItem; |
+ ivItem.data = enc_session_ticket.iv; |
+ ivItem.len = AES_BLOCK_SIZE; |
+ aes_ctx_pkcs11 = PK11_CreateContextBySymKey(cipherMech, |
+ CKA_DECRYPT, aes_key_pkcs11, &ivItem); |
+ if (!aes_ctx_pkcs11) { |
+ SSL_DBG(("%d: SSL[%d]: Unable to create AES context.", |
+ SSL_GETPID(), ss->fd)); |
+ goto no_ticket; |
+ } |
+ |
+ rv = PK11_CipherOp(aes_ctx_pkcs11, decrypted_state->data, |
+ (int *)&decrypted_state->len, decrypted_state->len, |
+ enc_session_ticket.encrypted_state.data, |
+ enc_session_ticket.encrypted_state.len); |
+ PK11_Finalize(aes_ctx_pkcs11); |
+ PK11_DestroyContext(aes_ctx_pkcs11, PR_TRUE); |
+ if (rv != SECSuccess) |
+ goto no_ticket; |
+ } |
+ |
+ /* Check padding. */ |
+ padding_length = |
+ (PRUint32)decrypted_state->data[decrypted_state->len - 1]; |
+ if (padding_length == 0 || padding_length > AES_BLOCK_SIZE) |
+ goto no_ticket; |
+ |
+ padding = &decrypted_state->data[decrypted_state->len - padding_length]; |
+ for (i = 0; i < padding_length; i++, padding++) { |
+ if (padding_length != (PRUint32)*padding) |
+ goto no_ticket; |
+ } |
+ |
+ /* Deserialize session state. */ |
+ buffer = decrypted_state->data; |
+ buffer_len = decrypted_state->len; |
+ |
+ parsed_session_ticket = PORT_ZAlloc(sizeof(SessionTicket)); |
+ if (parsed_session_ticket == NULL) { |
+ rv = SECFailure; |
+ goto loser; |
+ } |
+ |
+ /* Read ticket_version (which is ignored for now.) */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 2, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->ticket_version = (SSL3ProtocolVersion)temp; |
+ |
+ /* Read SSLVersion. */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 2, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->ssl_version = (SSL3ProtocolVersion)temp; |
+ |
+ /* Read cipher_suite. */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 2, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->cipher_suite = (ssl3CipherSuite)temp; |
+ |
+ /* Read compression_method. */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 1, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->compression_method = (SSLCompressionMethod)temp; |
+ |
+ /* Read cipher spec parameters. */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 1, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->authAlgorithm = (SSLSignType)temp; |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 4, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->authKeyBits = (PRUint32)temp; |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 1, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->keaType = (SSLKEAType)temp; |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 4, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->keaKeyBits = (PRUint32)temp; |
+ |
+ /* Read wrapped master_secret. */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 1, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->ms_is_wrapped = (PRBool)temp; |
+ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 1, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->exchKeyType = (SSL3KEAType)temp; |
+ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 4, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->msWrapMech = (CK_MECHANISM_TYPE)temp; |
+ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 2, &buffer, &buffer_len); |
+ if (temp < 0) goto no_ticket; |
+ parsed_session_ticket->ms_length = (PRUint16)temp; |
+ if (parsed_session_ticket->ms_length == 0 || /* sanity check MS. */ |
+ parsed_session_ticket->ms_length > |
+ sizeof(parsed_session_ticket->master_secret)) |
+ goto no_ticket; |
+ |
+ /* Allow for the wrapped master secret to be longer. */ |
+ if (buffer_len < sizeof(SSL3_MASTER_SECRET_LENGTH)) |
+ goto no_ticket; |
+ PORT_Memcpy(parsed_session_ticket->master_secret, buffer, |
+ parsed_session_ticket->ms_length); |
+ buffer += parsed_session_ticket->ms_length; |
+ buffer_len -= parsed_session_ticket->ms_length; |
+ |
+ /* Read client_identity */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 1, &buffer, &buffer_len); |
+ if (temp < 0) |
+ goto no_ticket; |
+ parsed_session_ticket->client_identity.client_auth_type = |
+ (ClientAuthenticationType)temp; |
+ switch(parsed_session_ticket->client_identity.client_auth_type) { |
+ case CLIENT_AUTH_ANONYMOUS: |
+ break; |
+ case CLIENT_AUTH_CERTIFICATE: |
+ rv = ssl3_ConsumeHandshakeVariable(ss, &cert_item, 3, |
+ &buffer, &buffer_len); |
+ if (rv != SECSuccess) goto no_ticket; |
+ rv = SECITEM_CopyItem(NULL, &parsed_session_ticket->peer_cert, |
+ &cert_item); |
+ if (rv != SECSuccess) goto no_ticket; |
+ break; |
+ default: |
+ goto no_ticket; |
+ } |
+ /* Read timestamp. */ |
+ temp = ssl3_ConsumeHandshakeNumber(ss, 4, &buffer, &buffer_len); |
+ if (temp < 0) |
+ goto no_ticket; |
+ parsed_session_ticket->timestamp = (PRUint32)temp; |
+ |
+ /* Done parsing. Check that all bytes have been consumed. */ |
+ if (buffer_len != padding_length) |
+ goto no_ticket; |
+ |
+ /* Use the ticket if it has not expired, otherwise free the allocated |
+ * memory since the ticket is of no use. |
+ */ |
+ if (parsed_session_ticket->timestamp != 0 && |
+ parsed_session_ticket->timestamp + |
+ TLS_EX_SESS_TICKET_LIFETIME_HINT > ssl_Time()) { |
+ |
+ sid = ssl3_NewSessionID(ss, PR_TRUE); |
+ if (sid == NULL) { |
+ rv = SECFailure; |
+ goto loser; |
+ } |
+ |
+ /* Copy over parameters. */ |
+ sid->version = parsed_session_ticket->ssl_version; |
+ sid->u.ssl3.cipherSuite = parsed_session_ticket->cipher_suite; |
+ sid->u.ssl3.compression = parsed_session_ticket->compression_method; |
+ sid->authAlgorithm = parsed_session_ticket->authAlgorithm; |
+ sid->authKeyBits = parsed_session_ticket->authKeyBits; |
+ sid->keaType = parsed_session_ticket->keaType; |
+ sid->keaKeyBits = parsed_session_ticket->keaKeyBits; |
+ |
+ /* Copy master secret. */ |
+ if (ss->opt.bypassPKCS11 && |
+ parsed_session_ticket->ms_is_wrapped) |
+ goto no_ticket; |
+ if (parsed_session_ticket->ms_length > |
+ sizeof(sid->u.ssl3.keys.wrapped_master_secret)) |
+ goto no_ticket; |
+ PORT_Memcpy(sid->u.ssl3.keys.wrapped_master_secret, |
+ parsed_session_ticket->master_secret, |
+ parsed_session_ticket->ms_length); |
+ sid->u.ssl3.keys.wrapped_master_secret_len = |
+ parsed_session_ticket->ms_length; |
+ sid->u.ssl3.exchKeyType = parsed_session_ticket->exchKeyType; |
+ sid->u.ssl3.masterWrapMech = parsed_session_ticket->msWrapMech; |
+ sid->u.ssl3.keys.msIsWrapped = |
+ parsed_session_ticket->ms_is_wrapped; |
+ sid->u.ssl3.masterValid = PR_TRUE; |
+ sid->u.ssl3.keys.resumable = PR_TRUE; |
+ |
+ /* Copy over client cert from session ticket if there is one. */ |
+ if (parsed_session_ticket->peer_cert.data != NULL) { |
+ if (sid->peerCert != NULL) |
+ CERT_DestroyCertificate(sid->peerCert); |
+ sid->peerCert = CERT_NewTempCertificate(ss->dbHandle, |
+ &parsed_session_ticket->peer_cert, NULL, PR_FALSE, PR_TRUE); |
+ if (sid->peerCert == NULL) { |
+ rv = SECFailure; |
+ goto loser; |
+ } |
+ } |
+ ss->statelessResume = PR_TRUE; |
+ ss->sec.ci.sid = sid; |
+ } |
+ } |
+ |
+ if (0) { |
+no_ticket: |
+ SSL_DBG(("%d: SSL[%d]: Session ticket parsing failed.", |
+ SSL_GETPID(), ss->fd)); |
+ ssl3stats = SSL_GetStatistics(); |
+ SSL_AtomicIncrementLong(& ssl3stats->hch_sid_ticket_parse_failures ); |
+ if (sid) { |
+ ssl_FreeSID(sid); |
+ sid = NULL; |
+ } |
+ } |
+ rv = SECSuccess; |
+ |
+loser: |
+ if (decrypted_state != NULL) { |
+ SECITEM_FreeItem(decrypted_state, PR_TRUE); |
+ decrypted_state = NULL; |
+ } |
+ |
+ if (parsed_session_ticket != NULL) { |
+ if (parsed_session_ticket->peer_cert.data) { |
+ SECITEM_FreeItem(&parsed_session_ticket->peer_cert, PR_FALSE); |
+ } |
+ PORT_ZFree(parsed_session_ticket, sizeof(SessionTicket)); |
+ } |
+ |
+ return rv; |
+} |
+ |
+/* |
+ * Read bytes. Using this function means the SECItem structure |
+ * cannot be freed. The caller is expected to call this function |
+ * on a shallow copy of the structure. |
+ */ |
+static SECStatus |
+ssl3_ConsumeFromItem(SECItem *item, unsigned char **buf, PRUint32 bytes) |
+{ |
+ if (bytes > item->len) |
+ return SECFailure; |
+ |
+ *buf = item->data; |
+ item->data += bytes; |
+ item->len -= bytes; |
+ return SECSuccess; |
+} |
+ |
+static SECStatus |
+ssl3_ParseEncryptedSessionTicket(sslSocket *ss, SECItem *data, |
+ EncryptedSessionTicket *enc_session_ticket) |
+{ |
+ if (ssl3_ConsumeFromItem(data, &enc_session_ticket->key_name, |
+ SESS_TICKET_KEY_NAME_LEN) != SECSuccess) |
+ return SECFailure; |
+ if (ssl3_ConsumeFromItem(data, &enc_session_ticket->iv, |
+ AES_BLOCK_SIZE) != SECSuccess) |
+ return SECFailure; |
+ if (ssl3_ConsumeHandshakeVariable(ss, &enc_session_ticket->encrypted_state, |
+ 2, &data->data, &data->len) != SECSuccess) |
+ return SECFailure; |
+ if (ssl3_ConsumeFromItem(data, &enc_session_ticket->mac, |
+ TLS_EX_SESS_TICKET_MAC_LENGTH) != SECSuccess) |
+ return SECFailure; |
+ if (data->len != 0) /* Make sure that we have consumed all bytes. */ |
+ return SECFailure; |
+ |
+ return SECSuccess; |
+} |
+ |
+/* go through hello extensions in buffer "b". |
+ * For each one, find the extension handler in the table, and |
+ * if present, invoke that handler. |
+ * Servers ignore any extensions with unknown extension types. |
+ * Clients reject any extensions with unadvertised extension types. |
+ */ |
+SECStatus |
+ssl3_HandleHelloExtensions(sslSocket *ss, SSL3Opaque **b, PRUint32 *length) |
+{ |
+ const ssl3HelloExtensionHandler * handlers = |
+ ss->sec.isServer ? clientHelloHandlers : serverHelloHandlers; |
+ |
+ while (*length) { |
+ const ssl3HelloExtensionHandler * handler; |
+ SECStatus rv; |
+ PRInt32 extension_type; |
+ SECItem extension_data; |
+ |
+ /* Get the extension's type field */ |
+ extension_type = ssl3_ConsumeHandshakeNumber(ss, 2, b, length); |
+ if (extension_type < 0) /* failure to decode extension_type */ |
+ return SECFailure; /* alert already sent */ |
+ |
+ /* get the data for this extension, so we can pass it or skip it. */ |
+ rv = ssl3_ConsumeHandshakeVariable(ss, &extension_data, 2, b, length); |
+ if (rv != SECSuccess) |
+ return rv; |
+ |
+ /* Check whether the server sent an extension which was not advertised |
+ * in the ClientHello. |
+ */ |
+ if (!ss->sec.isServer && |
+ !ssl3_ClientExtensionAdvertised(ss, extension_type)) |
+ return SECFailure; /* TODO: send unsupported_extension alert */ |
+ |
+ /* Check whether an extension has been sent multiple times. */ |
+ if (ssl3_ExtensionNegotiated(ss, extension_type)) |
+ return SECFailure; |
+ |
+ /* find extension_type in table of Hello Extension Handlers */ |
+ for (handler = handlers; handler->ex_type >= 0; handler++) { |
+ /* if found, call this handler */ |
+ if (handler->ex_type == extension_type) { |
+ rv = (*handler->ex_handler)(ss, (PRUint16)extension_type, |
+ &extension_data); |
+ /* Ignore this result */ |
+ /* Treat all bad extensions as unrecognized types. */ |
+ break; |
+ } |
+ } |
+ } |
+ return SECSuccess; |
+} |
+ |
+/* Add a callback function to the table of senders of server hello extensions. |
+ */ |
+SECStatus |
+ssl3_RegisterServerHelloExtensionSender(sslSocket *ss, PRUint16 ex_type, |
+ ssl3HelloExtensionSenderFunc cb) |
+{ |
+ int i; |
+ ssl3HelloExtensionSender *sender = &ss->xtnData.serverSenders[0]; |
+ |
+ for (i = 0; i < MAX_EXTENSIONS; ++i, ++sender) { |
+ if (!sender->ex_sender) { |
+ sender->ex_type = ex_type; |
+ sender->ex_sender = cb; |
+ return SECSuccess; |
+ } |
+ /* detect duplicate senders */ |
+ PORT_Assert(sender->ex_type != ex_type); |
+ if (sender->ex_type == ex_type) { |
+ /* duplicate */ |
+ break; |
+ } |
+ } |
+ PORT_Assert(i < MAX_EXTENSIONS); /* table needs to grow */ |
+ PORT_SetError(SEC_ERROR_LIBRARY_FAILURE); |
+ return SECFailure; |
+} |
+ |
+/* call each of the extension senders and return the accumulated length */ |
+PRInt32 |
+ssl3_CallHelloExtensionSenders(sslSocket *ss, PRBool append, PRUint32 maxBytes, |
+ const ssl3HelloExtensionSender *sender) |
+{ |
+ PRInt32 total_exten_len = 0; |
+ int i; |
+ |
+ if (!sender) |
+ sender = &clientHelloSenders[0]; |
+ |
+ for (i = 0; i < MAX_EXTENSIONS; ++i, ++sender) { |
+ if (sender->ex_sender) { |
+ PRInt32 extLen = (*sender->ex_sender)(ss, append, maxBytes); |
+ if (extLen < 0) |
+ return -1; |
+ maxBytes -= extLen; |
+ total_exten_len += extLen; |
+ } |
+ } |
+ return total_exten_len; |
+} |