| Index: net/socket/ssl_client_socket_win.cc
|
| diff --git a/net/socket/ssl_client_socket_win.cc b/net/socket/ssl_client_socket_win.cc
|
| deleted file mode 100644
|
| index ecc7f0e0f0381b51f760b1d5037fbffb3e945948..0000000000000000000000000000000000000000
|
| --- a/net/socket/ssl_client_socket_win.cc
|
| +++ /dev/null
|
| @@ -1,1635 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "net/socket/ssl_client_socket_win.h"
|
| -
|
| -#include <schnlsp.h>
|
| -
|
| -#include <algorithm>
|
| -#include <map>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/compiler_specific.h"
|
| -#include "base/lazy_instance.h"
|
| -#include "base/stl_util.h"
|
| -#include "base/string_util.h"
|
| -#include "base/synchronization/lock.h"
|
| -#include "base/utf_string_conversions.h"
|
| -#include "net/base/cert_verifier.h"
|
| -#include "net/base/connection_type_histograms.h"
|
| -#include "net/base/host_port_pair.h"
|
| -#include "net/base/io_buffer.h"
|
| -#include "net/base/net_log.h"
|
| -#include "net/base/net_errors.h"
|
| -#include "net/base/single_request_cert_verifier.h"
|
| -#include "net/base/ssl_cert_request_info.h"
|
| -#include "net/base/ssl_connection_status_flags.h"
|
| -#include "net/base/ssl_info.h"
|
| -#include "net/base/x509_certificate_net_log_param.h"
|
| -#include "net/base/x509_util.h"
|
| -#include "net/socket/client_socket_handle.h"
|
| -
|
| -#pragma comment(lib, "secur32.lib")
|
| -
|
| -namespace net {
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -// TODO(wtc): See http://msdn.microsoft.com/en-us/library/aa377188(VS.85).aspx
|
| -// for the other error codes we may need to map.
|
| -static int MapSecurityError(SECURITY_STATUS err) {
|
| - // There are numerous security error codes, but these are the ones we thus
|
| - // far find interesting.
|
| - switch (err) {
|
| - case SEC_E_WRONG_PRINCIPAL: // Schannel - server certificate error.
|
| - case CERT_E_CN_NO_MATCH: // CryptoAPI
|
| - return ERR_CERT_COMMON_NAME_INVALID;
|
| - case SEC_E_UNTRUSTED_ROOT: // Schannel - server certificate error or
|
| - // unknown_ca alert.
|
| - case CERT_E_UNTRUSTEDROOT: // CryptoAPI
|
| - return ERR_CERT_AUTHORITY_INVALID;
|
| - case SEC_E_CERT_EXPIRED: // Schannel - server certificate error or
|
| - // certificate_expired alert.
|
| - case CERT_E_EXPIRED: // CryptoAPI
|
| - return ERR_CERT_DATE_INVALID;
|
| - case CRYPT_E_NO_REVOCATION_CHECK:
|
| - return ERR_CERT_NO_REVOCATION_MECHANISM;
|
| - case CRYPT_E_REVOCATION_OFFLINE:
|
| - return ERR_CERT_UNABLE_TO_CHECK_REVOCATION;
|
| - case CRYPT_E_REVOKED: // CryptoAPI and Schannel server certificate error,
|
| - // or certificate_revoked alert.
|
| - return ERR_CERT_REVOKED;
|
| -
|
| - // We received one of the following alert messages from the server:
|
| - // bad_certificate
|
| - // unsupported_certificate
|
| - // certificate_unknown
|
| - case SEC_E_CERT_UNKNOWN:
|
| - case CERT_E_ROLE:
|
| - return ERR_CERT_INVALID;
|
| -
|
| - // We received one of the following alert messages from the server:
|
| - // decode_error
|
| - // export_restriction
|
| - // handshake_failure
|
| - // illegal_parameter
|
| - // record_overflow
|
| - // unexpected_message
|
| - // and all other TLS alerts not explicitly specified elsewhere.
|
| - case SEC_E_ILLEGAL_MESSAGE:
|
| - // We received one of the following alert messages from the server:
|
| - // decrypt_error
|
| - // decryption_failed
|
| - case SEC_E_DECRYPT_FAILURE:
|
| - // We received one of the following alert messages from the server:
|
| - // bad_record_mac
|
| - // decompression_failure
|
| - case SEC_E_MESSAGE_ALTERED:
|
| - // TODO(rsleevi): Add SEC_E_INTERNAL_ERROR, which corresponds to an
|
| - // internal_error alert message being received. However, it is also used
|
| - // by Schannel for authentication errors that happen locally, so it has
|
| - // been omitted to prevent masking them as protocol errors.
|
| - return ERR_SSL_PROTOCOL_ERROR;
|
| -
|
| - case SEC_E_LOGON_DENIED: // Received a access_denied alert.
|
| - return ERR_BAD_SSL_CLIENT_AUTH_CERT;
|
| -
|
| - case SEC_E_UNSUPPORTED_FUNCTION: // Received a protocol_version alert.
|
| - case SEC_E_ALGORITHM_MISMATCH: // Received an insufficient_security alert.
|
| - return ERR_SSL_VERSION_OR_CIPHER_MISMATCH;
|
| -
|
| - case SEC_E_NO_CREDENTIALS:
|
| - return ERR_SSL_CLIENT_AUTH_CERT_NO_PRIVATE_KEY;
|
| - case SEC_E_INVALID_HANDLE:
|
| - case SEC_E_INVALID_TOKEN:
|
| - LOG(ERROR) << "Unexpected error " << err;
|
| - return ERR_UNEXPECTED;
|
| - case SEC_E_OK:
|
| - return OK;
|
| - default:
|
| - LOG(WARNING) << "Unknown error " << err << " mapped to net::ERR_FAILED";
|
| - return ERR_FAILED;
|
| - }
|
| -}
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -// A bitmask consisting of these bit flags encodes which versions of the SSL
|
| -// protocol (SSL 3.0 and TLS 1.0) are enabled.
|
| -// TODO(wtc): support TLS 1.1 and TLS 1.2 on Windows Vista and later.
|
| -enum {
|
| - SSL3 = 1 << 0,
|
| - TLS1 = 1 << 1,
|
| - SSL_VERSION_MASKS = 1 << 2 // The number of SSL version bitmasks.
|
| -};
|
| -
|
| -// CredHandleClass simply gives a default constructor and a destructor to
|
| -// SSPI's CredHandle type (a C struct).
|
| -class CredHandleClass : public CredHandle {
|
| - public:
|
| - CredHandleClass() {
|
| - SecInvalidateHandle(this);
|
| - }
|
| -
|
| - ~CredHandleClass() {
|
| - if (SecIsValidHandle(this)) {
|
| - SECURITY_STATUS status = FreeCredentialsHandle(this);
|
| - DCHECK(status == SEC_E_OK);
|
| - }
|
| - }
|
| -};
|
| -
|
| -// A table of CredHandles.
|
| -class CredHandleTable {
|
| - public:
|
| - CredHandleTable() {}
|
| -
|
| - ~CredHandleTable() {
|
| - STLDeleteContainerPairSecondPointers(client_cert_creds_.begin(),
|
| - client_cert_creds_.end());
|
| - }
|
| -
|
| - int GetHandle(PCCERT_CONTEXT client_cert,
|
| - int ssl_version_mask,
|
| - CredHandle** handle_ptr) {
|
| - DCHECK(0 < ssl_version_mask &&
|
| - ssl_version_mask < arraysize(anonymous_creds_));
|
| - CredHandleClass* handle;
|
| - base::AutoLock lock(lock_);
|
| - if (client_cert) {
|
| - CredHandleMapKey key = std::make_pair(client_cert, ssl_version_mask);
|
| - CredHandleMap::const_iterator it = client_cert_creds_.find(key);
|
| - if (it == client_cert_creds_.end()) {
|
| - handle = new CredHandleClass;
|
| - client_cert_creds_[key] = handle;
|
| - } else {
|
| - handle = it->second;
|
| - }
|
| - } else {
|
| - handle = &anonymous_creds_[ssl_version_mask];
|
| - }
|
| - if (!SecIsValidHandle(handle)) {
|
| - int result = InitializeHandle(handle, client_cert, ssl_version_mask);
|
| - if (result != OK)
|
| - return result;
|
| - }
|
| - *handle_ptr = handle;
|
| - return OK;
|
| - }
|
| -
|
| - private:
|
| - // CredHandleMapKey is a std::pair consisting of these two components:
|
| - // PCCERT_CONTEXT client_cert
|
| - // int ssl_version_mask
|
| - typedef std::pair<PCCERT_CONTEXT, int> CredHandleMapKey;
|
| -
|
| - typedef std::map<CredHandleMapKey, CredHandleClass*> CredHandleMap;
|
| -
|
| - // Returns OK on success or a network error code on failure.
|
| - static int InitializeHandle(CredHandle* handle,
|
| - PCCERT_CONTEXT client_cert,
|
| - int ssl_version_mask);
|
| -
|
| - base::Lock lock_;
|
| -
|
| - // Anonymous (no client certificate) CredHandles for all possible
|
| - // combinations of SSL versions. Defined as an array for fast lookup.
|
| - CredHandleClass anonymous_creds_[SSL_VERSION_MASKS];
|
| -
|
| - // CredHandles that use a client certificate.
|
| - CredHandleMap client_cert_creds_;
|
| -};
|
| -
|
| -static base::LazyInstance<CredHandleTable> g_cred_handle_table =
|
| - LAZY_INSTANCE_INITIALIZER;
|
| -
|
| -// static
|
| -int CredHandleTable::InitializeHandle(CredHandle* handle,
|
| - PCCERT_CONTEXT client_cert,
|
| - int ssl_version_mask) {
|
| - SCHANNEL_CRED schannel_cred = {0};
|
| - schannel_cred.dwVersion = SCHANNEL_CRED_VERSION;
|
| - if (client_cert) {
|
| - schannel_cred.cCreds = 1;
|
| - schannel_cred.paCred = &client_cert;
|
| - // Schannel will make its own copy of client_cert.
|
| - }
|
| -
|
| - // The global system registry settings take precedence over the value of
|
| - // schannel_cred.grbitEnabledProtocols.
|
| - schannel_cred.grbitEnabledProtocols = 0;
|
| - if (ssl_version_mask & SSL3)
|
| - schannel_cred.grbitEnabledProtocols |= SP_PROT_SSL3;
|
| - if (ssl_version_mask & TLS1)
|
| - schannel_cred.grbitEnabledProtocols |= SP_PROT_TLS1;
|
| -
|
| - // The default session lifetime is 36000000 milliseconds (ten hours). Set
|
| - // schannel_cred.dwSessionLifespan to change the number of milliseconds that
|
| - // Schannel keeps the session in its session cache.
|
| -
|
| - // We can set the key exchange algorithms (RSA or DH) in
|
| - // schannel_cred.{cSupportedAlgs,palgSupportedAlgs}.
|
| -
|
| - // Although SCH_CRED_AUTO_CRED_VALIDATION is convenient, we have to use
|
| - // SCH_CRED_MANUAL_CRED_VALIDATION for three reasons.
|
| - // 1. SCH_CRED_AUTO_CRED_VALIDATION doesn't allow us to get the certificate
|
| - // context if the certificate validation fails.
|
| - // 2. SCH_CRED_AUTO_CRED_VALIDATION returns only one error even if the
|
| - // certificate has multiple errors.
|
| - // 3. SCH_CRED_AUTO_CRED_VALIDATION doesn't allow us to ignore untrusted CA
|
| - // and expired certificate errors. There are only flags to ignore the
|
| - // name mismatch and unable-to-check-revocation errors.
|
| - //
|
| - // We specify SCH_CRED_REVOCATION_CHECK_CHAIN_EXCLUDE_ROOT to cause the TLS
|
| - // certificate status request extension (commonly known as OCSP stapling)
|
| - // to be sent on Vista or later. This flag matches the
|
| - // CERT_CHAIN_REVOCATION_CHECK_CHAIN_EXCLUDE_ROOT flag that we pass to the
|
| - // CertGetCertificateChain calls. Note: we specify this flag even when
|
| - // revocation checking is disabled to avoid doubling the number of
|
| - // credentials handles we need to acquire.
|
| - //
|
| - // TODO(wtc): Look into undocumented or poorly documented flags:
|
| - // SCH_CRED_RESTRICTED_ROOTS
|
| - // SCH_CRED_REVOCATION_CHECK_CACHE_ONLY
|
| - // SCH_CRED_CACHE_ONLY_URL_RETRIEVAL
|
| - // SCH_CRED_MEMORY_STORE_CERT
|
| - schannel_cred.dwFlags |= SCH_CRED_NO_DEFAULT_CREDS |
|
| - SCH_CRED_MANUAL_CRED_VALIDATION |
|
| - SCH_CRED_REVOCATION_CHECK_CHAIN_EXCLUDE_ROOT;
|
| - TimeStamp expiry;
|
| - SECURITY_STATUS status;
|
| -
|
| - status = AcquireCredentialsHandle(
|
| - NULL, // Not used
|
| - UNISP_NAME, // Microsoft Unified Security Protocol Provider
|
| - SECPKG_CRED_OUTBOUND,
|
| - NULL, // Not used
|
| - &schannel_cred,
|
| - NULL, // Not used
|
| - NULL, // Not used
|
| - handle,
|
| - &expiry); // Optional
|
| - if (status != SEC_E_OK)
|
| - LOG(ERROR) << "AcquireCredentialsHandle failed: " << status;
|
| - return MapSecurityError(status);
|
| -}
|
| -
|
| -// For the SSL sockets to share SSL sessions by session resumption handshakes,
|
| -// they need to use the same CredHandle. The GetCredHandle function creates
|
| -// and stores a shared CredHandle in *handle_ptr. On success, GetCredHandle
|
| -// returns OK. On failure, GetCredHandle returns a network error code and
|
| -// leaves *handle_ptr unchanged.
|
| -//
|
| -// The versions of the SSL protocol enabled are a property of the CredHandle.
|
| -// So we need a separate CredHandle for each combination of SSL versions.
|
| -// Most of the time Chromium will use only one or two combinations of SSL
|
| -// versions (for example, SSL3 | TLS1 for normal use, plus SSL3 when visiting
|
| -// TLS-intolerant servers). These CredHandles are initialized only when
|
| -// needed.
|
| -
|
| -static int GetCredHandle(PCCERT_CONTEXT client_cert,
|
| - int ssl_version_mask,
|
| - CredHandle** handle_ptr) {
|
| - if (ssl_version_mask <= 0 || ssl_version_mask >= SSL_VERSION_MASKS) {
|
| - NOTREACHED();
|
| - return ERR_UNEXPECTED;
|
| - }
|
| - return g_cred_handle_table.Get().GetHandle(client_cert,
|
| - ssl_version_mask,
|
| - handle_ptr);
|
| -}
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -// This callback is intended to be used with CertFindChainInStore. In addition
|
| -// to filtering by extended/enhanced key usage, we do not show expired
|
| -// certificates and require digital signature usage in the key usage
|
| -// extension.
|
| -//
|
| -// This matches our behavior on Mac OS X and that of NSS. It also matches the
|
| -// default behavior of IE8. See http://support.microsoft.com/kb/890326 and
|
| -// http://blogs.msdn.com/b/askie/archive/2009/06/09/my-expired-client-certificates-no-longer-display-when-connecting-to-my-web-server-using-ie8.aspx
|
| -static BOOL WINAPI ClientCertFindCallback(PCCERT_CONTEXT cert_context,
|
| - void* find_arg) {
|
| - // Verify the certificate's KU is good.
|
| - BYTE key_usage;
|
| - if (CertGetIntendedKeyUsage(X509_ASN_ENCODING, cert_context->pCertInfo,
|
| - &key_usage, 1)) {
|
| - if (!(key_usage & CERT_DIGITAL_SIGNATURE_KEY_USAGE))
|
| - return FALSE;
|
| - } else {
|
| - DWORD err = GetLastError();
|
| - // If |err| is non-zero, it's an actual error. Otherwise the extension
|
| - // just isn't present, and we treat it as if everything was allowed.
|
| - if (err) {
|
| - DLOG(ERROR) << "CertGetIntendedKeyUsage failed: " << err;
|
| - return FALSE;
|
| - }
|
| - }
|
| -
|
| - // Verify the current time is within the certificate's validity period.
|
| - if (CertVerifyTimeValidity(NULL, cert_context->pCertInfo) != 0)
|
| - return FALSE;
|
| -
|
| - // Verify private key metadata is associated with this certificate.
|
| - DWORD size = 0;
|
| - if (!CertGetCertificateContextProperty(
|
| - cert_context, CERT_KEY_PROV_INFO_PROP_ID, NULL, &size)) {
|
| - return FALSE;
|
| - }
|
| -
|
| - return TRUE;
|
| -}
|
| -
|
| -static bool IsCertificateChainIdentical(const X509Certificate* a,
|
| - const X509Certificate* b) {
|
| - DCHECK(a);
|
| - DCHECK(b);
|
| - const X509Certificate::OSCertHandles& a_intermediates =
|
| - a->GetIntermediateCertificates();
|
| - const X509Certificate::OSCertHandles& b_intermediates =
|
| - b->GetIntermediateCertificates();
|
| - if (a_intermediates.size() != b_intermediates.size() || !a->Equals(b))
|
| - return false;
|
| - for (size_t i = 0; i < a_intermediates.size(); ++i) {
|
| - if (!X509Certificate::IsSameOSCert(a_intermediates[i], b_intermediates[i]))
|
| - return false;
|
| - }
|
| - return true;
|
| -}
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -// Size of recv_buffer_
|
| -//
|
| -// Ciphertext is decrypted one SSL record at a time, so recv_buffer_ needs to
|
| -// have room for a full SSL record, with the header and trailer. Here is the
|
| -// breakdown of the size:
|
| -// 5: SSL record header
|
| -// 16K: SSL record maximum size
|
| -// 64: >= SSL record trailer (16 or 20 have been observed)
|
| -static const int kRecvBufferSize = (5 + 16*1024 + 64);
|
| -
|
| -SSLClientSocketWin::SSLClientSocketWin(ClientSocketHandle* transport_socket,
|
| - const HostPortPair& host_and_port,
|
| - const SSLConfig& ssl_config,
|
| - const SSLClientSocketContext& context)
|
| - : transport_(transport_socket),
|
| - host_and_port_(host_and_port),
|
| - ssl_config_(ssl_config),
|
| - user_read_buf_len_(0),
|
| - user_write_buf_len_(0),
|
| - next_state_(STATE_NONE),
|
| - cert_verifier_(context.cert_verifier),
|
| - creds_(NULL),
|
| - isc_status_(SEC_E_OK),
|
| - payload_send_buffer_len_(0),
|
| - bytes_sent_(0),
|
| - decrypted_ptr_(NULL),
|
| - bytes_decrypted_(0),
|
| - received_ptr_(NULL),
|
| - bytes_received_(0),
|
| - writing_first_token_(false),
|
| - ignore_ok_result_(false),
|
| - renegotiating_(false),
|
| - need_more_data_(false),
|
| - net_log_(transport_socket->socket()->NetLog()) {
|
| - memset(&stream_sizes_, 0, sizeof(stream_sizes_));
|
| - memset(in_buffers_, 0, sizeof(in_buffers_));
|
| - memset(&send_buffer_, 0, sizeof(send_buffer_));
|
| - memset(&ctxt_, 0, sizeof(ctxt_));
|
| -}
|
| -
|
| -SSLClientSocketWin::~SSLClientSocketWin() {
|
| - Disconnect();
|
| -}
|
| -
|
| -bool SSLClientSocketWin::GetSSLInfo(SSLInfo* ssl_info) {
|
| - ssl_info->Reset();
|
| - if (!server_cert_)
|
| - return false;
|
| -
|
| - ssl_info->cert = server_cert_verify_result_.verified_cert;
|
| - ssl_info->cert_status = server_cert_verify_result_.cert_status;
|
| - ssl_info->public_key_hashes = server_cert_verify_result_.public_key_hashes;
|
| - ssl_info->is_issued_by_known_root =
|
| - server_cert_verify_result_.is_issued_by_known_root;
|
| - ssl_info->client_cert_sent =
|
| - ssl_config_.send_client_cert && ssl_config_.client_cert;
|
| - ssl_info->channel_id_sent = WasChannelIDSent();
|
| - SecPkgContext_ConnectionInfo connection_info;
|
| - SECURITY_STATUS status = QueryContextAttributes(
|
| - &ctxt_, SECPKG_ATTR_CONNECTION_INFO, &connection_info);
|
| - if (status == SEC_E_OK) {
|
| - // TODO(wtc): compute the overall security strength, taking into account
|
| - // dwExchStrength and dwHashStrength. dwExchStrength needs to be
|
| - // normalized.
|
| - ssl_info->security_bits = connection_info.dwCipherStrength;
|
| - // TODO(wtc): connection_info.dwProtocol is the negotiated version.
|
| - // Save it in ssl_info->connection_status.
|
| - }
|
| - // SecPkgContext_CipherInfo comes from CNG and is available on Vista or
|
| - // later only. On XP, the next QueryContextAttributes call fails with
|
| - // SEC_E_UNSUPPORTED_FUNCTION (0x80090302), so ssl_info->connection_status
|
| - // won't contain the cipher suite. If this is a problem, we can build the
|
| - // cipher suite from the aiCipher, aiHash, and aiExch fields of
|
| - // SecPkgContext_ConnectionInfo based on Appendix C of RFC 5246.
|
| - SecPkgContext_CipherInfo cipher_info = { SECPKGCONTEXT_CIPHERINFO_V1 };
|
| - status = QueryContextAttributes(
|
| - &ctxt_, SECPKG_ATTR_CIPHER_INFO, &cipher_info);
|
| - if (status == SEC_E_OK) {
|
| - // TODO(wtc): find out what the cipher_info.dwBaseCipherSuite field is.
|
| - ssl_info->connection_status |=
|
| - (cipher_info.dwCipherSuite & SSL_CONNECTION_CIPHERSUITE_MASK) <<
|
| - SSL_CONNECTION_CIPHERSUITE_SHIFT;
|
| - // SChannel doesn't support TLS compression, so cipher_info doesn't have
|
| - // any field related to the compression method.
|
| - }
|
| -
|
| - if (ssl_config_.version_fallback)
|
| - ssl_info->connection_status |= SSL_CONNECTION_VERSION_FALLBACK;
|
| -
|
| - return true;
|
| -}
|
| -
|
| -void SSLClientSocketWin::GetSSLCertRequestInfo(
|
| - SSLCertRequestInfo* cert_request_info) {
|
| - cert_request_info->host_and_port = host_and_port_.ToString();
|
| - cert_request_info->cert_authorities.clear();
|
| - cert_request_info->cert_key_types.clear();
|
| - cert_request_info->client_certs.clear();
|
| -
|
| - // Get the server criteria for client certificates. Schannel doesn't return
|
| - // the certificate_types field of the CertificateRequest message to us, so we
|
| - // can't fill the |cert_key_types| field.
|
| - SecPkgContext_IssuerListInfoEx issuer_list;
|
| - SECURITY_STATUS status = QueryContextAttributes(
|
| - &ctxt_, SECPKG_ATTR_ISSUER_LIST_EX, &issuer_list);
|
| - if (status != SEC_E_OK) {
|
| - DLOG(ERROR) << "QueryContextAttributes (issuer list) failed: " << status;
|
| - return;
|
| - }
|
| -
|
| - for (size_t i = 0; i < issuer_list.cIssuers; i++) {
|
| - cert_request_info->cert_authorities.push_back(std::string(
|
| - reinterpret_cast<const char*>(issuer_list.aIssuers[i].pbData),
|
| - static_cast<size_t>(issuer_list.aIssuers[i].cbData)));
|
| - }
|
| -
|
| - // Retrieve the list of matching client certificates. This is to be moved out
|
| - // of here as a part of refactoring effort being tracked in
|
| - // http://crbug.com/166642.
|
| -
|
| - // Client certificates of the user are in the "MY" system certificate store.
|
| - HCERTSTORE my_cert_store = CertOpenSystemStore(NULL, L"MY");
|
| - if (!my_cert_store) {
|
| - LOG(ERROR) << "Could not open the \"MY\" system certificate store: "
|
| - << GetLastError();
|
| - FreeContextBuffer(issuer_list.aIssuers);
|
| - return;
|
| - }
|
| -
|
| - // Enumerate the client certificates.
|
| - CERT_CHAIN_FIND_BY_ISSUER_PARA find_by_issuer_para;
|
| - memset(&find_by_issuer_para, 0, sizeof(find_by_issuer_para));
|
| - find_by_issuer_para.cbSize = sizeof(find_by_issuer_para);
|
| - find_by_issuer_para.pszUsageIdentifier = szOID_PKIX_KP_CLIENT_AUTH;
|
| - find_by_issuer_para.cIssuer = issuer_list.cIssuers;
|
| - find_by_issuer_para.rgIssuer = issuer_list.aIssuers;
|
| - find_by_issuer_para.pfnFindCallback = ClientCertFindCallback;
|
| -
|
| - PCCERT_CHAIN_CONTEXT chain_context = NULL;
|
| - DWORD find_flags = CERT_CHAIN_FIND_BY_ISSUER_CACHE_ONLY_FLAG |
|
| - CERT_CHAIN_FIND_BY_ISSUER_CACHE_ONLY_URL_FLAG;
|
| -
|
| - for (;;) {
|
| - // Find a certificate chain.
|
| - chain_context = CertFindChainInStore(my_cert_store,
|
| - X509_ASN_ENCODING,
|
| - find_flags,
|
| - CERT_CHAIN_FIND_BY_ISSUER,
|
| - &find_by_issuer_para,
|
| - chain_context);
|
| - if (!chain_context) {
|
| - DWORD err = GetLastError();
|
| - if (err != CRYPT_E_NOT_FOUND)
|
| - DLOG(ERROR) << "CertFindChainInStore failed: " << err;
|
| - break;
|
| - }
|
| -
|
| - // Get the leaf certificate.
|
| - PCCERT_CONTEXT cert_context =
|
| - chain_context->rgpChain[0]->rgpElement[0]->pCertContext;
|
| - // Copy the certificate into a NULL store, so that the "MY" store can be
|
| - // closed before returning from this function.
|
| - PCCERT_CONTEXT cert_context2 = NULL;
|
| - BOOL ok = CertAddCertificateContextToStore(NULL, cert_context,
|
| - CERT_STORE_ADD_USE_EXISTING,
|
| - &cert_context2);
|
| - if (!ok) {
|
| - NOTREACHED();
|
| - continue;
|
| - }
|
| -
|
| - // Grab the intermediates, if any.
|
| - X509Certificate::OSCertHandles intermediates;
|
| - for (DWORD i = 1; i < chain_context->rgpChain[0]->cElement; ++i) {
|
| - PCCERT_CONTEXT chain_intermediate =
|
| - chain_context->rgpChain[0]->rgpElement[i]->pCertContext;
|
| - PCCERT_CONTEXT copied_intermediate = NULL;
|
| - ok = CertAddCertificateContextToStore(NULL, chain_intermediate,
|
| - CERT_STORE_ADD_USE_EXISTING,
|
| - &copied_intermediate);
|
| - if (ok)
|
| - intermediates.push_back(copied_intermediate);
|
| - }
|
| - scoped_refptr<X509Certificate> cert = X509Certificate::CreateFromHandle(
|
| - cert_context2, intermediates);
|
| - cert_request_info->client_certs.push_back(cert);
|
| - CertFreeCertificateContext(cert_context2);
|
| - for (size_t i = 0; i < intermediates.size(); ++i)
|
| - CertFreeCertificateContext(intermediates[i]);
|
| - }
|
| -
|
| - std::sort(cert_request_info->client_certs.begin(),
|
| - cert_request_info->client_certs.end(),
|
| - x509_util::ClientCertSorter());
|
| -
|
| - FreeContextBuffer(issuer_list.aIssuers);
|
| -
|
| - BOOL ok = CertCloseStore(my_cert_store, CERT_CLOSE_STORE_CHECK_FLAG);
|
| - DCHECK(ok);
|
| -}
|
| -
|
| -int SSLClientSocketWin::ExportKeyingMaterial(const base::StringPiece& label,
|
| - bool has_context,
|
| - const base::StringPiece& context,
|
| - unsigned char* out,
|
| - unsigned int outlen) {
|
| - return ERR_NOT_IMPLEMENTED;
|
| -}
|
| -
|
| -int SSLClientSocketWin::GetTLSUniqueChannelBinding(std::string* out) {
|
| - return ERR_NOT_IMPLEMENTED;
|
| -}
|
| -
|
| -SSLClientSocket::NextProtoStatus
|
| -SSLClientSocketWin::GetNextProto(std::string* proto,
|
| - std::string* server_protos) {
|
| - proto->clear();
|
| - server_protos->clear();
|
| - return kNextProtoUnsupported;
|
| -}
|
| -
|
| -ServerBoundCertService* SSLClientSocketWin::GetServerBoundCertService() const {
|
| - return NULL;
|
| -}
|
| -
|
| -int SSLClientSocketWin::Connect(const CompletionCallback& callback) {
|
| - DCHECK(transport_.get());
|
| - DCHECK(next_state_ == STATE_NONE);
|
| - DCHECK(user_connect_callback_.is_null());
|
| -
|
| - net_log_.BeginEvent(NetLog::TYPE_SSL_CONNECT);
|
| -
|
| - int rv = InitializeSSLContext();
|
| - if (rv != OK) {
|
| - net_log_.EndEvent(NetLog::TYPE_SSL_CONNECT);
|
| - return rv;
|
| - }
|
| -
|
| - writing_first_token_ = true;
|
| - next_state_ = STATE_HANDSHAKE_WRITE;
|
| - rv = DoLoop(OK);
|
| - if (rv == ERR_IO_PENDING) {
|
| - user_connect_callback_ = callback;
|
| - } else {
|
| - net_log_.EndEvent(NetLog::TYPE_SSL_CONNECT);
|
| - }
|
| - return rv;
|
| -}
|
| -
|
| -int SSLClientSocketWin::InitializeSSLContext() {
|
| - // If ssl_config_.version_max > SSL_PROTOCOL_VERSION_TLS1, it means the
|
| - // SSLConfigService::SetDefaultVersionMax(SSL_PROTOCOL_VERSION_TLS1) call
|
| - // in ClientSocketFactory::UseSystemSSL() is not effective.
|
| - DCHECK_LE(ssl_config_.version_max, SSL_PROTOCOL_VERSION_TLS1);
|
| - int ssl_version_mask = 0;
|
| - if (ssl_config_.version_min == SSL_PROTOCOL_VERSION_SSL3)
|
| - ssl_version_mask |= SSL3;
|
| - if (ssl_config_.version_min <= SSL_PROTOCOL_VERSION_TLS1 &&
|
| - ssl_config_.version_max >= SSL_PROTOCOL_VERSION_TLS1) {
|
| - ssl_version_mask |= TLS1;
|
| - }
|
| - // If we pass 0 to GetCredHandle, we will let Schannel select the protocols,
|
| - // rather than enabling no protocols. So we have to fail here.
|
| - if (ssl_version_mask == 0)
|
| - return ERR_NO_SSL_VERSIONS_ENABLED;
|
| - PCCERT_CONTEXT cert_context = NULL;
|
| - if (ssl_config_.client_cert)
|
| - cert_context = ssl_config_.client_cert->os_cert_handle();
|
| - int result = GetCredHandle(cert_context, ssl_version_mask, &creds_);
|
| - if (result != OK)
|
| - return result;
|
| -
|
| - memset(&ctxt_, 0, sizeof(ctxt_));
|
| -
|
| - SecBufferDesc buffer_desc;
|
| - DWORD out_flags;
|
| - DWORD flags = ISC_REQ_SEQUENCE_DETECT |
|
| - ISC_REQ_REPLAY_DETECT |
|
| - ISC_REQ_CONFIDENTIALITY |
|
| - ISC_RET_EXTENDED_ERROR |
|
| - ISC_REQ_ALLOCATE_MEMORY |
|
| - ISC_REQ_STREAM;
|
| -
|
| - send_buffer_.pvBuffer = NULL;
|
| - send_buffer_.BufferType = SECBUFFER_TOKEN;
|
| - send_buffer_.cbBuffer = 0;
|
| -
|
| - buffer_desc.cBuffers = 1;
|
| - buffer_desc.pBuffers = &send_buffer_;
|
| - buffer_desc.ulVersion = SECBUFFER_VERSION;
|
| -
|
| - TimeStamp expiry;
|
| - SECURITY_STATUS status;
|
| -
|
| - status = InitializeSecurityContext(
|
| - creds_,
|
| - NULL, // NULL on the first call
|
| - const_cast<wchar_t*>(ASCIIToWide(host_and_port_.host()).c_str()),
|
| - flags,
|
| - 0, // Reserved
|
| - 0, // Not used with Schannel.
|
| - NULL, // NULL on the first call
|
| - 0, // Reserved
|
| - &ctxt_, // Receives the new context handle
|
| - &buffer_desc,
|
| - &out_flags,
|
| - &expiry);
|
| - if (status != SEC_I_CONTINUE_NEEDED) {
|
| - LOG(ERROR) << "InitializeSecurityContext failed: " << status;
|
| - if (status == SEC_E_INVALID_HANDLE) {
|
| - // The only handle we passed to this InitializeSecurityContext call is
|
| - // creds_, so print its contents to figure out why it's invalid.
|
| - if (creds_) {
|
| - LOG(ERROR) << "creds_->dwLower = " << creds_->dwLower
|
| - << "; creds_->dwUpper = " << creds_->dwUpper;
|
| - } else {
|
| - LOG(ERROR) << "creds_ is NULL";
|
| - }
|
| - }
|
| - return MapSecurityError(status);
|
| - }
|
| -
|
| - return OK;
|
| -}
|
| -
|
| -
|
| -void SSLClientSocketWin::Disconnect() {
|
| - // TODO(wtc): Send SSL close_notify alert.
|
| - next_state_ = STATE_NONE;
|
| -
|
| - // Shut down anything that may call us back.
|
| - verifier_.reset();
|
| - transport_->socket()->Disconnect();
|
| -
|
| - if (send_buffer_.pvBuffer)
|
| - FreeSendBuffer();
|
| - if (SecIsValidHandle(&ctxt_)) {
|
| - DeleteSecurityContext(&ctxt_);
|
| - SecInvalidateHandle(&ctxt_);
|
| - }
|
| - if (server_cert_)
|
| - server_cert_ = NULL;
|
| -
|
| - // TODO(wtc): reset more members?
|
| - bytes_decrypted_ = 0;
|
| - bytes_received_ = 0;
|
| - writing_first_token_ = false;
|
| - renegotiating_ = false;
|
| - need_more_data_ = false;
|
| -}
|
| -
|
| -bool SSLClientSocketWin::IsConnected() const {
|
| - // Ideally, we should also check if we have received the close_notify alert
|
| - // message from the server, and return false in that case. We're not doing
|
| - // that, so this function may return a false positive. Since the upper
|
| - // layer (HttpNetworkTransaction) needs to handle a persistent connection
|
| - // closed by the server when we send a request anyway, a false positive in
|
| - // exchange for simpler code is a good trade-off.
|
| - return completed_handshake() && transport_->socket()->IsConnected();
|
| -}
|
| -
|
| -bool SSLClientSocketWin::IsConnectedAndIdle() const {
|
| - // Unlike IsConnected, this method doesn't return a false positive.
|
| - //
|
| - // Strictly speaking, we should check if we have received the close_notify
|
| - // alert message from the server, and return false in that case. Although
|
| - // the close_notify alert message means EOF in the SSL layer, it is just
|
| - // bytes to the transport layer below, so
|
| - // transport_->socket()->IsConnectedAndIdle() returns the desired false
|
| - // when we receive close_notify.
|
| - return completed_handshake() && transport_->socket()->IsConnectedAndIdle();
|
| -}
|
| -
|
| -int SSLClientSocketWin::GetPeerAddress(IPEndPoint* address) const {
|
| - return transport_->socket()->GetPeerAddress(address);
|
| -}
|
| -
|
| -int SSLClientSocketWin::GetLocalAddress(IPEndPoint* address) const {
|
| - return transport_->socket()->GetLocalAddress(address);
|
| -}
|
| -
|
| -void SSLClientSocketWin::SetSubresourceSpeculation() {
|
| - if (transport_.get() && transport_->socket()) {
|
| - transport_->socket()->SetSubresourceSpeculation();
|
| - } else {
|
| - NOTREACHED();
|
| - }
|
| -}
|
| -
|
| -void SSLClientSocketWin::SetOmniboxSpeculation() {
|
| - if (transport_.get() && transport_->socket()) {
|
| - transport_->socket()->SetOmniboxSpeculation();
|
| - } else {
|
| - NOTREACHED();
|
| - }
|
| -}
|
| -
|
| -bool SSLClientSocketWin::WasEverUsed() const {
|
| - if (transport_.get() && transport_->socket()) {
|
| - return transport_->socket()->WasEverUsed();
|
| - }
|
| - NOTREACHED();
|
| - return false;
|
| -}
|
| -
|
| -bool SSLClientSocketWin::UsingTCPFastOpen() const {
|
| - if (transport_.get() && transport_->socket()) {
|
| - return transport_->socket()->UsingTCPFastOpen();
|
| - }
|
| - NOTREACHED();
|
| - return false;
|
| -}
|
| -
|
| -int64 SSLClientSocketWin::NumBytesRead() const {
|
| - if (transport_.get() && transport_->socket()) {
|
| - return transport_->socket()->NumBytesRead();
|
| - }
|
| - NOTREACHED();
|
| - return -1;
|
| -}
|
| -
|
| -base::TimeDelta SSLClientSocketWin::GetConnectTimeMicros() const {
|
| - if (transport_.get() && transport_->socket()) {
|
| - return transport_->socket()->GetConnectTimeMicros();
|
| - }
|
| - NOTREACHED();
|
| - return base::TimeDelta::FromMicroseconds(-1);
|
| -}
|
| -
|
| -int SSLClientSocketWin::Read(IOBuffer* buf, int buf_len,
|
| - const CompletionCallback& callback) {
|
| - DCHECK(completed_handshake());
|
| - DCHECK(user_read_callback_.is_null());
|
| -
|
| - // If we have surplus decrypted plaintext, satisfy the Read with it without
|
| - // reading more ciphertext from the transport socket.
|
| - if (bytes_decrypted_ != 0) {
|
| - int len = std::min(buf_len, bytes_decrypted_);
|
| - net_log_.AddByteTransferEvent(NetLog::TYPE_SSL_SOCKET_BYTES_RECEIVED, len,
|
| - decrypted_ptr_);
|
| - memcpy(buf->data(), decrypted_ptr_, len);
|
| - decrypted_ptr_ += len;
|
| - bytes_decrypted_ -= len;
|
| - if (bytes_decrypted_ == 0) {
|
| - decrypted_ptr_ = NULL;
|
| - if (bytes_received_ != 0) {
|
| - memmove(recv_buffer_.get(), received_ptr_, bytes_received_);
|
| - received_ptr_ = recv_buffer_.get();
|
| - }
|
| - }
|
| - return len;
|
| - }
|
| -
|
| - DCHECK(!user_read_buf_);
|
| - // http://crbug.com/16371: We're seeing |buf->data()| return NULL. See if the
|
| - // user is passing in an IOBuffer with a NULL |data_|.
|
| - CHECK(buf);
|
| - CHECK(buf->data());
|
| - user_read_buf_ = buf;
|
| - user_read_buf_len_ = buf_len;
|
| -
|
| - int rv = DoPayloadRead();
|
| - if (rv == ERR_IO_PENDING) {
|
| - user_read_callback_ = callback;
|
| - } else {
|
| - user_read_buf_ = NULL;
|
| - user_read_buf_len_ = 0;
|
| - }
|
| - return rv;
|
| -}
|
| -
|
| -int SSLClientSocketWin::Write(IOBuffer* buf, int buf_len,
|
| - const CompletionCallback& callback) {
|
| - DCHECK(completed_handshake());
|
| - DCHECK(user_write_callback_.is_null());
|
| -
|
| - DCHECK(!user_write_buf_);
|
| - user_write_buf_ = buf;
|
| - user_write_buf_len_ = buf_len;
|
| -
|
| - int rv = DoPayloadEncrypt();
|
| - if (rv != OK)
|
| - return rv;
|
| -
|
| - rv = DoPayloadWrite();
|
| - if (rv == ERR_IO_PENDING) {
|
| - user_write_callback_ = callback;
|
| - } else {
|
| - user_write_buf_ = NULL;
|
| - user_write_buf_len_ = 0;
|
| - }
|
| - return rv;
|
| -}
|
| -
|
| -bool SSLClientSocketWin::SetReceiveBufferSize(int32 size) {
|
| - return transport_->socket()->SetReceiveBufferSize(size);
|
| -}
|
| -
|
| -bool SSLClientSocketWin::SetSendBufferSize(int32 size) {
|
| - return transport_->socket()->SetSendBufferSize(size);
|
| -}
|
| -
|
| -void SSLClientSocketWin::OnHandshakeIOComplete(int result) {
|
| - int rv = DoLoop(result);
|
| -
|
| - // The SSL handshake has some round trips. We need to notify the caller of
|
| - // success or any error, other than waiting for IO.
|
| - if (rv != ERR_IO_PENDING) {
|
| - // If there is no connect callback available to call, we are renegotiating
|
| - // (which occurs because we are in the middle of a Read when the
|
| - // renegotiation process starts). So we complete the Read here.
|
| - if (user_connect_callback_.is_null()) {
|
| - CompletionCallback c = user_read_callback_;
|
| - user_read_callback_.Reset();
|
| - user_read_buf_ = NULL;
|
| - user_read_buf_len_ = 0;
|
| - c.Run(rv);
|
| - return;
|
| - }
|
| - net_log_.EndEvent(NetLog::TYPE_SSL_CONNECT);
|
| - CompletionCallback c = user_connect_callback_;
|
| - user_connect_callback_.Reset();
|
| - c.Run(rv);
|
| - }
|
| -}
|
| -
|
| -void SSLClientSocketWin::OnReadComplete(int result) {
|
| - DCHECK(completed_handshake());
|
| -
|
| - result = DoPayloadReadComplete(result);
|
| - if (result > 0)
|
| - result = DoPayloadDecrypt();
|
| - if (result != ERR_IO_PENDING) {
|
| - DCHECK(!user_read_callback_.is_null());
|
| - CompletionCallback c = user_read_callback_;
|
| - user_read_callback_.Reset();
|
| - user_read_buf_ = NULL;
|
| - user_read_buf_len_ = 0;
|
| - c.Run(result);
|
| - }
|
| -}
|
| -
|
| -void SSLClientSocketWin::OnWriteComplete(int result) {
|
| - DCHECK(completed_handshake());
|
| -
|
| - int rv = DoPayloadWriteComplete(result);
|
| - if (rv != ERR_IO_PENDING) {
|
| - DCHECK(!user_write_callback_.is_null());
|
| - CompletionCallback c = user_write_callback_;
|
| - user_write_callback_.Reset();
|
| - user_write_buf_ = NULL;
|
| - user_write_buf_len_ = 0;
|
| - c.Run(rv);
|
| - }
|
| -}
|
| -
|
| -
|
| -int SSLClientSocketWin::DoLoop(int last_io_result) {
|
| - DCHECK(next_state_ != STATE_NONE);
|
| - int rv = last_io_result;
|
| - do {
|
| - State state = next_state_;
|
| - next_state_ = STATE_NONE;
|
| - switch (state) {
|
| - case STATE_HANDSHAKE_READ:
|
| - rv = DoHandshakeRead();
|
| - break;
|
| - case STATE_HANDSHAKE_READ_COMPLETE:
|
| - rv = DoHandshakeReadComplete(rv);
|
| - break;
|
| - case STATE_HANDSHAKE_WRITE:
|
| - rv = DoHandshakeWrite();
|
| - break;
|
| - case STATE_HANDSHAKE_WRITE_COMPLETE:
|
| - rv = DoHandshakeWriteComplete(rv);
|
| - break;
|
| - case STATE_VERIFY_CERT:
|
| - rv = DoVerifyCert();
|
| - break;
|
| - case STATE_VERIFY_CERT_COMPLETE:
|
| - rv = DoVerifyCertComplete(rv);
|
| - break;
|
| - case STATE_COMPLETED_RENEGOTIATION:
|
| - rv = DoCompletedRenegotiation(rv);
|
| - break;
|
| - case STATE_COMPLETED_HANDSHAKE:
|
| - next_state_ = STATE_COMPLETED_HANDSHAKE;
|
| - // This is the end of our state machine, so return.
|
| - return rv;
|
| - default:
|
| - rv = ERR_UNEXPECTED;
|
| - LOG(DFATAL) << "unexpected state " << state;
|
| - break;
|
| - }
|
| - } while (rv != ERR_IO_PENDING && next_state_ != STATE_NONE);
|
| - return rv;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoHandshakeRead() {
|
| - next_state_ = STATE_HANDSHAKE_READ_COMPLETE;
|
| -
|
| - if (!recv_buffer_.get())
|
| - recv_buffer_.reset(new char[kRecvBufferSize]);
|
| -
|
| - int buf_len = kRecvBufferSize - bytes_received_;
|
| -
|
| - if (buf_len <= 0) {
|
| - LOG(DFATAL) << "Receive buffer is too small!";
|
| - return ERR_UNEXPECTED;
|
| - }
|
| -
|
| - DCHECK(!transport_read_buf_);
|
| - transport_read_buf_ = new IOBuffer(buf_len);
|
| -
|
| - return transport_->socket()->Read(
|
| - transport_read_buf_, buf_len,
|
| - base::Bind(&SSLClientSocketWin::OnHandshakeIOComplete,
|
| - base::Unretained(this)));
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoHandshakeReadComplete(int result) {
|
| - if (result < 0) {
|
| - transport_read_buf_ = NULL;
|
| - return result;
|
| - }
|
| -
|
| - if (transport_read_buf_) {
|
| - // A transition to STATE_HANDSHAKE_READ_COMPLETE is set in multiple places,
|
| - // not only in DoHandshakeRead(), so we may not have a transport_read_buf_.
|
| - DCHECK_LE(result, kRecvBufferSize - bytes_received_);
|
| - char* buf = recv_buffer_.get() + bytes_received_;
|
| - memcpy(buf, transport_read_buf_->data(), result);
|
| - transport_read_buf_ = NULL;
|
| - }
|
| -
|
| - if (result == 0 && !ignore_ok_result_)
|
| - return ERR_SSL_PROTOCOL_ERROR; // Incomplete response :(
|
| -
|
| - ignore_ok_result_ = false;
|
| -
|
| - bytes_received_ += result;
|
| -
|
| - // Process the contents of recv_buffer_.
|
| - TimeStamp expiry;
|
| - DWORD out_flags;
|
| -
|
| - DWORD flags = ISC_REQ_SEQUENCE_DETECT |
|
| - ISC_REQ_REPLAY_DETECT |
|
| - ISC_REQ_CONFIDENTIALITY |
|
| - ISC_RET_EXTENDED_ERROR |
|
| - ISC_REQ_ALLOCATE_MEMORY |
|
| - ISC_REQ_STREAM;
|
| -
|
| - if (ssl_config_.send_client_cert)
|
| - flags |= ISC_REQ_USE_SUPPLIED_CREDS;
|
| -
|
| - SecBufferDesc in_buffer_desc, out_buffer_desc;
|
| -
|
| - in_buffer_desc.cBuffers = 2;
|
| - in_buffer_desc.pBuffers = in_buffers_;
|
| - in_buffer_desc.ulVersion = SECBUFFER_VERSION;
|
| -
|
| - in_buffers_[0].pvBuffer = recv_buffer_.get();
|
| - in_buffers_[0].cbBuffer = bytes_received_;
|
| - in_buffers_[0].BufferType = SECBUFFER_TOKEN;
|
| -
|
| - in_buffers_[1].pvBuffer = NULL;
|
| - in_buffers_[1].cbBuffer = 0;
|
| - in_buffers_[1].BufferType = SECBUFFER_EMPTY;
|
| -
|
| - out_buffer_desc.cBuffers = 1;
|
| - out_buffer_desc.pBuffers = &send_buffer_;
|
| - out_buffer_desc.ulVersion = SECBUFFER_VERSION;
|
| -
|
| - send_buffer_.pvBuffer = NULL;
|
| - send_buffer_.BufferType = SECBUFFER_TOKEN;
|
| - send_buffer_.cbBuffer = 0;
|
| -
|
| - isc_status_ = InitializeSecurityContext(
|
| - creds_,
|
| - &ctxt_,
|
| - NULL,
|
| - flags,
|
| - 0,
|
| - 0,
|
| - &in_buffer_desc,
|
| - 0,
|
| - NULL,
|
| - &out_buffer_desc,
|
| - &out_flags,
|
| - &expiry);
|
| -
|
| - if (isc_status_ == SEC_E_INVALID_TOKEN) {
|
| - // Peer sent us an SSL record type that's invalid during SSL handshake.
|
| - // TODO(wtc): move this to MapSecurityError after sufficient testing.
|
| - LOG(ERROR) << "InitializeSecurityContext failed: " << isc_status_;
|
| - return ERR_SSL_PROTOCOL_ERROR;
|
| - }
|
| -
|
| - if (send_buffer_.cbBuffer != 0 &&
|
| - (isc_status_ == SEC_E_OK ||
|
| - isc_status_ == SEC_I_CONTINUE_NEEDED ||
|
| - (FAILED(isc_status_) && (out_flags & ISC_RET_EXTENDED_ERROR)))) {
|
| - next_state_ = STATE_HANDSHAKE_WRITE;
|
| - return OK;
|
| - }
|
| - return DidCallInitializeSecurityContext();
|
| -}
|
| -
|
| -int SSLClientSocketWin::DidCallInitializeSecurityContext() {
|
| - if (isc_status_ == SEC_E_INCOMPLETE_MESSAGE) {
|
| - next_state_ = STATE_HANDSHAKE_READ;
|
| - return OK;
|
| - }
|
| -
|
| - if (isc_status_ == SEC_E_OK) {
|
| - if (in_buffers_[1].BufferType == SECBUFFER_EXTRA) {
|
| - // Save this data for later.
|
| - memmove(recv_buffer_.get(),
|
| - recv_buffer_.get() + (bytes_received_ - in_buffers_[1].cbBuffer),
|
| - in_buffers_[1].cbBuffer);
|
| - bytes_received_ = in_buffers_[1].cbBuffer;
|
| - } else {
|
| - bytes_received_ = 0;
|
| - }
|
| - return DidCompleteHandshake();
|
| - }
|
| -
|
| - if (FAILED(isc_status_)) {
|
| - LOG(ERROR) << "InitializeSecurityContext failed: " << isc_status_;
|
| - if (isc_status_ == SEC_E_INTERNAL_ERROR) {
|
| - // "The Local Security Authority cannot be contacted". This happens
|
| - // when the user denies access to the private key for SSL client auth.
|
| - return ERR_SSL_CLIENT_AUTH_PRIVATE_KEY_ACCESS_DENIED;
|
| - }
|
| - int result = MapSecurityError(isc_status_);
|
| - // We told Schannel to not verify the server certificate
|
| - // (SCH_CRED_MANUAL_CRED_VALIDATION), so any certificate error returned by
|
| - // InitializeSecurityContext must be referring to the bad or missing
|
| - // client certificate.
|
| - if (IsCertificateError(result)) {
|
| - // TODO(wtc): Add fine-grained error codes for client certificate errors
|
| - // reported by the server using the following SSL/TLS alert messages:
|
| - // access_denied
|
| - // bad_certificate
|
| - // unsupported_certificate
|
| - // certificate_expired
|
| - // certificate_revoked
|
| - // certificate_unknown
|
| - // unknown_ca
|
| - return ERR_BAD_SSL_CLIENT_AUTH_CERT;
|
| - }
|
| - return result;
|
| - }
|
| -
|
| - if (isc_status_ == SEC_I_INCOMPLETE_CREDENTIALS)
|
| - return ERR_SSL_CLIENT_AUTH_CERT_NEEDED;
|
| -
|
| - if (isc_status_ == SEC_I_NO_RENEGOTIATION) {
|
| - // Received a no_renegotiation alert message. Although this is just a
|
| - // warning, SChannel doesn't seem to allow us to continue after this
|
| - // point, so we have to return an error. See http://crbug.com/36835.
|
| - return ERR_SSL_NO_RENEGOTIATION;
|
| - }
|
| -
|
| - DCHECK(isc_status_ == SEC_I_CONTINUE_NEEDED);
|
| - if (in_buffers_[1].BufferType == SECBUFFER_EXTRA) {
|
| - memmove(recv_buffer_.get(),
|
| - recv_buffer_.get() + (bytes_received_ - in_buffers_[1].cbBuffer),
|
| - in_buffers_[1].cbBuffer);
|
| - bytes_received_ = in_buffers_[1].cbBuffer;
|
| - next_state_ = STATE_HANDSHAKE_READ_COMPLETE;
|
| - ignore_ok_result_ = true; // OK doesn't mean EOF.
|
| - return OK;
|
| - }
|
| -
|
| - bytes_received_ = 0;
|
| - next_state_ = STATE_HANDSHAKE_READ;
|
| - return OK;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoHandshakeWrite() {
|
| - next_state_ = STATE_HANDSHAKE_WRITE_COMPLETE;
|
| -
|
| - // We should have something to send.
|
| - DCHECK(send_buffer_.pvBuffer);
|
| - DCHECK(send_buffer_.cbBuffer > 0);
|
| - DCHECK(!transport_write_buf_);
|
| -
|
| - const char* buf = static_cast<char*>(send_buffer_.pvBuffer) + bytes_sent_;
|
| - int buf_len = send_buffer_.cbBuffer - bytes_sent_;
|
| - transport_write_buf_ = new IOBuffer(buf_len);
|
| - memcpy(transport_write_buf_->data(), buf, buf_len);
|
| -
|
| - return transport_->socket()->Write(
|
| - transport_write_buf_, buf_len,
|
| - base::Bind(&SSLClientSocketWin::OnHandshakeIOComplete,
|
| - base::Unretained(this)));
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoHandshakeWriteComplete(int result) {
|
| - DCHECK(transport_write_buf_);
|
| - transport_write_buf_ = NULL;
|
| - if (result < 0)
|
| - return result;
|
| -
|
| - DCHECK(result != 0);
|
| -
|
| - bytes_sent_ += result;
|
| - DCHECK(bytes_sent_ <= static_cast<int>(send_buffer_.cbBuffer));
|
| -
|
| - if (bytes_sent_ >= static_cast<int>(send_buffer_.cbBuffer)) {
|
| - bool overflow = (bytes_sent_ > static_cast<int>(send_buffer_.cbBuffer));
|
| - FreeSendBuffer();
|
| - bytes_sent_ = 0;
|
| - if (overflow) { // Bug!
|
| - LOG(DFATAL) << "overflow";
|
| - return ERR_UNEXPECTED;
|
| - }
|
| - if (writing_first_token_) {
|
| - writing_first_token_ = false;
|
| - DCHECK(bytes_received_ == 0);
|
| - next_state_ = STATE_HANDSHAKE_READ;
|
| - return OK;
|
| - }
|
| - return DidCallInitializeSecurityContext();
|
| - }
|
| -
|
| - // Send the remaining bytes.
|
| - next_state_ = STATE_HANDSHAKE_WRITE;
|
| - return OK;
|
| -}
|
| -
|
| -// Set server_cert_status_ and return OK or a network error.
|
| -int SSLClientSocketWin::DoVerifyCert() {
|
| - next_state_ = STATE_VERIFY_CERT_COMPLETE;
|
| -
|
| - DCHECK(server_cert_);
|
| - CertStatus cert_status;
|
| - if (ssl_config_.IsAllowedBadCert(server_cert_, &cert_status)) {
|
| - VLOG(1) << "Received an expected bad cert with status: " << cert_status;
|
| - server_cert_verify_result_.Reset();
|
| - server_cert_verify_result_.cert_status = cert_status;
|
| - server_cert_verify_result_.verified_cert = server_cert_;
|
| - return OK;
|
| - }
|
| -
|
| - int flags = 0;
|
| - if (ssl_config_.rev_checking_enabled)
|
| - flags |= CertVerifier::VERIFY_REV_CHECKING_ENABLED;
|
| - if (ssl_config_.verify_ev_cert)
|
| - flags |= CertVerifier::VERIFY_EV_CERT;
|
| - if (ssl_config_.cert_io_enabled)
|
| - flags |= CertVerifier::VERIFY_CERT_IO_ENABLED;
|
| - verifier_.reset(new SingleRequestCertVerifier(cert_verifier_));
|
| - return verifier_->Verify(
|
| - server_cert_, host_and_port_.host(), flags,
|
| - NULL /* no CRL set */,
|
| - &server_cert_verify_result_,
|
| - base::Bind(&SSLClientSocketWin::OnHandshakeIOComplete,
|
| - base::Unretained(this)),
|
| - net_log_);
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoVerifyCertComplete(int result) {
|
| - DCHECK(verifier_.get());
|
| - verifier_.reset();
|
| -
|
| - if (result == OK)
|
| - LogConnectionTypeMetrics();
|
| - if (renegotiating_) {
|
| - DidCompleteRenegotiation();
|
| - return result;
|
| - }
|
| -
|
| - // The initial handshake has completed.
|
| - next_state_ = STATE_COMPLETED_HANDSHAKE;
|
| - return result;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoPayloadRead() {
|
| - DCHECK(recv_buffer_.get());
|
| -
|
| - int buf_len = kRecvBufferSize - bytes_received_;
|
| -
|
| - if (buf_len <= 0) {
|
| - NOTREACHED() << "Receive buffer is too small!";
|
| - return ERR_FAILED;
|
| - }
|
| -
|
| - int rv;
|
| - // If bytes_received_, we have some data from a previous read still ready
|
| - // for decoding. Otherwise, we need to issue a real read.
|
| - if (!bytes_received_ || need_more_data_) {
|
| - DCHECK(!transport_read_buf_);
|
| - transport_read_buf_ = new IOBuffer(buf_len);
|
| -
|
| - rv = transport_->socket()->Read(
|
| - transport_read_buf_, buf_len,
|
| - base::Bind(&SSLClientSocketWin::OnReadComplete,
|
| - base::Unretained(this)));
|
| - if (rv != ERR_IO_PENDING)
|
| - rv = DoPayloadReadComplete(rv);
|
| - if (rv <= 0)
|
| - return rv;
|
| - }
|
| -
|
| - // Decode what we've read. If there is not enough data to decode yet,
|
| - // this may return ERR_IO_PENDING still.
|
| - return DoPayloadDecrypt();
|
| -}
|
| -
|
| -// result is the number of bytes that have been read; it should not be
|
| -// less than zero; a value of zero means that no additional bytes have
|
| -// been read.
|
| -int SSLClientSocketWin::DoPayloadReadComplete(int result) {
|
| - DCHECK(completed_handshake());
|
| -
|
| - // If IO Pending, there is nothing to do here.
|
| - if (result == ERR_IO_PENDING)
|
| - return result;
|
| -
|
| - // We completed a Read, so reset the need_more_data_ flag.
|
| - need_more_data_ = false;
|
| -
|
| - // Check for error
|
| - if (result <= 0) {
|
| - transport_read_buf_ = NULL;
|
| - if (result == 0 && bytes_received_ != 0) {
|
| - // TODO(wtc): Unless we have received the close_notify alert, we need
|
| - // to return an error code indicating that the SSL connection ended
|
| - // uncleanly, a potential truncation attack. See
|
| - // http://crbug.com/18586.
|
| - return ERR_SSL_PROTOCOL_ERROR;
|
| - }
|
| - return result;
|
| - }
|
| -
|
| - // Transfer the data from transport_read_buf_ to recv_buffer_.
|
| - if (transport_read_buf_) {
|
| - DCHECK_LE(result, kRecvBufferSize - bytes_received_);
|
| - char* buf = recv_buffer_.get() + bytes_received_;
|
| - memcpy(buf, transport_read_buf_->data(), result);
|
| - transport_read_buf_ = NULL;
|
| - }
|
| -
|
| - bytes_received_ += result;
|
| -
|
| - return result;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoPayloadDecrypt() {
|
| - // Process the contents of recv_buffer_.
|
| - int len = 0; // the number of bytes we've copied to the user buffer.
|
| - while (bytes_received_) {
|
| - SecBuffer buffers[4];
|
| - buffers[0].pvBuffer = recv_buffer_.get();
|
| - buffers[0].cbBuffer = bytes_received_;
|
| - buffers[0].BufferType = SECBUFFER_DATA;
|
| -
|
| - buffers[1].BufferType = SECBUFFER_EMPTY;
|
| - buffers[2].BufferType = SECBUFFER_EMPTY;
|
| - buffers[3].BufferType = SECBUFFER_EMPTY;
|
| -
|
| - SecBufferDesc buffer_desc;
|
| - buffer_desc.cBuffers = 4;
|
| - buffer_desc.pBuffers = buffers;
|
| - buffer_desc.ulVersion = SECBUFFER_VERSION;
|
| -
|
| - SECURITY_STATUS status;
|
| - status = DecryptMessage(&ctxt_, &buffer_desc, 0, NULL);
|
| -
|
| - if (status == SEC_E_INCOMPLETE_MESSAGE) {
|
| - need_more_data_ = true;
|
| - return DoPayloadRead();
|
| - }
|
| -
|
| - if (status == SEC_I_CONTEXT_EXPIRED) {
|
| - // Received the close_notify alert.
|
| - bytes_received_ = 0;
|
| - return OK;
|
| - }
|
| -
|
| - if (status != SEC_E_OK && status != SEC_I_RENEGOTIATE) {
|
| - DCHECK(status != SEC_E_MESSAGE_ALTERED);
|
| - LOG(ERROR) << "DecryptMessage failed: " << status;
|
| - return MapSecurityError(status);
|
| - }
|
| -
|
| - // The received ciphertext was decrypted in place in recv_buffer_. Remember
|
| - // the location and length of the decrypted plaintext and any unused
|
| - // ciphertext.
|
| - decrypted_ptr_ = NULL;
|
| - bytes_decrypted_ = 0;
|
| - received_ptr_ = NULL;
|
| - bytes_received_ = 0;
|
| - for (int i = 1; i < 4; i++) {
|
| - switch (buffers[i].BufferType) {
|
| - case SECBUFFER_DATA:
|
| - DCHECK(!decrypted_ptr_ && bytes_decrypted_ == 0);
|
| - decrypted_ptr_ = static_cast<char*>(buffers[i].pvBuffer);
|
| - bytes_decrypted_ = buffers[i].cbBuffer;
|
| - break;
|
| - case SECBUFFER_EXTRA:
|
| - DCHECK(!received_ptr_ && bytes_received_ == 0);
|
| - received_ptr_ = static_cast<char*>(buffers[i].pvBuffer);
|
| - bytes_received_ = buffers[i].cbBuffer;
|
| - break;
|
| - default:
|
| - break;
|
| - }
|
| - }
|
| -
|
| - DCHECK(len == 0);
|
| - if (bytes_decrypted_ != 0) {
|
| - len = std::min(user_read_buf_len_, bytes_decrypted_);
|
| - memcpy(user_read_buf_->data(), decrypted_ptr_, len);
|
| - decrypted_ptr_ += len;
|
| - bytes_decrypted_ -= len;
|
| - }
|
| - if (bytes_decrypted_ == 0) {
|
| - decrypted_ptr_ = NULL;
|
| - if (bytes_received_ != 0) {
|
| - memmove(recv_buffer_.get(), received_ptr_, bytes_received_);
|
| - received_ptr_ = recv_buffer_.get();
|
| - }
|
| - }
|
| -
|
| - if (status == SEC_I_RENEGOTIATE) {
|
| - if (bytes_received_ != 0) {
|
| - // The server requested renegotiation, but there are some data yet to
|
| - // be decrypted. The Platform SDK WebClient.c sample doesn't handle
|
| - // this, so we don't know how to handle this. Assume this cannot
|
| - // happen.
|
| - LOG(ERROR) << "DecryptMessage returned SEC_I_RENEGOTIATE with a buffer "
|
| - << "of type SECBUFFER_EXTRA.";
|
| - return ERR_SSL_RENEGOTIATION_REQUESTED;
|
| - }
|
| - if (len != 0) {
|
| - // The server requested renegotiation, but there are some decrypted
|
| - // data. We can't start renegotiation until we have returned all
|
| - // decrypted data to the caller.
|
| - //
|
| - // This hasn't happened during testing. Assume this cannot happen even
|
| - // though we know how to handle this.
|
| - LOG(ERROR) << "DecryptMessage returned SEC_I_RENEGOTIATE with a buffer "
|
| - << "of type SECBUFFER_DATA.";
|
| - return ERR_SSL_RENEGOTIATION_REQUESTED;
|
| - }
|
| - // Jump to the handshake sequence. Will come back when the rehandshake is
|
| - // done.
|
| - renegotiating_ = true;
|
| - ignore_ok_result_ = true; // OK doesn't mean EOF.
|
| - // If renegotiation handshake occurred, we need to go back into the
|
| - // handshake state machine.
|
| - next_state_ = STATE_HANDSHAKE_READ_COMPLETE;
|
| - return DoLoop(OK);
|
| - }
|
| -
|
| - // We've already copied data into the user buffer, so quit now.
|
| - // TODO(mbelshe): We really should keep decoding as long as we can. This
|
| - // break out is causing us to return pretty small chunks of data up to the
|
| - // application, even though more is already buffered and ready to be
|
| - // decoded.
|
| - if (len)
|
| - break;
|
| - }
|
| -
|
| - // If we decrypted 0 bytes, don't report 0 bytes read, which would be
|
| - // mistaken for EOF. Continue decrypting or read more.
|
| - if (len == 0)
|
| - return DoPayloadRead();
|
| - net_log_.AddByteTransferEvent(NetLog::TYPE_SSL_SOCKET_BYTES_RECEIVED, len,
|
| - user_read_buf_->data());
|
| - return len;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoPayloadEncrypt() {
|
| - DCHECK(completed_handshake());
|
| - DCHECK(user_write_buf_);
|
| - DCHECK(user_write_buf_len_ > 0);
|
| -
|
| - ULONG message_len = std::min(
|
| - stream_sizes_.cbMaximumMessage, static_cast<ULONG>(user_write_buf_len_));
|
| - ULONG alloc_len =
|
| - message_len + stream_sizes_.cbHeader + stream_sizes_.cbTrailer;
|
| - user_write_buf_len_ = message_len;
|
| -
|
| - payload_send_buffer_.reset(new char[alloc_len]);
|
| - memcpy(&payload_send_buffer_[stream_sizes_.cbHeader],
|
| - user_write_buf_->data(), message_len);
|
| - net_log_.AddByteTransferEvent(NetLog::TYPE_SSL_SOCKET_BYTES_SENT, message_len,
|
| - user_write_buf_->data());
|
| -
|
| - SecBuffer buffers[4];
|
| - buffers[0].pvBuffer = payload_send_buffer_.get();
|
| - buffers[0].cbBuffer = stream_sizes_.cbHeader;
|
| - buffers[0].BufferType = SECBUFFER_STREAM_HEADER;
|
| -
|
| - buffers[1].pvBuffer = &payload_send_buffer_[stream_sizes_.cbHeader];
|
| - buffers[1].cbBuffer = message_len;
|
| - buffers[1].BufferType = SECBUFFER_DATA;
|
| -
|
| - buffers[2].pvBuffer = &payload_send_buffer_[stream_sizes_.cbHeader +
|
| - message_len];
|
| - buffers[2].cbBuffer = stream_sizes_.cbTrailer;
|
| - buffers[2].BufferType = SECBUFFER_STREAM_TRAILER;
|
| -
|
| - buffers[3].BufferType = SECBUFFER_EMPTY;
|
| -
|
| - SecBufferDesc buffer_desc;
|
| - buffer_desc.cBuffers = 4;
|
| - buffer_desc.pBuffers = buffers;
|
| - buffer_desc.ulVersion = SECBUFFER_VERSION;
|
| -
|
| - SECURITY_STATUS status = EncryptMessage(&ctxt_, 0, &buffer_desc, 0);
|
| -
|
| - if (FAILED(status)) {
|
| - LOG(ERROR) << "EncryptMessage failed: " << status;
|
| - return MapSecurityError(status);
|
| - }
|
| -
|
| - payload_send_buffer_len_ = buffers[0].cbBuffer +
|
| - buffers[1].cbBuffer +
|
| - buffers[2].cbBuffer;
|
| - DCHECK(bytes_sent_ == 0);
|
| - return OK;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoPayloadWrite() {
|
| - DCHECK(completed_handshake());
|
| -
|
| - // We should have something to send.
|
| - DCHECK(payload_send_buffer_.get());
|
| - DCHECK(payload_send_buffer_len_ > 0);
|
| - DCHECK(!transport_write_buf_);
|
| -
|
| - const char* buf = payload_send_buffer_.get() + bytes_sent_;
|
| - int buf_len = payload_send_buffer_len_ - bytes_sent_;
|
| - transport_write_buf_ = new IOBuffer(buf_len);
|
| - memcpy(transport_write_buf_->data(), buf, buf_len);
|
| -
|
| - int rv = transport_->socket()->Write(
|
| - transport_write_buf_, buf_len,
|
| - base::Bind(&SSLClientSocketWin::OnWriteComplete,
|
| - base::Unretained(this)));
|
| - if (rv != ERR_IO_PENDING)
|
| - rv = DoPayloadWriteComplete(rv);
|
| - return rv;
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoPayloadWriteComplete(int result) {
|
| - DCHECK(transport_write_buf_);
|
| - transport_write_buf_ = NULL;
|
| - if (result < 0)
|
| - return result;
|
| -
|
| - DCHECK(result != 0);
|
| -
|
| - bytes_sent_ += result;
|
| - DCHECK(bytes_sent_ <= payload_send_buffer_len_);
|
| -
|
| - if (bytes_sent_ >= payload_send_buffer_len_) {
|
| - bool overflow = (bytes_sent_ > payload_send_buffer_len_);
|
| - payload_send_buffer_.reset();
|
| - payload_send_buffer_len_ = 0;
|
| - bytes_sent_ = 0;
|
| - if (overflow) { // Bug!
|
| - LOG(DFATAL) << "overflow";
|
| - return ERR_UNEXPECTED;
|
| - }
|
| - // Done
|
| - return user_write_buf_len_;
|
| - }
|
| -
|
| - // Send the remaining bytes.
|
| - return DoPayloadWrite();
|
| -}
|
| -
|
| -int SSLClientSocketWin::DoCompletedRenegotiation(int result) {
|
| - // The user had a read in progress, which was usurped by the renegotiation.
|
| - // Restart the read sequence.
|
| - next_state_ = STATE_COMPLETED_HANDSHAKE;
|
| - if (result != OK)
|
| - return result;
|
| - return DoPayloadRead();
|
| -}
|
| -
|
| -int SSLClientSocketWin::DidCompleteHandshake() {
|
| - SECURITY_STATUS status = QueryContextAttributes(
|
| - &ctxt_, SECPKG_ATTR_STREAM_SIZES, &stream_sizes_);
|
| - if (status != SEC_E_OK) {
|
| - LOG(ERROR) << "QueryContextAttributes (stream sizes) failed: " << status;
|
| - return MapSecurityError(status);
|
| - }
|
| - DCHECK(!server_cert_ || renegotiating_);
|
| - PCCERT_CONTEXT server_cert_handle = NULL;
|
| - status = QueryContextAttributes(
|
| - &ctxt_, SECPKG_ATTR_REMOTE_CERT_CONTEXT, &server_cert_handle);
|
| - if (status != SEC_E_OK) {
|
| - LOG(ERROR) << "QueryContextAttributes (remote cert) failed: " << status;
|
| - return MapSecurityError(status);
|
| - }
|
| -
|
| - X509Certificate::OSCertHandles intermediates;
|
| - PCCERT_CONTEXT intermediate = NULL;
|
| - // In testing, enumerating the store returned from SChannel appears to
|
| - // enumerate certificates in reverse of the order they were added, meaning
|
| - // that issuer certificates appear before the subject certificates. This is
|
| - // likely because the default Windows memory store is implemented as a
|
| - // linked-list. Reverse the list, so that intermediates are ordered from
|
| - // subject to issuer.
|
| - // Note that the store also includes the end-entity (server) certificate,
|
| - // so exclude this certificate from the set of |intermediates|.
|
| - while ((intermediate = CertEnumCertificatesInStore(
|
| - server_cert_handle->hCertStore, intermediate))) {
|
| - if (!X509Certificate::IsSameOSCert(server_cert_handle, intermediate))
|
| - intermediates.push_back(CertDuplicateCertificateContext(intermediate));
|
| - }
|
| - std::reverse(intermediates.begin(), intermediates.end());
|
| -
|
| - scoped_refptr<X509Certificate> new_server_cert(
|
| - X509Certificate::CreateFromHandle(server_cert_handle, intermediates));
|
| - net_log_.AddEvent(
|
| - NetLog::TYPE_SSL_CERTIFICATES_RECEIVED,
|
| - base::Bind(&NetLogX509CertificateCallback,
|
| - base::Unretained(new_server_cert.get())));
|
| - if (renegotiating_ && IsCertificateChainIdentical(server_cert_,
|
| - new_server_cert)) {
|
| - // We already verified the server certificate. Either it is good or the
|
| - // user has accepted the certificate error.
|
| - DidCompleteRenegotiation();
|
| - } else {
|
| - server_cert_ = new_server_cert;
|
| - next_state_ = STATE_VERIFY_CERT;
|
| - }
|
| - CertFreeCertificateContext(server_cert_handle);
|
| - for (size_t i = 0; i < intermediates.size(); ++i)
|
| - CertFreeCertificateContext(intermediates[i]);
|
| - return OK;
|
| -}
|
| -
|
| -// Called when a renegotiation is completed. |result| is the verification
|
| -// result of the server certificate received during renegotiation.
|
| -void SSLClientSocketWin::DidCompleteRenegotiation() {
|
| - DCHECK(user_connect_callback_.is_null());
|
| - DCHECK(!user_read_callback_.is_null());
|
| - renegotiating_ = false;
|
| - next_state_ = STATE_COMPLETED_RENEGOTIATION;
|
| -}
|
| -
|
| -void SSLClientSocketWin::LogConnectionTypeMetrics() const {
|
| - UpdateConnectionTypeHistograms(CONNECTION_SSL);
|
| - if (server_cert_verify_result_.has_md5)
|
| - UpdateConnectionTypeHistograms(CONNECTION_SSL_MD5);
|
| - if (server_cert_verify_result_.has_md2)
|
| - UpdateConnectionTypeHistograms(CONNECTION_SSL_MD2);
|
| - if (server_cert_verify_result_.has_md4)
|
| - UpdateConnectionTypeHistograms(CONNECTION_SSL_MD4);
|
| - if (server_cert_verify_result_.has_md5_ca)
|
| - UpdateConnectionTypeHistograms(CONNECTION_SSL_MD5_CA);
|
| - if (server_cert_verify_result_.has_md2_ca)
|
| - UpdateConnectionTypeHistograms(CONNECTION_SSL_MD2_CA);
|
| -}
|
| -
|
| -void SSLClientSocketWin::FreeSendBuffer() {
|
| - SECURITY_STATUS status = FreeContextBuffer(send_buffer_.pvBuffer);
|
| - DCHECK(status == SEC_E_OK);
|
| - memset(&send_buffer_, 0, sizeof(send_buffer_));
|
| -}
|
| -
|
| -} // namespace net
|
|
|