Google Git
Sign in
chromium / chromium / src / 622b6ad1e5a97087df6ee18ea901bab98eef04df / . / net / quic / quic_chromium_client_session.cc
blob: 6120cf9670c53ea54eff70dec18a154e9efc5668 [file] [log] [blame]
// Copyright 2012 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifdef UNSAFE_BUFFERS_BUILD
// TODO(crbug.com/40284755): Remove this and spanify to fix the errors.
#pragma allow_unsafe_buffers
#endif
#include "net/quic/quic_chromium_client_session.h"
#include <algorithm>
#include <memory>
#include <set>
#include <string_view>
#include <utility>
#include "base/containers/contains.h"
#include "base/feature_list.h"
#include "base/functional/bind.h"
#include "base/functional/callback_helpers.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/memory/ptr_util.h"
#include "base/metrics/histogram_functions.h"
#include "base/metrics/histogram_macros.h"
#include "base/metrics/sparse_histogram.h"
#include "base/no_destructor.h"
#include "base/numerics/checked_math.h"
#include "base/observer_list.h"
#include "base/strings/string_number_conversions.h"
#include "base/strings/stringprintf.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/time/tick_clock.h"
#include "base/time/time.h"
#include "base/trace_event/memory_usage_estimator.h"
#include "base/values.h"
#include "net/base/connection_endpoint_metadata.h"
#include "net/base/features.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "net/base/network_activity_monitor.h"
#include "net/base/network_anonymization_key.h"
#include "net/base/privacy_mode.h"
#include "net/base/session_usage.h"
#include "net/base/url_util.h"
#include "net/cert/signed_certificate_timestamp_and_status.h"
#include "net/dns/public/secure_dns_policy.h"
#include "net/http/transport_security_state.h"
#include "net/log/net_log_event_type.h"
#include "net/log/net_log_source_type.h"
#include "net/log/net_log_values.h"
#include "net/quic/address_utils.h"
#include "net/quic/crypto/proof_verifier_chromium.h"
#include "net/quic/quic_chromium_connection_helper.h"
#include "net/quic/quic_chromium_packet_writer.h"
#include "net/quic/quic_crypto_client_stream_factory.h"
#include "net/quic/quic_server_info.h"
#include "net/quic/quic_session_attempt_manager.h"
#include "net/quic/quic_session_pool.h"
#include "net/socket/datagram_client_socket.h"
#include "net/spdy/multiplexed_session_creation_initiator.h"
#include "net/spdy/spdy_http_utils.h"
#include "net/spdy/spdy_log_util.h"
#include "net/spdy/spdy_session.h"
#include "net/ssl/ssl_connection_status_flags.h"
#include "net/ssl/ssl_info.h"
#include "net/third_party/quiche/src/quiche/quic/core/quic_stream_priority.h"
#include "net/third_party/quiche/src/quiche/quic/core/quic_types.h"
#include "net/third_party/quiche/src/quiche/quic/core/quic_utils.h"
#include "net/third_party/quiche/src/quiche/quic/platform/api/quic_flags.h"
#include "net/traffic_annotation/network_traffic_annotation.h"
#include "net/websockets/websocket_quic_spdy_stream.h"
#include "third_party/boringssl/src/include/openssl/ssl.h"
#include "url/origin.h"
#include "url/scheme_host_port.h"
namespace net {
namespace features {
BASE_FEATURE(kQuicMigrationIgnoreDisconnectSignalDuringProbing,
"kQuicMigrationIgnoreDisconnectSignalDuringProbing",
base::FEATURE_DISABLED_BY_DEFAULT);
BASE_FEATURE(kQuicRegisterConnectionClosePayload,
"kQuicRegisterConnectionClosePayload",
base::FEATURE_DISABLED_BY_DEFAULT);
} // namespace features
namespace {
base::OnceClosure& MidMigrationCallbackForTesting() {
static base::NoDestructor<base::OnceClosure> callback;
return *callback;
}
// IPv6 packets have an additional 20 bytes of overhead than IPv4 packets.
const size_t kAdditionalOverheadForIPv6 = 20;
// Maximum number of Readers that are created for any session due to
// connection migration. A new Reader is created every time this endpoint's
// IP address changes.
const size_t kMaxReadersPerQuicSession = 5;
// Time to wait (in seconds) when no networks are available and
// migrating sessions need to wait for a new network to connect.
const size_t kWaitTimeForNewNetworkSecs = 10;
const size_t kMinRetryTimeForDefaultNetworkSecs = 1;
// These values are persisted to logs. Entries should not be renumbered,
// and numeric values should never be reused.
enum class AcceptChEntries {
kNoEntries = 0,
kOnlyValidEntries = 1,
kOnlyInvalidEntries = 2,
kBothValidAndInvalidEntries = 3,
kMaxValue = kBothValidAndInvalidEntries,
};
void LogAcceptChFrameReceivedHistogram(bool has_valid_entry,
bool has_invalid_entry) {
AcceptChEntries value;
if (has_valid_entry) {
if (has_invalid_entry) {
value = AcceptChEntries::kBothValidAndInvalidEntries;
} else {
value = AcceptChEntries::kOnlyValidEntries;
}
} else {
if (has_invalid_entry) {
value = AcceptChEntries::kOnlyInvalidEntries;
} else {
value = AcceptChEntries::kNoEntries;
}
}
base::UmaHistogramEnumeration("Net.QuicSession.AcceptChFrameReceivedViaAlps",
value);
}
void LogAcceptChForOriginHistogram(bool value) {
base::UmaHistogramBoolean("Net.QuicSession.AcceptChForOrigin", value);
}
void RecordConnectionCloseErrorCodeImpl(const std::string& histogram,
uint64_t error,
bool is_google_host,
bool handshake_confirmed,
bool has_ech_config_list) {
base::UmaHistogramSparse(histogram, error);
if (handshake_confirmed) {
base::UmaHistogramSparse(histogram + ".HandshakeConfirmed", error);
} else {
base::UmaHistogramSparse(histogram + ".HandshakeNotConfirmed", error);
}
if (is_google_host) {
base::UmaHistogramSparse(histogram + "Google", error);
if (handshake_confirmed) {
base::UmaHistogramSparse(histogram + "Google.HandshakeConfirmed", error);
} else {
base::UmaHistogramSparse(histogram + "Google.HandshakeNotConfirmed",
error);
}
}
// Record a set of metrics based on whether ECH was advertised in DNS. The ECH
// experiment does not change DNS behavior, so this measures the same servers
// in both experiment and control groups.
if (has_ech_config_list) {
base::UmaHistogramSparse(histogram + "ECH", error);
if (handshake_confirmed) {
base::UmaHistogramSparse(histogram + "ECH.HandshakeConfirmed", error);
} else {
base::UmaHistogramSparse(histogram + "ECH.HandshakeNotConfirmed", error);
}
}
}
void LogMigrateToSocketStatus(bool success) {
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.MigrateToSocketSuccess", success);
}
void RecordConnectionCloseErrorCode(const quic::QuicConnectionCloseFrame& frame,
quic::ConnectionCloseSource source,
std::string_view hostname,
bool handshake_confirmed,
bool has_ech_config_list) {
bool is_google_host = IsGoogleHost(hostname);
std::string histogram = "Net.QuicSession.ConnectionCloseErrorCode";
if (source == quic::ConnectionCloseSource::FROM_SELF) {
// When sending a CONNECTION_CLOSE frame, it is sufficient to record
// |quic_error_code|.
histogram += "Client";
RecordConnectionCloseErrorCodeImpl(histogram, frame.quic_error_code,
is_google_host, handshake_confirmed,
has_ech_config_list);
return;
}
histogram += "Server";
// Record |quic_error_code|. Note that when using IETF QUIC, this is
// extracted from the CONNECTION_CLOSE frame reason phrase, and might be
// QUIC_IETF_GQUIC_ERROR_MISSING.
RecordConnectionCloseErrorCodeImpl(histogram, frame.quic_error_code,
is_google_host, handshake_confirmed,
has_ech_config_list);
// For IETF QUIC frames, also record the error code received on the wire.
if (frame.close_type == quic::IETF_QUIC_TRANSPORT_CONNECTION_CLOSE) {
histogram += "IetfTransport";
RecordConnectionCloseErrorCodeImpl(histogram, frame.wire_error_code,
is_google_host, handshake_confirmed,
has_ech_config_list);
if (frame.quic_error_code == quic::QUIC_IETF_GQUIC_ERROR_MISSING) {
histogram += "GQuicErrorMissing";
RecordConnectionCloseErrorCodeImpl(histogram, frame.wire_error_code,
is_google_host, handshake_confirmed,
has_ech_config_list);
}
} else if (frame.close_type == quic::IETF_QUIC_APPLICATION_CONNECTION_CLOSE) {
histogram += "IetfApplication";
RecordConnectionCloseErrorCodeImpl(histogram, frame.wire_error_code,
is_google_host, handshake_confirmed,
has_ech_config_list);
if (frame.quic_error_code == quic::QUIC_IETF_GQUIC_ERROR_MISSING) {
histogram += "GQuicErrorMissing";
RecordConnectionCloseErrorCodeImpl(histogram, frame.wire_error_code,
is_google_host, handshake_confirmed,
has_ech_config_list);
}
}
}
void LogConnectionDurationMetrics(
base::TimeDelta duration,
bool is_google_with_alpn_h3,
const MultiplexedSessionCreationInitiator session_creation_initiator) {
std::string_view base_name = "Net.QuicSession.ConnectionDuration";
std::string total_suffix = "";
base::UmaHistogramLongTimes100(base_name, duration);
if (is_google_with_alpn_h3) {
std::string_view host_suffix = ".GoogleWithAlpnH3";
base::UmaHistogramLongTimes100(base::StrCat({base_name, host_suffix}),
duration);
total_suffix += host_suffix;
}
if (session_creation_initiator ==
MultiplexedSessionCreationInitiator::kPreconnect) {
std::string_view initiator_suffix = ".Preconnect";
base::UmaHistogramLongTimes100(base::StrCat({base_name, initiator_suffix}),
duration);
if (!total_suffix.empty()) {
base::UmaHistogramLongTimes100(
base::StrCat({base_name, total_suffix, initiator_suffix}), duration);
}
}
}
base::Value::Dict NetLogQuicMigrationFailureParams(
quic::QuicConnectionId connection_id,
std::string_view reason) {
return base::Value::Dict()
.Set("connection_id", connection_id.ToString())
.Set("reason", reason);
}
base::Value::Dict NetLogQuicMigrationSuccessParams(
quic::QuicConnectionId connection_id) {
return base::Value::Dict().Set("connection_id", connection_id.ToString());
}
base::Value::Dict NetLogProbingResultParams(
handles::NetworkHandle network,
const quic::QuicSocketAddress* peer_address,
bool is_success) {
return base::Value::Dict()
.Set("network", base::NumberToString(network))
.Set("peer address", peer_address->ToString())
.Set("is_success", is_success);
}
base::Value::Dict NetLogAcceptChFrameReceivedParams(
spdy::AcceptChOriginValuePair entry) {
return base::Value::Dict()
.Set("origin", entry.origin)
.Set("accept_ch", entry.value);
}
base::Value::Dict NetLogReceivedOrigins(
const std::set<url::SchemeHostPort>& received_origins) {
base::Value::List origins;
for (const auto& origin : received_origins) {
origins.Append(origin.Serialize());
}
return base::Value::Dict().Set("origins", std::move(origins));
}
// Histogram for recording the different reasons that a QUIC session is unable
// to complete the handshake.
enum HandshakeFailureReason {
HANDSHAKE_FAILURE_UNKNOWN = 0,
HANDSHAKE_FAILURE_BLACK_HOLE = 1,
HANDSHAKE_FAILURE_PUBLIC_RESET = 2,
NUM_HANDSHAKE_FAILURE_REASONS = 3,
};
void RecordHandshakeFailureReason(HandshakeFailureReason reason) {
UMA_HISTOGRAM_ENUMERATION(
"Net.QuicSession.ConnectionClose.HandshakeNotConfirmed.Reason", reason,
NUM_HANDSHAKE_FAILURE_REASONS);
}
// Note: these values must be kept in sync with the corresponding values in:
// tools/metrics/histograms/histograms.xml
enum HandshakeState {
STATE_STARTED = 0,
STATE_ENCRYPTION_ESTABLISHED = 1,
STATE_HANDSHAKE_CONFIRMED = 2,
STATE_FAILED = 3,
NUM_HANDSHAKE_STATES = 4
};
enum class ZeroRttState {
kAttemptedAndSucceeded = 0,
kAttemptedAndRejected = 1,
kNotAttempted = 2,
kMaxValue = kNotAttempted,
};
std::string_view ZeroRttStateToString(ZeroRttState state) {
switch (state) {
case ZeroRttState::kAttemptedAndSucceeded:
return "AttemptedAndSucceeded";
case ZeroRttState::kAttemptedAndRejected:
return "AttemptedAndRejected";
case ZeroRttState::kNotAttempted:
return "NotAttempted";
}
}
void RecordHandshakeState(HandshakeState state) {
UMA_HISTOGRAM_ENUMERATION("Net.QuicHandshakeState", state,
NUM_HANDSHAKE_STATES);
}
std::string MigrationCauseToString(MigrationCause cause) {
switch (cause) {
case UNKNOWN_CAUSE:
return "Unknown";
case ON_NETWORK_CONNECTED:
return "OnNetworkConnected";
case ON_NETWORK_DISCONNECTED:
return "OnNetworkDisconnected";
case ON_WRITE_ERROR:
return "OnWriteError";
case ON_NETWORK_MADE_DEFAULT:
return "OnNetworkMadeDefault";
case ON_MIGRATE_BACK_TO_DEFAULT_NETWORK:
return "OnMigrateBackToDefaultNetwork";
case CHANGE_NETWORK_ON_PATH_DEGRADING:
return "OnPathDegrading";
case CHANGE_PORT_ON_PATH_DEGRADING:
return "ChangePortOnPathDegrading";
case NEW_NETWORK_CONNECTED_POST_PATH_DEGRADING:
return "NewNetworkConnectedPostPathDegrading";
case ON_SERVER_PREFERRED_ADDRESS_AVAILABLE:
return "OnServerPreferredAddressAvailable";
default:
QUICHE_NOTREACHED();
break;
}
return "InvalidCause";
}
base::Value::Dict NetLogQuicClientSessionParams(
const NetLogWithSource& net_log,
const QuicSessionKey* session_key,
const quic::QuicConnectionId& connection_id,
const quic::QuicConnectionId& client_connection_id,
const quic::ParsedQuicVersionVector& supported_versions,
int cert_verify_flags,
bool require_confirmation,
base::span<const uint8_t> ech_config_list) {
auto dict =
base::Value::Dict()
.Set("host", session_key->server_id().host())
.Set("port", session_key->server_id().port())
.Set("connection_id", connection_id.ToString())
.Set("versions", ParsedQuicVersionVectorToString(supported_versions))
.Set("require_confirmation", require_confirmation)
.Set("cert_verify_flags", cert_verify_flags)
.Set("privacy_mode",
PrivacyModeToDebugString(session_key->privacy_mode()))
.Set("proxy_chain", session_key->proxy_chain().ToDebugString())
.Set("session_usage",
session_key->session_usage() == SessionUsage::kDestination
? "destination"
: "proxy")
.Set("network_anonymization_key",
session_key->network_anonymization_key().ToDebugString())
.Set("secure_dns_policy",
SecureDnsPolicyToDebugString(session_key->secure_dns_policy()))
.Set("require_dns_https_alpn", session_key->require_dns_https_alpn());
if (!client_connection_id.IsEmpty()) {
dict.Set("client_connection_id", client_connection_id.ToString());
}
if (!ech_config_list.empty()) {
dict.Set("ech_config_list", NetLogBinaryValue(ech_config_list));
}
net_log.source().AddToEventParameters(dict);
return dict;
}
// TODO(fayang): Remove this when necessary data is collected.
void LogProbeResultToHistogram(MigrationCause cause, bool success) {
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.PathValidationSuccess", success);
const std::string histogram_name =
"Net.QuicSession.PathValidationSuccess." + MigrationCauseToString(cause);
STATIC_HISTOGRAM_POINTER_GROUP(
histogram_name, cause, MIGRATION_CAUSE_MAX, AddBoolean(success),
base::BooleanHistogram::FactoryGet(
histogram_name, base::HistogramBase::kUmaTargetedHistogramFlag));
}
void LogSessionCreationInitiatorToHistogram(
MultiplexedSessionCreationInitiator session_creation,
bool is_used) {
std::string histogram_name =
base::StrCat({"Net.QuicSession.GoogleSearch.SessionCreationInitiator",
is_used ? ".Used" : ".Unused"});
base::UmaHistogramEnumeration(histogram_name, session_creation);
}
} // namespace
// static
void QuicChromiumClientSession::SetMidMigrationCallbackForTesting(
base::OnceClosure callback) {
MidMigrationCallbackForTesting() = std::move(callback); // IN-TEST
}
QuicChromiumClientSession::Handle::Handle(
const base::WeakPtr<QuicChromiumClientSession>& session,
url::SchemeHostPort destination)
: MultiplexedSessionHandle(session),
session_(session),
destination_(std::move(destination)),
net_log_(session_->net_log()),
was_handshake_confirmed_(session->OneRttKeysAvailable()),
server_id_(session_->server_id()),
quic_version_(session->connection()->version()),
initial_migration_information_(session->migration_info()),
last_migration_information_(session->migration_info()) {
DCHECK(session_);
session_->AddHandle(this);
}
QuicChromiumClientSession::Handle::~Handle() {
if (session_) {
session_->RemoveHandle(this);
}
}
void QuicChromiumClientSession::Handle::OnCryptoHandshakeConfirmed() {
was_handshake_confirmed_ = true;
}
void QuicChromiumClientSession::Handle::OnSessionClosed(
quic::ParsedQuicVersion quic_version,
int net_error,
quic::QuicErrorCode quic_error,
quic::ConnectionCloseSource source,
bool port_migration_detected,
bool quic_connection_migration_attempted,
bool quic_connection_migration_successful,
LoadTimingInfo::ConnectTiming connect_timing,
bool was_ever_used,
const ConnectionMigrationInformation& migration_info) {
session_ = nullptr;
port_migration_detected_ = port_migration_detected;
quic_connection_migration_attempted_ = quic_connection_migration_attempted;
quic_connection_migration_successful_ = quic_connection_migration_successful;
net_error_ = net_error;
quic_error_ = quic_error;
source_ = source;
quic_version_ = quic_version;
connect_timing_ = connect_timing;
was_ever_used_ = was_ever_used;
last_migration_information_ = migration_info;
}
bool QuicChromiumClientSession::Handle::IsConnected() const {
return session_ != nullptr;
}
bool QuicChromiumClientSession::Handle::OneRttKeysAvailable() const {
return was_handshake_confirmed_;
}
const LoadTimingInfo::ConnectTiming&
QuicChromiumClientSession::Handle::GetConnectTiming() {
if (!session_) {
return connect_timing_;
}
return session_->GetConnectTiming();
}
void QuicChromiumClientSession::Handle::PopulateNetErrorDetails(
NetErrorDetails* details) const {
if (session_) {
session_->PopulateNetErrorDetails(details);
} else {
details->quic_port_migration_detected = port_migration_detected_;
details->quic_connection_error = quic_error_;
details->source = source_;
details->quic_connection_migration_attempted =
quic_connection_migration_attempted_;
details->quic_connection_migration_successful =
quic_connection_migration_successful_;
}
}
quic::ParsedQuicVersion QuicChromiumClientSession::Handle::GetQuicVersion()
const {
if (!session_) {
return quic_version_;
}
return session_->GetQuicVersion();
}
std::unique_ptr<quic::QuicConnection::ScopedPacketFlusher>
QuicChromiumClientSession::Handle::CreatePacketBundler() {
if (!session_) {
return nullptr;
}
return std::make_unique<quic::QuicConnection::ScopedPacketFlusher>(
session_->connection());
}
bool QuicChromiumClientSession::Handle::SharesSameSession(
const Handle& other) const {
return session_.get() == other.session_.get();
}
int QuicChromiumClientSession::Handle::RequestStream(
bool requires_confirmation,
CompletionOnceCallback callback,
const NetworkTrafficAnnotationTag& traffic_annotation) {
DCHECK(!stream_request_);
if (!session_ || session_->going_away_) {
return ERR_CONNECTION_CLOSED;
}
requires_confirmation |= session_->gquic_zero_rtt_disabled();
// std::make_unique does not work because the StreamRequest constructor
// is private.
stream_request_ = base::WrapUnique(
new StreamRequest(this, requires_confirmation, traffic_annotation));
return stream_request_->StartRequest(std::move(callback));
}
std::unique_ptr<QuicChromiumClientStream::Handle>
QuicChromiumClientSession::Handle::ReleaseStream() {
DCHECK(stream_request_);
auto handle = stream_request_->ReleaseStream();
stream_request_.reset();
return handle;
}
int QuicChromiumClientSession::Handle::WaitForHandshakeConfirmation(
CompletionOnceCallback callback) {
if (!session_) {
return ERR_CONNECTION_CLOSED;
}
return session_->WaitForHandshakeConfirmation(std::move(callback));
}
void QuicChromiumClientSession::Handle::CancelRequest(StreamRequest* request) {
if (session_) {
session_->CancelRequest(request);
}
}
int QuicChromiumClientSession::Handle::TryCreateStream(StreamRequest* request) {
if (!session_) {
return ERR_CONNECTION_CLOSED;
}
return session_->TryCreateStream(request);
}
int QuicChromiumClientSession::Handle::GetPeerAddress(
IPEndPoint* address) const {
if (!session_) {
return ERR_CONNECTION_CLOSED;
}
*address = ToIPEndPoint(session_->peer_address());
return OK;
}
int QuicChromiumClientSession::Handle::GetSelfAddress(
IPEndPoint* address) const {
if (!session_) {
return ERR_CONNECTION_CLOSED;
}
*address = ToIPEndPoint(session_->self_address());
return OK;
}
bool QuicChromiumClientSession::Handle::WasEverUsed() const {
if (!session_) {
return was_ever_used_;
}
return session_->WasConnectionEverUsed();
}
const std::set<std::string>&
QuicChromiumClientSession::Handle::GetDnsAliasesForSessionKey(
const QuicSessionKey& key) const {
static const base::NoDestructor<std::set<std::string>> emptyset_result;
return session_ ? session_->GetDnsAliasesForSessionKey(key)
: *emptyset_result;
}
#if BUILDFLAG(ENABLE_WEBSOCKETS)
std::unique_ptr<WebSocketQuicStreamAdapter>
QuicChromiumClientSession::Handle::CreateWebSocketQuicStreamAdapter(
WebSocketQuicStreamAdapter::Delegate* delegate,
base::OnceCallback<void(std::unique_ptr<WebSocketQuicStreamAdapter>)>
callback,
const NetworkTrafficAnnotationTag& traffic_annotation) {
DCHECK(!stream_request_);
// std::make_unique does not work because the StreamRequest constructor
// is private.
stream_request_ = base::WrapUnique(new StreamRequest(
this, /*requires_confirmation=*/false, traffic_annotation));
return session_->CreateWebSocketQuicStreamAdapter(
delegate, std::move(callback), stream_request_.get());
}
#endif // BUILDFLAG(ENABLE_WEBSOCKETS)
QuicChromiumClientSession::StreamRequest::StreamRequest(
QuicChromiumClientSession::Handle* session,
bool requires_confirmation,
const NetworkTrafficAnnotationTag& traffic_annotation)
: session_(session),
requires_confirmation_(requires_confirmation),
traffic_annotation_(traffic_annotation) {}
QuicChromiumClientSession::StreamRequest::~StreamRequest() {
if (stream_) {
stream_->Reset(quic::QUIC_STREAM_CANCELLED);
}
if (session_) {
session_->CancelRequest(this);
}
}
int QuicChromiumClientSession::StreamRequest::StartRequest(
CompletionOnceCallback callback) {
if (!session_->IsConnected()) {
return ERR_CONNECTION_CLOSED;
}
next_state_ = STATE_WAIT_FOR_CONFIRMATION;
int rv = DoLoop(OK);
if (rv == ERR_IO_PENDING) {
callback_ = std::move(callback);
}
return rv;
}
std::unique_ptr<QuicChromiumClientStream::Handle>
QuicChromiumClientSession::StreamRequest::ReleaseStream() {
DCHECK(stream_);
return std::move(stream_);
}
void QuicChromiumClientSession::StreamRequest::OnRequestCompleteSuccess(
std::unique_ptr<QuicChromiumClientStream::Handle> stream) {
DCHECK_EQ(STATE_REQUEST_STREAM_COMPLETE, next_state_);
stream_ = std::move(stream);
// This method is called even when the request completes synchronously.
if (callback_) {
DoCallback(OK);
}
}
void QuicChromiumClientSession::StreamRequest::OnRequestCompleteFailure(
int rv) {
DCHECK_EQ(STATE_REQUEST_STREAM_COMPLETE, next_state_);
// This method is called even when the request completes synchronously.
if (callback_) {
// Avoid re-entrancy if the callback calls into the session.
base::SingleThreadTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::StreamRequest::DoCallback,
weak_factory_.GetWeakPtr(), rv));
}
}
void QuicChromiumClientSession::StreamRequest::OnIOComplete(int rv) {
rv = DoLoop(rv);
if (rv != ERR_IO_PENDING && !callback_.is_null()) {
DoCallback(rv);
}
}
void QuicChromiumClientSession::StreamRequest::DoCallback(int rv) {
CHECK_NE(rv, ERR_IO_PENDING);
CHECK(!callback_.is_null());
// The client callback can do anything, including destroying this class,
// so any pending callback must be issued after everything else is done.
std::move(callback_).Run(rv);
}
int QuicChromiumClientSession::StreamRequest::DoLoop(int rv) {
do {
State state = next_state_;
next_state_ = STATE_NONE;
switch (state) {
case STATE_WAIT_FOR_CONFIRMATION:
CHECK_EQ(OK, rv);
rv = DoWaitForConfirmation();
break;
case STATE_WAIT_FOR_CONFIRMATION_COMPLETE:
rv = DoWaitForConfirmationComplete(rv);
break;
case STATE_REQUEST_STREAM:
CHECK_EQ(OK, rv);
rv = DoRequestStream();
break;
case STATE_REQUEST_STREAM_COMPLETE:
rv = DoRequestStreamComplete(rv);
break;
default:
NOTREACHED() << "next_state_: " << next_state_;
}
} while (next_state_ != STATE_NONE && next_state_ && rv != ERR_IO_PENDING);
return rv;
}
int QuicChromiumClientSession::StreamRequest::DoWaitForConfirmation() {
next_state_ = STATE_WAIT_FOR_CONFIRMATION_COMPLETE;
if (requires_confirmation_) {
return session_->WaitForHandshakeConfirmation(
base::BindOnce(&QuicChromiumClientSession::StreamRequest::OnIOComplete,
weak_factory_.GetWeakPtr()));
}
return OK;
}
int QuicChromiumClientSession::StreamRequest::DoWaitForConfirmationComplete(
int rv) {
DCHECK_NE(ERR_IO_PENDING, rv);
if (rv < 0) {
return rv;
}
next_state_ = STATE_REQUEST_STREAM;
return OK;
}
int QuicChromiumClientSession::StreamRequest::DoRequestStream() {
next_state_ = STATE_REQUEST_STREAM_COMPLETE;
return session_->TryCreateStream(this);
}
int QuicChromiumClientSession::StreamRequest::DoRequestStreamComplete(int rv) {
DCHECK(rv == OK || !stream_);
return rv;
}
QuicChromiumClientSession::QuicChromiumPathValidationContext::
QuicChromiumPathValidationContext(
const quic::QuicSocketAddress& self_address,
const quic::QuicSocketAddress& peer_address,
handles::NetworkHandle network,
std::unique_ptr<QuicChromiumPacketWriter> writer,
std::unique_ptr<QuicChromiumPacketReader> reader)
: QuicPathValidationContext(self_address, peer_address),
network_handle_(network),
reader_(std::move(reader)),
writer_(std::move(writer)) {}
QuicChromiumClientSession::QuicChromiumPathValidationContext::
~QuicChromiumPathValidationContext() = default;
handles::NetworkHandle
QuicChromiumClientSession::QuicChromiumPathValidationContext::network() {
return network_handle_;
}
quic::QuicPacketWriter*
QuicChromiumClientSession::QuicChromiumPathValidationContext::WriterToUse() {
return writer_.get();
}
std::unique_ptr<QuicChromiumPacketWriter>
QuicChromiumClientSession::QuicChromiumPathValidationContext::ReleaseWriter() {
return std::move(writer_);
}
std::unique_ptr<QuicChromiumPacketReader>
QuicChromiumClientSession::QuicChromiumPathValidationContext::ReleaseReader() {
return std::move(reader_);
}
QuicChromiumClientSession::ConnectionMigrationValidationResultDelegate::
ConnectionMigrationValidationResultDelegate(
QuicChromiumClientSession* session)
: session_(session) {}
void QuicChromiumClientSession::ConnectionMigrationValidationResultDelegate::
OnPathValidationSuccess(
std::unique_ptr<quic::QuicPathValidationContext> context,
quic::QuicTime start_time) {
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
session_->OnConnectionMigrationProbeSucceeded(
chrome_context->network(), chrome_context->peer_address(),
chrome_context->self_address(), chrome_context->ReleaseWriter(),
chrome_context->ReleaseReader());
}
void QuicChromiumClientSession::ConnectionMigrationValidationResultDelegate::
OnPathValidationFailure(
std::unique_ptr<quic::QuicPathValidationContext> context) {
session_->connection()->OnPathValidationFailureAtClient(
/*is_multi_port=*/false, *context);
// Note that socket, packet writer, and packet reader in |context| will be
// discarded.
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
session_->OnProbeFailed(chrome_context->network(),
chrome_context->peer_address());
}
QuicChromiumClientSession::PortMigrationValidationResultDelegate::
PortMigrationValidationResultDelegate(QuicChromiumClientSession* session)
: session_(session) {}
void QuicChromiumClientSession::PortMigrationValidationResultDelegate::
OnPathValidationSuccess(
std::unique_ptr<quic::QuicPathValidationContext> context,
quic::QuicTime start_time) {
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
session_->OnPortMigrationProbeSucceeded(
chrome_context->network(), chrome_context->peer_address(),
chrome_context->self_address(), chrome_context->ReleaseWriter(),
chrome_context->ReleaseReader());
}
void QuicChromiumClientSession::PortMigrationValidationResultDelegate::
OnPathValidationFailure(
std::unique_ptr<quic::QuicPathValidationContext> context) {
session_->connection()->OnPathValidationFailureAtClient(
/*is_multi_port=*/false, *context);
// Note that socket, packet writer, and packet reader in |context| will be
// discarded.
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
session_->OnProbeFailed(chrome_context->network(),
chrome_context->peer_address());
}
QuicChromiumClientSession::ServerPreferredAddressValidationResultDelegate::
ServerPreferredAddressValidationResultDelegate(
QuicChromiumClientSession* session)
: session_(session) {}
void QuicChromiumClientSession::ServerPreferredAddressValidationResultDelegate::
OnPathValidationSuccess(
std::unique_ptr<quic::QuicPathValidationContext> context,
quic::QuicTime start_time) {
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
session_->OnServerPreferredAddressProbeSucceeded(
chrome_context->network(), chrome_context->peer_address(),
chrome_context->self_address(), chrome_context->ReleaseWriter(),
chrome_context->ReleaseReader());
}
void QuicChromiumClientSession::ServerPreferredAddressValidationResultDelegate::
OnPathValidationFailure(
std::unique_ptr<quic::QuicPathValidationContext> context) {
session_->connection()->OnPathValidationFailureAtClient(
/*is_multi_port=*/false, *context);
// Note that socket, packet writer, and packet reader in |context| will be
// discarded.
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
session_->OnProbeFailed(chrome_context->network(),
chrome_context->peer_address());
}
QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
QuicChromiumPathValidationWriterDelegate(
QuicChromiumClientSession* session,
base::SequencedTaskRunner* task_runner)
: session_(session),
task_runner_(task_runner),
network_(handles::kInvalidNetworkHandle) {}
QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
~QuicChromiumPathValidationWriterDelegate() = default;
int QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
HandleWriteError(
int error_code,
scoped_refptr<QuicChromiumPacketWriter::ReusableIOBuffer> last_packet) {
// Write error on the probing network is not recoverable.
DVLOG(1) << "Probing packet encounters write error " << error_code;
// Post a task to notify |session_| that this probe failed and cancel
// undergoing probing, which will delete the packet writer.
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(
&QuicChromiumPathValidationWriterDelegate::NotifySessionProbeFailed,
weak_factory_.GetWeakPtr(), network_));
return error_code;
}
void QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
OnWriteError(int error_code) {
NotifySessionProbeFailed(network_);
}
void QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
OnWriteUnblocked() {}
void QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
NotifySessionProbeFailed(handles::NetworkHandle network) {
session_->OnProbeFailed(network, peer_address_);
}
void QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
set_peer_address(const quic::QuicSocketAddress& peer_address) {
peer_address_ = peer_address;
}
void QuicChromiumClientSession::QuicChromiumPathValidationWriterDelegate::
set_network(handles::NetworkHandle network) {
network_ = network;
}
QuicChromiumClientSession::QuicChromiumClientSession(
quic::QuicConnection* connection,
std::unique_ptr<DatagramClientSocket> socket,
QuicSessionPool* session_pool,
QuicCryptoClientStreamFactory* crypto_client_stream_factory,
const quic::QuicClock* clock,
TransportSecurityState* transport_security_state,
SSLConfigService* ssl_config_service,
std::unique_ptr<QuicServerInfo> server_info,
QuicSessionAliasKey session_alias_key,
bool require_confirmation,
bool migrate_session_early_v2,
bool migrate_sessions_on_network_change_v2,
handles::NetworkHandle default_network,
quic::QuicTime::Delta retransmittable_on_wire_timeout,
bool migrate_idle_session,
bool allow_port_migration,
base::TimeDelta idle_migration_period,
int multi_port_probing_interval,
base::TimeDelta max_time_on_non_default_network,
int max_migrations_to_non_default_network_on_write_error,
int max_migrations_to_non_default_network_on_path_degrading,
int yield_after_packets,
quic::QuicTime::Delta yield_after_duration,
int cert_verify_flags,
const quic::QuicConfig& config,
std::unique_ptr<QuicCryptoClientConfigHandle> crypto_config,
const char* const connection_description,
base::TimeTicks dns_resolution_start_time,
base::TimeTicks dns_resolution_end_time,
const base::TickClock* tick_clock,
base::SequencedTaskRunner* task_runner,
std::unique_ptr<SocketPerformanceWatcher> socket_performance_watcher,
const ConnectionEndpointMetadata& metadata,
bool enable_origin_frame,
bool allow_server_preferred_address,
MultiplexedSessionCreationInitiator session_creation_initiator,
const NetLogWithSource& net_log)
: quic::QuicSpdyClientSessionBase(connection,
/*visitor=*/nullptr,
config,
connection->supported_versions()),
session_alias_key_(std::move(session_alias_key)),
session_key_(session_alias_key_.session_key()),
require_confirmation_(require_confirmation),
migrate_session_early_v2_(migrate_session_early_v2),
migrate_session_on_network_change_v2_(
migrate_sessions_on_network_change_v2),
migrate_idle_session_(migrate_idle_session),
allow_port_migration_(allow_port_migration),
idle_migration_period_(idle_migration_period),
max_time_on_non_default_network_(max_time_on_non_default_network),
max_migrations_to_non_default_network_on_write_error_(
max_migrations_to_non_default_network_on_write_error),
max_migrations_to_non_default_network_on_path_degrading_(
max_migrations_to_non_default_network_on_path_degrading),
clock_(clock),
yield_after_packets_(yield_after_packets),
yield_after_duration_(yield_after_duration),
most_recent_path_degrading_timestamp_(base::TimeTicks()),
most_recent_network_disconnected_timestamp_(base::TimeTicks()),
tick_clock_(tick_clock),
most_recent_stream_close_time_(tick_clock_->NowTicks()),
most_recent_write_error_timestamp_(base::TimeTicks()),
crypto_config_(std::move(crypto_config)),
session_pool_(session_pool),
transport_security_state_(transport_security_state),
ssl_config_service_(ssl_config_service),
server_info_(std::move(server_info)),
enable_origin_frame_(enable_origin_frame),
task_runner_(task_runner),
net_log_(NetLogWithSource::Make(net_log.net_log(),
NetLogSourceType::QUIC_SESSION)),
logger_(std::make_unique<QuicConnectionLogger>(
this,
connection_description,
std::move(socket_performance_watcher),
net_log_)),
http3_logger_(std::make_unique<QuicHttp3Logger>(net_log_)),
path_validation_writer_delegate_(this, task_runner_),
ech_config_list_(metadata.ech_config_list),
trust_anchor_ids_(metadata.trust_anchor_ids),
allow_server_preferred_address_(allow_server_preferred_address),
session_creation_initiator_(session_creation_initiator) {
default_network_ = default_network;
auto* socket_raw = socket.get();
packet_readers_.push_back(std::make_unique<QuicChromiumPacketReader>(
std::move(socket), clock, this, yield_after_packets, yield_after_duration,
net_log_));
crypto_stream_ = crypto_client_stream_factory->CreateQuicCryptoClientStream(
session_key_.server_id(), this,
std::make_unique<ProofVerifyContextChromium>(cert_verify_flags, net_log_),
crypto_config_->GetConfig());
set_debug_visitor(http3_logger_.get());
connection->set_debug_visitor(logger_.get());
connection->set_creator_debug_delegate(logger_.get());
migrate_back_to_default_timer_.SetTaskRunner(task_runner_.get());
net_log_.BeginEvent(NetLogEventType::QUIC_SESSION, [&] {
return NetLogQuicClientSessionParams(
net_log, &session_key_, connection_id(),
connection->client_connection_id(), supported_versions(),
cert_verify_flags, require_confirmation_, ech_config_list_);
});
// Associate the owned NetLog with the parent NetLog.
net_log.AddEventReferencingSource(NetLogEventType::QUIC_SESSION_CREATED,
net_log_.source());
IPEndPoint address;
if (socket_raw && socket_raw->GetLocalAddress(&address) == OK &&
address.GetFamily() == ADDRESS_FAMILY_IPV6) {
connection->SetMaxPacketLength(connection->max_packet_length() -
kAdditionalOverheadForIPv6);
}
if (multi_port_probing_interval > 0) {
connection->SetMultiPortProbingInterval(
quic::QuicTime::Delta::FromSeconds(multi_port_probing_interval));
}
connect_timing_.domain_lookup_start = dns_resolution_start_time;
connect_timing_.domain_lookup_end = dns_resolution_end_time;
if (!retransmittable_on_wire_timeout.IsZero()) {
connection->set_initial_retransmittable_on_wire_timeout(
retransmittable_on_wire_timeout);
}
}
QuicChromiumClientSession::~QuicChromiumClientSession() {
DCHECK(callback_.is_null());
for (auto& observer : connectivity_observer_list_) {
observer.OnSessionRemoved(this);
}
net_log_.EndEvent(NetLogEventType::QUIC_SESSION);
DCHECK(waiting_for_confirmation_callbacks_.empty());
DCHECK(!HasActiveRequestStreams());
DCHECK(handles_.empty());
if (!stream_requests_.empty()) {
// The session must be closed before it is destroyed.
CancelAllRequests(ERR_UNEXPECTED);
}
connection()->set_debug_visitor(nullptr);
if (connection()->connected()) {
// Ensure that the connection is closed by the time the session is
// destroyed.
connection()->CloseConnection(quic::QUIC_PEER_GOING_AWAY,
"session torn down",
quic::ConnectionCloseBehavior::SILENT_CLOSE);
}
if (IsEncryptionEstablished()) {
RecordHandshakeState(STATE_ENCRYPTION_ESTABLISHED);
}
if (OneRttKeysAvailable()) {
RecordHandshakeState(STATE_HANDSHAKE_CONFIRMED);
} else {
RecordHandshakeState(STATE_FAILED);
}
UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.NumTotalStreams",
num_total_streams_);
if (IsGoogleHostWithAlpnH3(session_key_.host())) {
LogSessionCreationInitiatorToHistogram(session_creation_initiator_,
num_total_streams_ > 0);
}
if (!OneRttKeysAvailable()) {
return;
}
// Sending one client_hello means we had zero handshake-round-trips.
int round_trip_handshakes = crypto_stream_->num_sent_client_hellos() - 1;
SSLInfo ssl_info;
// QUIC supports only secure urls.
if (GetSSLInfo(&ssl_info) && ssl_info.cert.get()) {
UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.ConnectRandomPortForHTTPS",
round_trip_handshakes, 1, 3, 4);
if (require_confirmation_) {
UMA_HISTOGRAM_CUSTOM_COUNTS(
"Net.QuicSession.ConnectRandomPortRequiringConfirmationForHTTPS",
round_trip_handshakes, 1, 3, 4);
}
}
const quic::QuicConnectionStats stats = connection()->GetStats();
// The MTU used by QUIC is limited to a fairly small set of predefined values
// (initial values and MTU discovery values), but does not fare well when
// bucketed. Because of that, a sparse histogram is used here.
base::UmaHistogramSparse("Net.QuicSession.ClientSideMtu", stats.egress_mtu);
base::UmaHistogramSparse("Net.QuicSession.ServerSideMtu", stats.ingress_mtu);
UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.MtuProbesSent",
connection()->mtu_probe_count());
if (stats.packets_sent >= 100) {
// Used to monitor for regressions that effect large uploads.
UMA_HISTOGRAM_COUNTS_1000(
"Net.QuicSession.PacketRetransmitsPerMille",
1000 * stats.packets_retransmitted / stats.packets_sent);
}
if (stats.max_sequence_reordering == 0) {
return;
}
const base::HistogramBase::Sample32 kMaxReordering = 100;
base::HistogramBase::Sample32 reordering = kMaxReordering;
if (stats.min_rtt_us > 0) {
reordering = static_cast<base::HistogramBase::Sample32>(
100 * stats.max_time_reordering_us / stats.min_rtt_us);
}
UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.MaxReorderingTime", reordering,
1, kMaxReordering, 50);
if (stats.min_rtt_us > 100 * 1000) {
UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.MaxReorderingTimeLongRtt",
reordering, 1, kMaxReordering, 50);
}
UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.MaxReordering",
static_cast<base::HistogramBase::Sample32>(
stats.max_sequence_reordering));
}
void QuicChromiumClientSession::Initialize() {
set_max_inbound_header_list_size(kQuicMaxHeaderListSize);
quic::QuicSpdyClientSessionBase::Initialize();
}
size_t QuicChromiumClientSession::WriteHeadersOnHeadersStream(
quic::QuicStreamId id,
quiche::HttpHeaderBlock headers,
bool fin,
const spdy::SpdyStreamPrecedence& precedence,
quiche::QuicheReferenceCountedPointer<quic::QuicAckListenerInterface>
ack_listener) {
const int weight =
spdy::Spdy3PriorityToHttp2Weight(precedence.spdy3_priority());
return WriteHeadersOnHeadersStreamImpl(id, std::move(headers), fin,
/* parent_stream_id = */ 0, weight,
/* exclusive = */ false,
std::move(ack_listener));
}
void QuicChromiumClientSession::OnHttp3GoAway(uint64_t id) {
quic::QuicSpdySession::OnHttp3GoAway(id);
NotifyFactoryOfSessionGoingAway();
PerformActionOnActiveStreams([id](quic::QuicStream* stream) {
if (stream->id() >= id) {
static_cast<QuicChromiumClientStream*>(stream)->OnError(
ERR_QUIC_GOAWAY_REQUEST_CAN_BE_RETRIED);
}
return true;
});
}
void QuicChromiumClientSession::OnAcceptChFrameReceivedViaAlps(
const quic::AcceptChFrame& frame) {
bool has_valid_entry = false;
bool has_invalid_entry = false;
for (const auto& entry : frame.entries) {
const url::SchemeHostPort scheme_host_port(GURL(entry.origin));
// |entry.origin| must be a valid SchemeHostPort.
std::string serialized = scheme_host_port.Serialize();
if (serialized.empty() || entry.origin != serialized) {
has_invalid_entry = true;
continue;
}
has_valid_entry = true;
accept_ch_entries_received_via_alps_.emplace(std::move(scheme_host_port),
entry.value);
net_log_.AddEvent(NetLogEventType::QUIC_ACCEPT_CH_FRAME_RECEIVED,
[&] { return NetLogAcceptChFrameReceivedParams(entry); });
}
LogAcceptChFrameReceivedHistogram(has_valid_entry, has_invalid_entry);
}
void QuicChromiumClientSession::OnOriginFrame(const quic::OriginFrame& frame) {
if (!enable_origin_frame_) {
return;
}
// The max size of an origin in ASCII serializaion can be 64kB. Choose a
// relatively small limit on total number of received origins.
static constexpr uint32_t kMaxOriginCount = 20;
for (const std::string& origin_str : frame.origins) {
if (received_origins_.size() >= kMaxOriginCount) {
return;
}
GURL url(base::StrCat({origin_str, "/"}));
if (!url.is_valid() || url.path() != "/") {
continue;
}
url::SchemeHostPort origin(url);
if (!origin.IsValid()) {
continue;
}
received_origins_.insert(origin);
}
net_log_.AddEvent(NetLogEventType::QUIC_SESSION_ORIGIN_FRAME_RECEIVED,
[&] { return NetLogReceivedOrigins(received_origins_); });
base::UmaHistogramCounts100("Net.QuicSession.NumReceivedOrigins",
received_origins_.size());
if (session_pool_ && session_pool_->session_attempt_manager()) {
session_pool_->session_attempt_manager()->OnOriginFrame(this);
}
}
void QuicChromiumClientSession::AddHandle(Handle* handle) {
if (going_away_) {
handle->OnSessionClosed(
connection()->version(), ERR_UNEXPECTED, error(), source_,
port_migration_detected_, quic_connection_migration_attempted_,
quic_connection_migration_successful_, GetConnectTiming(),
WasConnectionEverUsed(), migration_info_);
return;
}
DCHECK(!base::Contains(handles_, handle));
handles_.insert(handle);
}
void QuicChromiumClientSession::RemoveHandle(Handle* handle) {
DCHECK(base::Contains(handles_, handle));
handles_.erase(handle);
}
void QuicChromiumClientSession::AddConnectivityObserver(
ConnectivityObserver* observer) {
connectivity_observer_list_.AddObserver(observer);
observer->OnSessionRegistered(this, GetCurrentNetwork());
}
void QuicChromiumClientSession::RemoveConnectivityObserver(
ConnectivityObserver* observer) {
connectivity_observer_list_.RemoveObserver(observer);
}
// TODO(zhongyi): replace migration_session_* booleans with
// ConnectionMigrationMode.
ConnectionMigrationMode QuicChromiumClientSession::connection_migration_mode()
const {
if (migrate_session_early_v2_) {
return ConnectionMigrationMode::FULL_MIGRATION_V2;
}
if (migrate_session_on_network_change_v2_) {
return ConnectionMigrationMode::NO_MIGRATION_ON_PATH_DEGRADING_V2;
}
return ConnectionMigrationMode::NO_MIGRATION;
}
int QuicChromiumClientSession::WaitForHandshakeConfirmation(
CompletionOnceCallback callback) {
if (!connection()->connected()) {
return ERR_CONNECTION_CLOSED;
}
if (OneRttKeysAvailable()) {
return OK;
}
waiting_for_confirmation_callbacks_.push_back(std::move(callback));
return ERR_IO_PENDING;
}
int QuicChromiumClientSession::TryCreateStream(StreamRequest* request) {
if (goaway_received()) {
DVLOG(1) << "Going away.";
return ERR_CONNECTION_CLOSED;
}
if (!connection()->connected()) {
DVLOG(1) << "Already closed.";
return ERR_CONNECTION_CLOSED;
}
if (going_away_) {
return ERR_CONNECTION_CLOSED;
}
bool can_open_next = CanOpenNextOutgoingBidirectionalStream();
if (can_open_next) {
request->stream_ =
CreateOutgoingReliableStreamImpl(request->traffic_annotation())
->CreateHandle();
return OK;
}
// Calling CanOpenNextOutgoingBidirectionalStream() could close the
// connection.
if (!connection()->connected()) {
return ERR_CONNECTION_CLOSED;
}
request->pending_start_time_ = tick_clock_->NowTicks();
stream_requests_.push_back(request);
UMA_HISTOGRAM_COUNTS_1000("Net.QuicSession.NumPendingStreamRequests",
stream_requests_.size());
return ERR_IO_PENDING;
}
void QuicChromiumClientSession::CancelRequest(StreamRequest* request) {
// Remove |request| from the queue while preserving the order of the
// other elements.
auto it = std::ranges::find(stream_requests_, request);
if (it != stream_requests_.end()) {
it = stream_requests_.erase(it);
}
}
bool QuicChromiumClientSession::ShouldCreateOutgoingBidirectionalStream() {
if (!crypto_stream_->encryption_established()) {
DVLOG(1) << "Encryption not active so no outgoing stream created.";
return false;
}
if (!CanOpenNextOutgoingBidirectionalStream()) {
DVLOG(1) << "Failed to create a new outgoing stream. " << "Already "
<< GetNumActiveStreams() << " open.";
return false;
}
if (goaway_received()) {
DVLOG(1) << "Failed to create a new outgoing stream. "
<< "Already received goaway.";
return false;
}
if (going_away_) {
return false;
}
return true;
}
bool QuicChromiumClientSession::WasConnectionEverUsed() {
const quic::QuicConnectionStats& stats = connection()->GetStats();
return stats.bytes_sent > 0 || stats.bytes_received > 0;
}
QuicChromiumClientStream*
QuicChromiumClientSession::CreateOutgoingBidirectionalStream() {
NOTREACHED() << "CreateOutgoingReliableStreamImpl should be called directly";
}
QuicChromiumClientStream*
QuicChromiumClientSession::CreateOutgoingReliableStreamImpl(
const NetworkTrafficAnnotationTag& traffic_annotation) {
DCHECK(connection()->connected());
QuicChromiumClientStream* stream = new QuicChromiumClientStream(
GetNextOutgoingBidirectionalStreamId(), this, server_id(),
quic::BIDIRECTIONAL, net_log_, traffic_annotation);
ActivateStream(base::WrapUnique(stream));
++num_total_streams_;
UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.NumOpenStreams",
GetNumActiveStreams());
// The previous histogram puts 100 in a bucket betweeen 86-113 which does
// not shed light on if chrome ever things it has more than 100 streams open.
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.TooManyOpenStreams",
GetNumActiveStreams() > 100);
return stream;
}
quic::QuicCryptoClientStream*
QuicChromiumClientSession::GetMutableCryptoStream() {
return crypto_stream_.get();
}
const quic::QuicCryptoClientStream* QuicChromiumClientSession::GetCryptoStream()
const {
return crypto_stream_.get();
}
int QuicChromiumClientSession::GetRemoteEndpoint(IPEndPoint* endpoint) {
*endpoint = ToIPEndPoint(peer_address());
return OK;
}
// TODO(rtenneti): Add unittests for GetSSLInfo which exercise the various ways
// we learn about SSL info (sync vs async vs cached).
bool QuicChromiumClientSession::GetSSLInfo(SSLInfo* ssl_info) const {
*ssl_info = SSLInfo();
if (!cert_verify_result_) {
return false;
}
ssl_info->cert_status = cert_verify_result_->cert_status;
ssl_info->cert = cert_verify_result_->verified_cert;
ssl_info->public_key_hashes = cert_verify_result_->public_key_hashes;
ssl_info->is_issued_by_known_root =
cert_verify_result_->is_issued_by_known_root;
ssl_info->pkp_bypassed = pkp_bypassed_;
ssl_info->client_cert_sent = false;
ssl_info->handshake_type = SSLInfo::HANDSHAKE_FULL;
ssl_info->is_fatal_cert_error = is_fatal_cert_error_;
ssl_info->signed_certificate_timestamps = cert_verify_result_->scts;
ssl_info->ct_policy_compliance = cert_verify_result_->policy_compliance;
DCHECK(connection()->version().UsesTls());
const auto& crypto_params = crypto_stream_->crypto_negotiated_params();
uint16_t cipher_suite = crypto_params.cipher_suite;
int ssl_connection_status = 0;
SSLConnectionStatusSetCipherSuite(cipher_suite, &ssl_connection_status);
SSLConnectionStatusSetVersion(SSL_CONNECTION_VERSION_QUIC,
&ssl_connection_status);
ssl_info->connection_status = ssl_connection_status;
ssl_info->key_exchange_group = crypto_params.key_exchange_group;
ssl_info->peer_signature_algorithm = crypto_params.peer_signature_algorithm;
ssl_info->encrypted_client_hello = crypto_params.encrypted_client_hello;
return true;
}
std::string_view QuicChromiumClientSession::GetAcceptChViaAlps(
const url::SchemeHostPort& scheme_host_port) const {
auto it = accept_ch_entries_received_via_alps_.find(scheme_host_port);
if (it == accept_ch_entries_received_via_alps_.end()) {
LogAcceptChForOriginHistogram(false);
return {};
} else {
LogAcceptChForOriginHistogram(true);
return it->second;
}
}
int QuicChromiumClientSession::CryptoConnect(CompletionOnceCallback callback) {
connect_timing_.connect_start = tick_clock_->NowTicks();
RecordHandshakeState(STATE_STARTED);
DCHECK(flow_controller());
if (!crypto_stream_->CryptoConnect()) {
return ERR_QUIC_HANDSHAKE_FAILED;
}
if (OneRttKeysAvailable()) {
connect_timing_.connect_end = tick_clock_->NowTicks();
return OK;
}
// Unless we require handshake confirmation, activate the session if
// we have established initial encryption.
if (!require_confirmation_ && IsEncryptionEstablished()) {
return OK;
}
callback_ = std::move(callback);
return ERR_IO_PENDING;
}
int QuicChromiumClientSession::GetNumSentClientHellos() const {
return crypto_stream_->num_sent_client_hellos();
}
bool QuicChromiumClientSession::CanPool(
std::string_view hostname,
const QuicSessionKey& other_session_key) const {
DCHECK(connection()->connected());
if (!session_key_.CanUseForAliasing(other_session_key)) {
return false;
}
SSLInfo ssl_info;
if (!GetSSLInfo(&ssl_info) || !ssl_info.cert.get()) {
NOTREACHED() << "QUIC should always have certificates.";
}
return SpdySession::CanPool(transport_security_state_, ssl_info,
*ssl_config_service_, session_key_.host(),
hostname);
}
bool QuicChromiumClientSession::ShouldCreateIncomingStream(
quic::QuicStreamId id) {
if (!connection()->connected()) {
LOG(DFATAL) << "ShouldCreateIncomingStream called when disconnected";
return false;
}
if (goaway_received()) {
DVLOG(1) << "Cannot create a new outgoing stream. "
<< "Already received goaway.";
return false;
}
if (going_away_) {
return false;
}
if (quic::QuicUtils::IsClientInitiatedStreamId(
connection()->transport_version(), id) ||
quic::QuicUtils::IsBidirectionalStreamId(id, connection()->version())) {
LOG(WARNING) << "Received invalid push stream id " << id;
connection()->CloseConnection(
quic::QUIC_INVALID_STREAM_ID,
"Server created non write unidirectional stream",
quic::ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET);
return false;
}
return true;
}
QuicChromiumClientStream* QuicChromiumClientSession::CreateIncomingStream(
quic::QuicStreamId id) {
if (!ShouldCreateIncomingStream(id)) {
return nullptr;
}
net::NetworkTrafficAnnotationTag traffic_annotation =
net::DefineNetworkTrafficAnnotation("quic_chromium_incoming_session", R"(
semantics {
sender: "Quic Chromium Client Session"
description:
"When a web server needs to push a response to a client, an incoming "
"stream is created to reply the client with pushed message instead "
"of a message from the network."
trigger:
"A request by a server to push a response to the client."
data: "None."
destination: OTHER
destination_other:
"This stream is not used for sending data."
}
policy {
cookies_allowed: NO
setting: "This feature cannot be disabled in settings."
policy_exception_justification:
"Essential for network access."
}
)");
return CreateIncomingReliableStreamImpl(id, traffic_annotation);
}
QuicChromiumClientStream* QuicChromiumClientSession::CreateIncomingStream(
quic::PendingStream* pending) {
net::NetworkTrafficAnnotationTag traffic_annotation =
net::DefineNetworkTrafficAnnotation(
"quic_chromium_incoming_pending_session", R"(
semantics {
sender: "Quic Chromium Client Session Pending Stream"
description:
"When a web server needs to push a response to a client, an incoming "
"stream is created to reply to the client with pushed message instead "
"of a message from the network."
trigger:
"A request by a server to push a response to the client."
data: "This stream is only used to receive data from the server."
destination: OTHER
destination_other:
"The web server pushing the response."
}
policy {
cookies_allowed: NO
setting: "This feature cannot be disabled in settings."
policy_exception_justification:
"Essential for network access."
}
)");
return CreateIncomingReliableStreamImpl(pending, traffic_annotation);
}
QuicChromiumClientStream*
QuicChromiumClientSession::CreateIncomingReliableStreamImpl(
quic::QuicStreamId id,
const NetworkTrafficAnnotationTag& traffic_annotation) {
DCHECK(connection()->connected());
QuicChromiumClientStream* stream = new QuicChromiumClientStream(
id, this, server_id(), quic::READ_UNIDIRECTIONAL, net_log_,
traffic_annotation);
ActivateStream(base::WrapUnique(stream));
++num_total_streams_;
return stream;
}
QuicChromiumClientStream*
QuicChromiumClientSession::CreateIncomingReliableStreamImpl(
quic::PendingStream* pending,
const NetworkTrafficAnnotationTag& traffic_annotation) {
DCHECK(connection()->connected());
QuicChromiumClientStream* stream = new QuicChromiumClientStream(
pending, this, server_id(), net_log_, traffic_annotation);
ActivateStream(base::WrapUnique(stream));
++num_total_streams_;
return stream;
}
void QuicChromiumClientSession::OnStreamClosed(quic::QuicStreamId stream_id) {
most_recent_stream_close_time_ = tick_clock_->NowTicks();
quic::QuicStream* stream = GetActiveStream(stream_id);
if (stream != nullptr) {
logger_->UpdateReceivedFrameCounts(stream_id, stream->num_frames_received(),
stream->num_duplicate_frames_received());
}
quic::QuicSpdyClientSessionBase::OnStreamClosed(stream_id);
}
bool QuicChromiumClientSession::ShouldKeepConnectionAlive() const {
// `quic::QuicSpdyClientSessionBase::ShouldKeepConnectionAlive` returns true
// when we have an outstanding request in flight. We want to send PINGs when
// there is an outstanding request or if `enable_periodic_ping_` has been
// set to keep the connection alive when idle.
return (enable_periodic_ping_ && crypto_handshake_complete_) ||
quic::QuicSpdyClientSessionBase::ShouldKeepConnectionAlive();
}
void QuicChromiumClientSession::OnCanCreateNewOutgoingStream(
bool unidirectional) {
while (CanOpenNextOutgoingBidirectionalStream() &&
!stream_requests_.empty() &&
crypto_stream_->encryption_established() && !goaway_received() &&
!going_away_ && connection()->connected()) {
StreamRequest* request = stream_requests_.front();
// TODO(ckrasic) - analyze data and then add logic to mark QUIC
// broken if wait times are excessive.
UMA_HISTOGRAM_TIMES("Net.QuicSession.PendingStreamsWaitTime",
tick_clock_->NowTicks() - request->pending_start_time_);
stream_requests_.pop_front();
#if BUILDFLAG(ENABLE_WEBSOCKETS)
if (request->for_websockets_) {
std::unique_ptr<WebSocketQuicStreamAdapter> adapter =
CreateWebSocketQuicStreamAdapterImpl(
request->websocket_adapter_delegate_);
request->websocket_adapter_delegate_ = nullptr;
std::move(request->start_websocket_callback_).Run(std::move(adapter));
continue;
}
#endif // BUILDFLAG(ENABLE_WEBSOCKETS)
request->OnRequestCompleteSuccess(
CreateOutgoingReliableStreamImpl(request->traffic_annotation())
->CreateHandle());
}
}
quic::QuicSSLConfig QuicChromiumClientSession::GetSSLConfig() const {
quic::QuicSSLConfig config = quic::QuicSpdyClientSessionBase::GetSSLConfig();
SSLContextConfig ssl_context_config =
ssl_config_service_->GetSSLContextConfig();
if (ssl_context_config.ech_enabled) {
config.ech_grease_enabled = true;
config.ech_config_list.assign(ech_config_list_.begin(),
ech_config_list_.end());
}
if (base::FeatureList::IsEnabled(features::kTLSTrustAnchorIDs)) {
if (!trust_anchor_ids_.empty() &&
!ssl_context_config.trust_anchor_ids.empty()) {
std::vector<uint8_t> selected_trust_anchor_ids =
SSLConfig::SelectTrustAnchorIDs(trust_anchor_ids_,
ssl_context_config.trust_anchor_ids);
config.trust_anchor_ids = std::string(selected_trust_anchor_ids.begin(),
selected_trust_anchor_ids.end());
}
}
return config;
}
void QuicChromiumClientSession::SetDefaultEncryptionLevel(
quic::EncryptionLevel level) {
if (!callback_.is_null() &&
(!require_confirmation_ || level == quic::ENCRYPTION_FORWARD_SECURE ||
level == quic::ENCRYPTION_ZERO_RTT)) {
// Currently for all CryptoHandshakeEvent events, callback_
// could be called because there are no error events in CryptoHandshakeEvent
// enum. If error events are added to CryptoHandshakeEvent, then the
// following code needs to changed.
std::move(callback_).Run(OK);
}
if (level == quic::ENCRYPTION_FORWARD_SECURE) {
OnCryptoHandshakeComplete();
LogZeroRttStats();
}
if (level == quic::ENCRYPTION_ZERO_RTT) {
attempted_zero_rtt_ = true;
}
quic::QuicSpdySession::SetDefaultEncryptionLevel(level);
}
void QuicChromiumClientSession::OnTlsHandshakeComplete() {
if (!callback_.is_null()) {
// Currently for all CryptoHandshakeEvent events, callback_
// could be called because there are no error events in CryptoHandshakeEvent
// enum. If error events are added to CryptoHandshakeEvent, then the
// following code needs to changed.
std::move(callback_).Run(OK);
}
OnCryptoHandshakeComplete();
LogZeroRttStats();
quic::QuicSpdySession::OnTlsHandshakeComplete();
}
void QuicChromiumClientSession::RegisterQuicConnectionClosePayload() {
if (!base::FeatureList::IsEnabled(
features::kQuicRegisterConnectionClosePayload)) {
return;
}
std::unique_ptr<quic::SerializedPacket> connection_close_packet =
connection()->SerializeLargePacketNumberConnectionClosePacket(
quic::QUIC_CLIENT_LOST_NETWORK_ACCESS,
"App loses network access on Android");
base::span<uint8_t> payload(
(uint8_t*)connection_close_packet->encrypted_buffer,
connection_close_packet->encrypted_length);
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->RegisterQuicConnectionClosePayload(payload);
}
void QuicChromiumClientSession::UnregisterQuicConnectionClosePayload() {
if (!base::FeatureList::IsEnabled(
features::kQuicRegisterConnectionClosePayload)) {
return;
}
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->UnregisterQuicConnectionClosePayload();
}
void QuicChromiumClientSession::OnTlsHandshakeConfirmed() {
RegisterQuicConnectionClosePayload();
quic::QuicSpdySession::OnTlsHandshakeConfirmed();
}
void QuicChromiumClientSession::OnNewEncryptionKeyAvailable(
quic::EncryptionLevel level,
std::unique_ptr<quic::QuicEncrypter> encrypter) {
if (!attempted_zero_rtt_ && (level == quic::ENCRYPTION_ZERO_RTT ||
level == quic::ENCRYPTION_FORWARD_SECURE)) {
base::TimeTicks now = tick_clock_->NowTicks();
DCHECK_LE(connect_timing_.connect_start, now);
UMA_HISTOGRAM_TIMES("Net.QuicSession.EncryptionEstablishedTime",
now - connect_timing_.connect_start);
}
if (level == quic::ENCRYPTION_ZERO_RTT) {
attempted_zero_rtt_ = true;
}
QuicSpdySession::OnNewEncryptionKeyAvailable(level, std::move(encrypter));
if (!callback_.is_null() &&
(!require_confirmation_ && level == quic::ENCRYPTION_ZERO_RTT)) {
// Currently for all CryptoHandshakeEvent events, callback_
// could be called because there are no error events in CryptoHandshakeEvent
// enum. If error events are added to CryptoHandshakeEvent, then the
// following code needs to changed.
std::move(callback_).Run(OK);
}
}
void QuicChromiumClientSession::LogZeroRttStats() {
DCHECK(OneRttKeysAvailable());
ZeroRttState state;
ssl_early_data_reason_t early_data_reason = crypto_stream_->EarlyDataReason();
if (early_data_reason == ssl_early_data_accepted) {
state = ZeroRttState::kAttemptedAndSucceeded;
} else if (early_data_reason == ssl_early_data_peer_declined ||
early_data_reason == ssl_early_data_session_not_resumed ||
early_data_reason == ssl_early_data_hello_retry_request) {
state = ZeroRttState::kAttemptedAndRejected;
} else {
state = ZeroRttState::kNotAttempted;
}
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttState", state);
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttReason", early_data_reason,
ssl_early_data_reason_max_value + 1);
if (IsGoogleHost(session_key_.host())) {
if (IsGoogleHostWithAlpnH3(session_key_.host())) {
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttState.GoogleWithAlpnH3",
state);
UMA_HISTOGRAM_ENUMERATION(
"Net.QuicSession.ZeroRttReason.GoogleWithAlpnH3", early_data_reason,
ssl_early_data_reason_max_value + 1);
}
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttState.Google", state);
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttReason.Google",
early_data_reason,
ssl_early_data_reason_max_value + 1);
} else {
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttState.NonGoogle", state);
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ZeroRttReason.NonGoogle",
early_data_reason,
ssl_early_data_reason_max_value + 1);
}
net_log_.AddEvent(NetLogEventType::QUIC_SESSION_ZERO_RTT_STATE, [&] {
return base::Value::Dict().Set("state", ZeroRttStateToString(state));
});
}
void QuicChromiumClientSession::OnCryptoHandshakeMessageSent(
const quic::CryptoHandshakeMessage& message) {
logger_->OnCryptoHandshakeMessageSent(message);
}
void QuicChromiumClientSession::OnCryptoHandshakeMessageReceived(
const quic::CryptoHandshakeMessage& message) {
logger_->OnCryptoHandshakeMessageReceived(message);
if (message.tag() == quic::kREJ) {
UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.RejectLength",
message.GetSerialized().length(), 1000, 10000,
50);
std::string_view proof;
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.RejectHasProof",
message.GetStringPiece(quic::kPROF, &proof));
}
}
void QuicChromiumClientSession::OnGoAway(const quic::QuicGoAwayFrame& frame) {
quic::QuicSession::OnGoAway(frame);
NotifyFactoryOfSessionGoingAway();
port_migration_detected_ =
frame.error_code == quic::QUIC_ERROR_MIGRATING_PORT;
}
void QuicChromiumClientSession::OnConnectionClosed(
const quic::QuicConnectionCloseFrame& frame,
quic::ConnectionCloseSource source) {
DCHECK(!connection()->connected());
logger_->OnConnectionClosed(frame, source);
source_ = source;
UMA_HISTOGRAM_COUNTS_1000("Net.QuicSession.NumDefaultPathDegrading",
connection()->GetStats().num_path_degrading);
if (connection()->GetStats().num_path_degrading > 0) {
UMA_HISTOGRAM_COUNTS_1000(
"Net.QuicSession.NumForwardProgressMadeAfterPathDegrading",
connection()->GetStats().num_forward_progress_after_path_degrading);
}
if (const quic::QuicConnection::MultiPortStats* multi_port_stats =
connection()->multi_port_stats()) {
UMA_HISTOGRAM_COUNTS_1000("Net.QuicMultiPort.NumProbeAttempts",
multi_port_stats->num_client_probing_attempts);
UMA_HISTOGRAM_COUNTS_1000("Net.QuicMultiPort.NumSuccessfulProbes",
multi_port_stats->num_successful_probes);
UMA_HISTOGRAM_COUNTS_1000(
"Net.QuicMultiPort.NumMultiPortFailureWhenPathNotDegrading",
multi_port_stats
->num_multi_port_probe_failures_when_path_not_degrading);
size_t total_multi_port_probe_failures =
multi_port_stats
->num_multi_port_probe_failures_when_path_not_degrading +
multi_port_stats->num_multi_port_probe_failures_when_path_degrading;
uint64_t srtt_ms =
multi_port_stats->rtt_stats.smoothed_rtt().ToMilliseconds();
if (connection()->GetStats().num_path_degrading > 0 &&
total_multi_port_probe_failures > 0 && srtt_ms > 0) {
base::UmaHistogramSparse(
"Net.QuicMultiPort.AltPortRttWhenPathDegradingVsGeneral",
static_cast<int>(
multi_port_stats->rtt_stats_when_default_path_degrading
.smoothed_rtt()
.ToMilliseconds() *
100 / srtt_ms));
UMA_HISTOGRAM_COUNTS_1000(
"Net.QuicMultiPort.NumMultiPortFailureWhenPathDegrading",
multi_port_stats->num_multi_port_probe_failures_when_path_degrading);
base::UmaHistogramPercentage(
"Net.QuicMultiPort.AltPortFailureWhenPathDegradingVsGeneral",
static_cast<int>(
multi_port_stats
->num_multi_port_probe_failures_when_path_degrading *
100 / total_multi_port_probe_failures));
}
}
RecordConnectionCloseErrorCode(frame, source, session_key_.host(),
OneRttKeysAvailable(),
!ech_config_list_.empty());
if (OneRttKeysAvailable()) {
handles::NetworkHandle current_network = GetCurrentNetwork();
for (auto& observer : connectivity_observer_list_) {
observer.OnSessionClosedAfterHandshake(this, current_network, source,
frame.quic_error_code);
}
}
const quic::QuicErrorCode error = frame.quic_error_code;
const std::string& error_details = frame.error_details;
if (source == quic::ConnectionCloseSource::FROM_SELF &&
error == quic::QUIC_NETWORK_IDLE_TIMEOUT && ShouldKeepConnectionAlive()) {
quic::QuicStreamCount streams_waiting_to_write = 0;
PerformActionOnActiveStreams(
[&streams_waiting_to_write](quic::QuicStream* stream) {
if (stream->HasBufferedData()) {
++streams_waiting_to_write;
}
return true;
});
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.NumStreamsWaitingToWriteOnIdleTimeout",
streams_waiting_to_write);
UMA_HISTOGRAM_COUNTS_100("Net.QuicSession.NumActiveStreamsOnIdleTimeout",
GetNumActiveStreams());
if (IsGoogleHostWithAlpnH3(session_key_.host())) {
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.NumStreamsWaitingToWriteOnIdleTimeout."
"GoogleWithAlpnH3",
streams_waiting_to_write);
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.NumActiveStreamsOnIdleTimeout.GoogleHost."
"GoogleWithAlpnH3",
GetNumActiveStreams());
}
}
if (source == quic::ConnectionCloseSource::FROM_PEER) {
if (error == quic::QUIC_PUBLIC_RESET) {
// is_from_google_server will be true if the received EPID is
// kEPIDGoogleFrontEnd or kEPIDGoogleFrontEnd0.
const bool is_from_google_server =
error_details.find(base::StringPrintf(
"From %s", quic::kEPIDGoogleFrontEnd)) != std::string::npos;
if (OneRttKeysAvailable()) {
UMA_HISTOGRAM_BOOLEAN(
"Net.QuicSession.ClosedByPublicReset.HandshakeConfirmed",
is_from_google_server);
} else {
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.ClosedByPublicReset",
is_from_google_server);
}
if (is_from_google_server) {
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.NumMigrationsExercisedBeforePublicReset",
packet_readers_.size() - 1);
}
base::UmaHistogramSparse(
"Net.QuicSession.LastSentPacketContentBeforePublicReset",
connection()
->sent_packet_manager()
.unacked_packets()
.GetLastPacketContent());
const quic::QuicTime last_in_flight_packet_sent_time =
connection()
->sent_packet_manager()
.unacked_packets()
.GetLastInFlightPacketSentTime();
const quic::QuicTime handshake_completion_time =
connection()->GetStats().handshake_completion_time;
if (last_in_flight_packet_sent_time.IsInitialized() &&
handshake_completion_time.IsInitialized() &&
last_in_flight_packet_sent_time >= handshake_completion_time) {
const quic::QuicTime::Delta delay =
last_in_flight_packet_sent_time - handshake_completion_time;
UMA_HISTOGRAM_LONG_TIMES_100(
"Net.QuicSession."
"LastInFlightPacketSentTimeFromHandshakeCompletionWithPublicReset",
base::Milliseconds(delay.ToMilliseconds()));
}
UMA_HISTOGRAM_LONG_TIMES_100(
"Net.QuicSession.ConnectionDurationWithPublicReset",
tick_clock_->NowTicks() - connect_timing_.connect_end);
}
if (OneRttKeysAvailable()) {
base::HistogramBase* histogram = base::SparseHistogram::FactoryGet(
"Net.QuicSession.StreamCloseErrorCodeServer.HandshakeConfirmed",
base::HistogramBase::kUmaTargetedHistogramFlag);
size_t num_streams = GetNumActiveStreams();
if (num_streams > 0) {
histogram->AddCount(error, num_streams);
}
}
} else {
if (OneRttKeysAvailable()) {
base::HistogramBase* histogram = base::SparseHistogram::FactoryGet(
"Net.QuicSession.StreamCloseErrorCodeClient.HandshakeConfirmed",
base::HistogramBase::kUmaTargetedHistogramFlag);
size_t num_streams = GetNumActiveStreams();
if (num_streams > 0) {
histogram->AddCount(error, num_streams);
}
} else {
if (error == quic::QUIC_HANDSHAKE_TIMEOUT) {
UMA_HISTOGRAM_BOOLEAN(
"Net.QuicSession.HandshakeTimeout.PathDegradingDetected",
connection()->IsPathDegrading());
}
}
if (error == quic::QUIC_TOO_MANY_RTOS) {
UMA_HISTOGRAM_COUNTS_1000(
"Net.QuicSession.ClosedByRtoAtClient.ReceivedPacketCount",
connection()->GetStats().packets_received);
UMA_HISTOGRAM_COUNTS_1000(
"Net.QuicSession.ClosedByRtoAtClient.SentPacketCount",
connection()->GetStats().packets_sent);
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession."
"MaxConsecutiveRtoWithForwardProgressAndBlackholeDetected",
connection()->GetStats().max_consecutive_rto_with_forward_progress);
}
}
if (error == quic::QUIC_NETWORK_IDLE_TIMEOUT) {
UMA_HISTOGRAM_COUNTS_1M(
"Net.QuicSession.ConnectionClose.NumOpenStreams.TimedOut",
GetNumActiveStreams());
if (OneRttKeysAvailable()) {
if (GetNumActiveStreams() > 0) {
UMA_HISTOGRAM_BOOLEAN(
"Net.QuicSession.TimedOutWithOpenStreams.HasUnackedPackets",
connection()->sent_packet_manager().HasInFlightPackets());
UMA_HISTOGRAM_COUNTS_1M(
"Net.QuicSession.TimedOutWithOpenStreams.ConsecutivePTOCount",
connection()->sent_packet_manager().GetConsecutivePtoCount());
base::UmaHistogramSparse(
"Net.QuicSession.TimedOutWithOpenStreams.LocalPort",
connection()->self_address().port());
}
} else {
UMA_HISTOGRAM_COUNTS_1M(
"Net.QuicSession.ConnectionClose.NumOpenStreams.HandshakeTimedOut",
GetNumActiveStreams());
UMA_HISTOGRAM_COUNTS_1M(
"Net.QuicSession.ConnectionClose.NumTotalStreams.HandshakeTimedOut",
num_total_streams_);
}
}
if (OneRttKeysAvailable()) {
// QUIC connections should not timeout while there are open streams,
// since PING frames are sent to prevent timeouts. If, however, the
// connection timed out with open streams then QUIC traffic has become
// blackholed. Alternatively, if too many retransmission timeouts occur
// then QUIC traffic has become blackholed.
if (session_pool_ && (error == quic::QUIC_TOO_MANY_RTOS ||
(error == quic::QUIC_NETWORK_IDLE_TIMEOUT &&
GetNumActiveStreams() > 0))) {
session_pool_->OnBlackholeAfterHandshakeConfirmed(this);
}
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.CryptoRetransmitCount.HandshakeConfirmed",
connection()->GetStats().crypto_retransmit_count);
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.MaxConsecutiveRtoWithForwardProgress",
connection()->GetStats().max_consecutive_rto_with_forward_progress);
UMA_HISTOGRAM_COUNTS_1000("Net.QuicSession.NumPingsSent",
connection()->GetStats().ping_frames_sent);
UMA_HISTOGRAM_COUNTS_100("Net.QuicSession.NumMigrations", num_migrations_);
if (IsGoogleHostWithAlpnH3(session_key_.host())) {
UMA_HISTOGRAM_COUNTS_1000("Net.QuicSession.NumPingsSent.GoogleWithAlpnH3",
connection()->GetStats().ping_frames_sent);
}
LogConnectionDurationMetrics(
tick_clock_->NowTicks() - connect_timing_.connect_end,
IsGoogleHostWithAlpnH3(session_key_.host()),
session_creation_initiator_);
// KeyUpdates are used in TLS, but we no longer support pre-TLS QUIC.
DCHECK(connection()->version().UsesTls());
base::UmaHistogramCounts100("Net.QuicSession.KeyUpdate.PerConnection2",
connection()->GetStats().key_update_count);
base::UmaHistogramCounts100(
"Net.QuicSession.KeyUpdate.PotentialPeerKeyUpdateAttemptCount",
connection()->PotentialPeerKeyUpdateAttemptCount());
if (last_key_update_reason_ != quic::KeyUpdateReason::kInvalid) {
std::string suffix =
last_key_update_reason_ == quic::KeyUpdateReason::kRemote ? "Remote"
: "Local";
// These values are persisted to logs. Entries should not be renumbered
// and numeric values should never be reused.
enum class KeyUpdateSuccess {
kInvalid = 0,
kSuccess = 1,
kFailedInitial = 2,
kFailedNonInitial = 3,
kMaxValue = kFailedNonInitial,
};
KeyUpdateSuccess value = KeyUpdateSuccess::kInvalid;
if (connection()->HaveSentPacketsInCurrentKeyPhaseButNoneAcked()) {
if (connection()->GetStats().key_update_count >= 2) {
value = KeyUpdateSuccess::kFailedNonInitial;
} else {
value = KeyUpdateSuccess::kFailedInitial;
}
} else {
value = KeyUpdateSuccess::kSuccess;
}
base::UmaHistogramEnumeration(
"Net.QuicSession.KeyUpdate.Success." + suffix, value);
}
} else {
if (error == quic::QUIC_PUBLIC_RESET) {
RecordHandshakeFailureReason(HANDSHAKE_FAILURE_PUBLIC_RESET);
} else if (connection()->GetStats().packets_received == 0) {
RecordHandshakeFailureReason(HANDSHAKE_FAILURE_BLACK_HOLE);
base::UmaHistogramSparse(
"Net.QuicSession.ConnectionClose.HandshakeFailureBlackHole.QuicError",
error);
} else {
RecordHandshakeFailureReason(HANDSHAKE_FAILURE_UNKNOWN);
base::UmaHistogramSparse(
"Net.QuicSession.ConnectionClose.HandshakeFailureUnknown.QuicError",
error);
}
UMA_HISTOGRAM_COUNTS_100(
"Net.QuicSession.CryptoRetransmitCount.HandshakeNotConfirmed",
connection()->GetStats().crypto_retransmit_count);
}
base::UmaHistogramCounts1M(
"Net.QuicSession.UndecryptablePacketsReceivedWithDecrypter",
connection()->GetStats().num_failed_authentication_packets_received);
base::UmaHistogramSparse("Net.QuicSession.QuicVersion",
connection()->transport_version());
NotifyFactoryOfSessionGoingAway();
quic::QuicSession::OnConnectionClosed(frame, source);
if (!callback_.is_null()) {
std::move(callback_).Run(ERR_QUIC_PROTOCOL_ERROR);
}
UnregisterQuicConnectionClosePayload();
bool socket_found_in_writer = false;
for (auto& packet_reader : packet_readers_) {
packet_reader->CloseSocket();
// If a writer exists that was not destroyed when the connection migrated,
// then that writer may not be notified that its socket has been closed.
// We know that the writer is a QuicChromiumPacketWriter since the packet
// writer is set with the same type originally.
socket_found_in_writer |=
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->OnSocketClosed(packet_reader->socket());
}
CHECK(socket_found_in_writer);
DCHECK(!HasActiveRequestStreams());
CloseAllHandles(ERR_UNEXPECTED);
CancelAllRequests(ERR_CONNECTION_CLOSED);
NotifyRequestsOfConfirmation(ERR_CONNECTION_CLOSED);
NotifyFactoryOfSessionClosedLater();
}
void QuicChromiumClientSession::OnSuccessfulVersionNegotiation(
const quic::ParsedQuicVersion& version) {
logger_->OnSuccessfulVersionNegotiation(version);
quic::QuicSpdySession::OnSuccessfulVersionNegotiation(version);
}
int QuicChromiumClientSession::HandleWriteError(
int error_code,
scoped_refptr<QuicChromiumPacketWriter::ReusableIOBuffer> packet) {
current_migration_cause_ = ON_WRITE_ERROR;
LogHandshakeStatusOnMigrationSignal();
base::UmaHistogramSparse("Net.QuicSession.WriteError", -error_code);
if (OneRttKeysAvailable()) {
base::UmaHistogramSparse("Net.QuicSession.WriteError.HandshakeConfirmed",
-error_code);
}
// For now, skip reporting if there are multiple packet writers and
// connection migration is enabled.
if (packet_readers_.size() == 1u || !migrate_session_early_v2_) {
handles::NetworkHandle current_network = GetCurrentNetwork();
for (auto& observer : connectivity_observer_list_) {
observer.OnSessionEncounteringWriteError(this, current_network,
error_code);
}
}
// Proxied sessions cannot presently encounter write errors, but in case that
// changes, those sessions should not attempt migration when such an error
// occurs. The underlying connection to the proxy server may still migrate.
if (!session_key_.proxy_chain().is_direct()) {
return error_code;
}
if (error_code == ERR_MSG_TOO_BIG || session_pool_ == nullptr ||
!migrate_session_on_network_change_v2_ || !OneRttKeysAvailable()) {
return error_code;
}
handles::NetworkHandle current_network = GetCurrentNetwork();
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_ON_WRITE_ERROR, "network",
current_network);
DCHECK(packet != nullptr);
DCHECK_NE(ERR_IO_PENDING, error_code);
DCHECK_GT(0, error_code);
DCHECK(packet_ == nullptr);
// Post a task to migrate the session onto a new network.
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(
&QuicChromiumClientSession::MigrateSessionOnWriteError,
weak_factory_.GetWeakPtr(), error_code,
// UnsafeDanglingUntriaged triggered by test:
// QuicSessionPoolTest.MigrateSessionOnSyncWriteErrorPauseBeforeConnected
// TODO(crbug.com/40061562): Remove `UnsafeDanglingUntriaged`
base::UnsafeDanglingUntriaged(connection()->writer())));
ignore_read_error_ = true;
// Cause the packet writer to return ERR_IO_PENDING and block so
// that the actual migration happens from the message loop instead
// of under the call stack of quic::QuicConnection::WritePacket.
return ERR_IO_PENDING;
}
void QuicChromiumClientSession::MigrateSessionOnWriteError(
int error_code,
quic::QuicPacketWriter* writer) {
DCHECK(migrate_session_on_network_change_v2_);
// If |writer| is no longer actively in use, or a session migration has
// started from MigrateNetworkImmediately, abort this migration attempt.
if (writer != connection()->writer() ||
pending_migrate_network_immediately_) {
return;
}
most_recent_write_error_timestamp_ = tick_clock_->NowTicks();
most_recent_write_error_ = error_code;
if (session_pool_ == nullptr) {
// Close the connection if migration failed. Do not cause a
// connection close packet to be sent since socket may be borked.
connection()->CloseConnection(quic::QUIC_PACKET_WRITE_ERROR,
"Write error with nulled stream factory",
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
current_migration_cause_ = ON_WRITE_ERROR;
if (migrate_idle_session_ && CheckIdleTimeExceedsIdleMigrationPeriod()) {
return;
}
if (!migrate_idle_session_ && !HasActiveRequestStreams()) {
// connection close packet to be sent since socket may be borked.
connection()->CloseConnection(quic::QUIC_PACKET_WRITE_ERROR,
"Write error for non-migratable session",
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
// Do not migrate if connection migration is disabled.
if (config()->DisableConnectionMigration()) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_DISABLED_BY_CONFIG,
connection_id(),
"Migration disabled by config");
// Close the connection since migration was disabled. Do not cause a
// connection close packet to be sent since socket may be borked.
connection()->CloseConnection(quic::QUIC_PACKET_WRITE_ERROR,
"Write error for non-migratable session",
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
handles::NetworkHandle new_network =
session_pool_->FindAlternateNetwork(GetCurrentNetwork());
if (new_network == handles::kInvalidNetworkHandle) {
// No alternate network found.
HistogramAndLogMigrationFailure(MIGRATION_STATUS_NO_ALTERNATE_NETWORK,
connection_id(),
"No alternate network found");
OnNoNewNetwork();
return;
}
if (GetCurrentNetwork() == default_network_ &&
current_migrations_to_non_default_network_on_write_error_ >=
max_migrations_to_non_default_network_on_write_error_) {
HistogramAndLogMigrationFailure(
MIGRATION_STATUS_ON_WRITE_ERROR_DISABLED, connection_id(),
"Exceeds maximum number of migrations on write error");
connection()->CloseConnection(
quic::QUIC_PACKET_WRITE_ERROR,
"Too many migrations for write error for the same network",
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
current_migrations_to_non_default_network_on_write_error_++;
net_log_.BeginEventWithStringParams(
NetLogEventType::QUIC_CONNECTION_MIGRATION_TRIGGERED, "trigger",
"WriteError");
pending_migrate_session_on_write_error_ = true;
Migrate(new_network, ToIPEndPoint(connection()->peer_address()),
/*close_session_on_error=*/false,
base::BindOnce(
&QuicChromiumClientSession::FinishMigrateSessionOnWriteError,
weak_factory_.GetWeakPtr(), new_network));
net_log_.EndEvent(NetLogEventType::QUIC_CONNECTION_MIGRATION_TRIGGERED);
}
void QuicChromiumClientSession::FinishMigrateSessionOnWriteError(
handles::NetworkHandle new_network,
MigrationResult result) {
pending_migrate_session_on_write_error_ = false;
if (result == MigrationResult::FAILURE) {
// Close the connection if migration failed. Do not cause a
// connection close packet to be sent since socket may be borked.
connection()->CloseConnection(quic::QUIC_PACKET_WRITE_ERROR,
"Write and subsequent migration failed",
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
if (new_network != default_network_) {
StartMigrateBackToDefaultNetworkTimer(
base::Seconds(kMinRetryTimeForDefaultNetworkSecs));
} else {
CancelMigrateBackToDefaultNetworkTimer();
}
}
void QuicChromiumClientSession::OnNoNewNetwork() {
DCHECK(OneRttKeysAvailable());
wait_for_new_network_ = true;
net_log_.AddEvent(
NetLogEventType::QUIC_CONNECTION_MIGRATION_WAITING_FOR_NEW_NETWORK);
DVLOG(1) << "Force blocking the packet writer";
// Force blocking the packet writer to avoid any writes since there is no
// alternate network available.
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_force_write_blocked(true);
if (base::FeatureList::IsEnabled(features::kDisableBlackholeOnNoNewNetwork)) {
// Turn off the black hole detector since the writer is blocked.
// Blackhole will be re-enabled once a packet is sent again.
connection()->blackhole_detector().StopDetection(false);
}
// Post a task to maybe close the session if the alarm fires.
task_runner_->PostDelayedTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::OnMigrationTimeout,
weak_factory_.GetWeakPtr(), packet_readers_.size()),
base::Seconds(kWaitTimeForNewNetworkSecs));
}
void QuicChromiumClientSession::WriteToNewSocket() {
// Set |send_packet_after_migration_| to true so that a packet will be
// sent when the writer becomes unblocked.
send_packet_after_migration_ = true;
DVLOG(1) << "Cancel force blocking the packet writer";
// Notify writer that it is no longer forced blocked, which may call
// OnWriteUnblocked() if the writer has no write in progress.
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_force_write_blocked(false);
}
void QuicChromiumClientSession::OnMigrationTimeout(size_t num_sockets) {
// If number of sockets has changed, this migration task is stale.
if (num_sockets != packet_readers_.size()) {
return;
}
net_log_.AddEvent(
NetLogEventType::QUIC_CONNECTION_MIGRATION_FAILURE_WAITING_FOR_NETWORK);
int net_error = current_migration_cause_ == ON_NETWORK_DISCONNECTED
? ERR_INTERNET_DISCONNECTED
: ERR_NETWORK_CHANGED;
// |current_migration_cause_| will be reset after logging.
LogMigrationResultToHistogram(MIGRATION_STATUS_TIMEOUT);
CloseSessionOnError(net_error, quic::QUIC_CONNECTION_MIGRATION_NO_NEW_NETWORK,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
}
void QuicChromiumClientSession::OnPortMigrationProbeSucceeded(
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address,
const quic::QuicSocketAddress& self_address,
std::unique_ptr<QuicChromiumPacketWriter> writer,
std::unique_ptr<QuicChromiumPacketReader> reader) {
DCHECK(writer);
DCHECK(reader);
// Writer must be destroyed before reader, since it points to the socket owned
// by reader. C++ doesn't have any guarantees about destruction order of
// arguments.
std::unique_ptr<QuicChromiumPacketWriter> writer_moved = std::move(writer);
net_log_.AddEvent(NetLogEventType::QUIC_SESSION_CONNECTIVITY_PROBING_FINISHED,
[&] {
return NetLogProbingResultParams(network, &peer_address,
/*is_success=*/true);
});
LogProbeResultToHistogram(current_migration_cause_, true);
// Remove |this| as the old packet writer's delegate. Write error on old
// writers will be ignored.
// Set |this| to listen on socket write events on the packet writer
// that was used for probing.
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_delegate(nullptr);
writer_moved->set_delegate(this);
if (!migrate_idle_session_ && !HasActiveRequestStreams()) {
// If idle sessions won't be migrated, close the connection.
CloseSessionOnErrorLater(
ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_NO_MIGRATABLE_STREAMS,
quic::ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET);
return;
}
if (migrate_idle_session_ && CheckIdleTimeExceedsIdleMigrationPeriod()) {
return;
}
// Migrate to the probed socket immediately: socket, writer and reader will
// be acquired by connection and used as default on success.
if (!MigrateToSocket(self_address, peer_address, std::move(reader),
std::move(writer_moved))) {
LogMigrateToSocketStatus(false);
net_log_.AddEvent(
NetLogEventType::QUIC_CONNECTION_MIGRATION_FAILURE_AFTER_PROBING);
return;
}
LogMigrateToSocketStatus(true);
num_migrations_++;
HistogramAndLogMigrationSuccess(connection_id());
}
void QuicChromiumClientSession::OnConnectionMigrationProbeSucceeded(
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address,
const quic::QuicSocketAddress& self_address,
std::unique_ptr<QuicChromiumPacketWriter> writer,
std::unique_ptr<QuicChromiumPacketReader> reader) {
DCHECK(writer);
DCHECK(reader);
// Writer must be destroyed before reader, since it points to the socket owned
// by reader. C++ doesn't have any guarantees about destruction order of
// arguments.
std::unique_ptr<QuicChromiumPacketWriter> writer_moved = std::move(writer);
net_log_.AddEvent(NetLogEventType::QUIC_SESSION_CONNECTIVITY_PROBING_FINISHED,
[&] {
return NetLogProbingResultParams(network, &peer_address,
/*is_success=*/true);
});
if (network == handles::kInvalidNetworkHandle) {
return;
}
LogProbeResultToHistogram(current_migration_cause_, true);
// Remove |this| as the old packet writer's delegate. Write error on old
// writers will be ignored.
// Set |this| to listen on socket write events on the packet writer
// that was used for probing.
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_delegate(nullptr);
writer_moved->set_delegate(this);
// Close streams that are not migratable to the probed |network|.
ResetNonMigratableStreams();
if (!migrate_idle_session_ && !HasActiveRequestStreams()) {
// If idle sessions won't be migrated, close the connection.
CloseSessionOnErrorLater(
ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_NO_MIGRATABLE_STREAMS,
quic::ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET);
return;
}
if (migrate_idle_session_ && CheckIdleTimeExceedsIdleMigrationPeriod()) {
return;
}
// Migrate to the probed socket immediately: socket, writer and reader will
// be acquired by connection and used as default on success.
if (!MigrateToSocket(self_address, peer_address, std::move(reader),
std::move(writer_moved))) {
LogMigrateToSocketStatus(false);
net_log_.AddEvent(
NetLogEventType::QUIC_CONNECTION_MIGRATION_FAILURE_AFTER_PROBING);
return;
}
LogMigrateToSocketStatus(true);
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_SUCCESS_AFTER_PROBING,
"migrate_to_network", network);
num_migrations_++;
HistogramAndLogMigrationSuccess(connection_id());
if (network == default_network_) {
DVLOG(1) << "Client successfully migrated to default network: "
<< default_network_;
CancelMigrateBackToDefaultNetworkTimer();
return;
}
DVLOG(1) << "Client successfully got off default network after "
<< "successful probing network: " << network << ".";
current_migrations_to_non_default_network_on_path_degrading_++;
if (!migrate_back_to_default_timer_.IsRunning()) {
current_migration_cause_ = ON_MIGRATE_BACK_TO_DEFAULT_NETWORK;
// Session gets off the |default_network|, stay on |network| for now but
// try to migrate back to default network after 1 second.
StartMigrateBackToDefaultNetworkTimer(
base::Seconds(kMinRetryTimeForDefaultNetworkSecs));
}
}
void QuicChromiumClientSession::OnServerPreferredAddressProbeSucceeded(
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address,
const quic::QuicSocketAddress& self_address,
std::unique_ptr<QuicChromiumPacketWriter> writer,
std::unique_ptr<QuicChromiumPacketReader> reader) {
// Writer must be destroyed before reader, since it points to the socket owned
// by reader. C++ doesn't have any guarantees about destruction order of
// arguments.
std::unique_ptr<QuicChromiumPacketWriter> writer_moved = std::move(writer);
net_log_.AddEvent(NetLogEventType::QUIC_SESSION_CONNECTIVITY_PROBING_FINISHED,
[&] {
return NetLogProbingResultParams(network, &peer_address,
/*is_success=*/true);
});
LogProbeResultToHistogram(current_migration_cause_, true);
connection()->mutable_stats().server_preferred_address_validated = true;
// Remove |this| as the old packet writer's delegate. Write error on old
// writers will be ignored.
// Set |this| to listen on socket write events on the packet writer
// that was used for probing.
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_delegate(nullptr);
writer_moved->set_delegate(this);
// Migrate to the probed socket immediately: socket, writer and reader will
// be acquired by connection and used as default on success.
if (!MigrateToSocket(self_address, peer_address, std::move(reader),
std::move(writer_moved))) {
LogMigrateToSocketStatus(false);
net_log_.AddEvent(
NetLogEventType::QUIC_CONNECTION_MIGRATION_FAILURE_AFTER_PROBING);
return;
}
LogMigrateToSocketStatus(true);
num_migrations_++;
HistogramAndLogMigrationSuccess(connection_id());
}
void QuicChromiumClientSession::OnProbeFailed(
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address) {
net_log_.AddEvent(NetLogEventType::QUIC_SESSION_CONNECTIVITY_PROBING_FINISHED,
[&] {
return NetLogProbingResultParams(network, &peer_address,
/*is_success=*/false);
});
LogProbeResultToHistogram(current_migration_cause_, false);
auto* context = static_cast<QuicChromiumPathValidationContext*>(
connection()->GetPathValidationContext());
if (!context) {
return;
}
if (context->network() == network &&
context->peer_address() == peer_address) {
connection()->CancelPathValidation();
}
if (network != handles::kInvalidNetworkHandle) {
// Probing failure can be ignored.
DVLOG(1) << "Connectivity probing failed on <network: " << network
<< ", peer_address: " << peer_address.ToString() << ">.";
DVLOG_IF(1, network == default_network_ &&
GetCurrentNetwork() != default_network_)
<< "Client probing failed on the default network, still using "
"non-default network.";
}
}
void QuicChromiumClientSession::OnNetworkConnected(
handles::NetworkHandle network) {
migration_info_.event_count.network_connected_num =
base::CheckAdd(migration_info_.event_count.network_connected_num, 1)
.ValueOrDefault(std::numeric_limits<uint32_t>::max());
if (connection()->IsPathDegrading()) {
base::TimeDelta duration =
tick_clock_->NowTicks() - most_recent_path_degrading_timestamp_;
UMA_HISTOGRAM_CUSTOM_TIMES("Net.QuicNetworkDegradingDurationTillConnected",
duration, base::Milliseconds(1),
base::Minutes(10), 50);
}
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_SESSION_NETWORK_CONNECTED, "connected_network",
network);
if (!migrate_session_on_network_change_v2_) {
return;
}
// If there was no migration waiting for new network and the path is not
// degrading, ignore this signal.
if (!wait_for_new_network_ && !connection()->IsPathDegrading()) {
return;
}
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_ON_NETWORK_CONNECTED,
"connected_network", network);
if (connection()->IsPathDegrading()) {
current_migration_cause_ = NEW_NETWORK_CONNECTED_POST_PATH_DEGRADING;
}
if (wait_for_new_network_) {
wait_for_new_network_ = false;
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_SUCCESS_WAITING_FOR_NETWORK,
"network", network);
if (current_migration_cause_ == ON_WRITE_ERROR) {
current_migrations_to_non_default_network_on_write_error_++;
}
// |wait_for_new_network_| is true, there was no working network previously.
// |network| is now the only possible candidate, migrate immediately.
MigrateNetworkImmediately(network);
} else {
// The connection is path degrading.
DCHECK(connection()->IsPathDegrading());
MaybeMigrateToAlternateNetworkOnPathDegrading();
}
}
void QuicChromiumClientSession::OnNetworkDisconnectedV2(
handles::NetworkHandle disconnected_network) {
migration_info_.event_count.network_disconnected_num =
base::CheckAdd(migration_info_.event_count.network_disconnected_num, 1)
.ValueOrDefault(std::numeric_limits<uint32_t>::max());
LogMetricsOnNetworkDisconnected();
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_SESSION_NETWORK_DISCONNECTED,
"disconnected_network", disconnected_network);
if (!migrate_session_on_network_change_v2_) {
return;
}
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_ON_NETWORK_DISCONNECTED,
"disconnected_network", disconnected_network);
// Stop probing the disconnected network if there is one.
auto* context = static_cast<QuicChromiumPathValidationContext*>(
connection()->GetPathValidationContext());
if (context && context->network() == disconnected_network &&
context->peer_address() == peer_address()) {
connection()->CancelPathValidation();
}
if (disconnected_network == default_network_) {
DVLOG(1) << "Default network: " << default_network_ << " is disconnected.";
default_network_ = handles::kInvalidNetworkHandle;
current_migrations_to_non_default_network_on_write_error_ = 0;
}
// Ignore the signal if the current active network is not affected.
if (GetCurrentNetwork() != disconnected_network) {
DVLOG(1) << "Client's current default network is not affected by the "
<< "disconnected one.";
return;
}
if (base::FeatureList::IsEnabled(
features::kQuicMigrationIgnoreDisconnectSignalDuringProbing) &&
current_migration_cause_ == ON_NETWORK_MADE_DEFAULT) {
DVLOG(1) << "Ignoring a network disconnection signal because a "
"connection migration is happening on the default network.";
return;
}
current_migration_cause_ = ON_NETWORK_DISCONNECTED;
LogHandshakeStatusOnMigrationSignal();
if (!OneRttKeysAvailable()) {
// Close the connection if handshake is not confirmed. Migration before
// handshake is not allowed.
CloseSessionOnErrorLater(
ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_HANDSHAKE_UNCONFIRMED,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
// Attempt to find alternative network.
handles::NetworkHandle new_network =
session_pool_->FindAlternateNetwork(disconnected_network);
if (new_network == handles::kInvalidNetworkHandle) {
OnNoNewNetwork();
return;
}
// Current network is being disconnected, migrate immediately to the
// alternative network.
MigrateNetworkImmediately(new_network);
}
void QuicChromiumClientSession::OnNetworkMadeDefault(
handles::NetworkHandle new_network) {
migration_info_.event_count.default_network_changed_num++;
migration_info_.event_count.default_network_changed_num =
base::CheckAdd(migration_info_.event_count.default_network_changed_num, 1)
.ValueOrDefault(std::numeric_limits<uint32_t>::max());
LogMetricsOnNetworkMadeDefault();
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_SESSION_NETWORK_MADE_DEFAULT, "new_default_network",
new_network);
if (!migrate_session_on_network_change_v2_) {
return;
}
DCHECK_NE(handles::kInvalidNetworkHandle, new_network);
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_ON_NETWORK_MADE_DEFAULT,
"new_default_network", new_network);
default_network_ = new_network;
DVLOG(1) << "Network: " << new_network
<< " becomes default, old default: " << default_network_;
current_migration_cause_ = ON_NETWORK_MADE_DEFAULT;
current_migrations_to_non_default_network_on_write_error_ = 0;
current_migrations_to_non_default_network_on_path_degrading_ = 0;
// Simply cancel the timer to migrate back to the default network if session
// is already on the default network.
if (GetCurrentNetwork() == new_network) {
CancelMigrateBackToDefaultNetworkTimer();
HistogramAndLogMigrationFailure(MIGRATION_STATUS_ALREADY_MIGRATED,
connection_id(),
"Already migrated on the new network");
return;
}
LogHandshakeStatusOnMigrationSignal();
// Stay on the current network. Try to migrate back to default network
// without any delay, which will start probing the new default network and
// migrate to the new network immediately on success.
StartMigrateBackToDefaultNetworkTimer(base::TimeDelta());
}
void QuicChromiumClientSession::MigrateNetworkImmediately(
handles::NetworkHandle network) {
// There is no choice but to migrate to |network|. If any error encountered,
// close the session. When migration succeeds:
// - if no longer on the default network, start timer to migrate back;
// - otherwise, it's brought to default network, cancel the running timer to
// migrate back.
DCHECK(migrate_session_on_network_change_v2_);
if (!migrate_idle_session_ && !HasActiveRequestStreams()) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_NO_MIGRATABLE_STREAMS,
connection_id(), "No active streams");
CloseSessionOnErrorLater(
ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_NO_MIGRATABLE_STREAMS,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
if (migrate_idle_session_ && CheckIdleTimeExceedsIdleMigrationPeriod()) {
return;
}
// Do not migrate if connection migration is disabled.
if (config()->DisableConnectionMigration()) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_DISABLED_BY_CONFIG,
connection_id(),
"Migration disabled by config");
CloseSessionOnErrorLater(ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_DISABLED_BY_CONFIG,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return;
}
if (network == GetCurrentNetwork()) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_ALREADY_MIGRATED,
connection_id(),
"Already bound to new network");
return;
}
// Cancel probing on |network| if there is any.
auto* context = static_cast<QuicChromiumPathValidationContext*>(
connection()->GetPathValidationContext());
if (context && context->network() == network &&
context->peer_address() == peer_address()) {
connection()->CancelPathValidation();
}
pending_migrate_network_immediately_ = true;
Migrate(network, ToIPEndPoint(connection()->peer_address()),
/*close_session_on_error=*/true,
base::BindOnce(
&QuicChromiumClientSession::FinishMigrateNetworkImmediately,
weak_factory_.GetWeakPtr(), network));
}
void QuicChromiumClientSession::FinishMigrateNetworkImmediately(
handles::NetworkHandle network,
MigrationResult result) {
pending_migrate_network_immediately_ = false;
if (result == MigrationResult::FAILURE) {
return;
}
if (network == default_network_) {
CancelMigrateBackToDefaultNetworkTimer();
return;
}
// TODO(zhongyi): reconsider this, maybe we just want to hear back
// We are forced to migrate to |network|, probably |default_network_| is
// not working, start to migrate back to default network after 1 secs.
StartMigrateBackToDefaultNetworkTimer(
base::Seconds(kMinRetryTimeForDefaultNetworkSecs));
}
void QuicChromiumClientSession::OnWriteError(int error_code) {
DCHECK_NE(ERR_IO_PENDING, error_code);
DCHECK_GT(0, error_code);
connection()->OnWriteError(error_code);
}
void QuicChromiumClientSession::OnWriteUnblocked() {
DCHECK(!connection()->writer()->IsWriteBlocked());
// A new packet will be written after migration completes, unignore read
// errors.
if (ignore_read_error_) {
ignore_read_error_ = false;
}
if (packet_) {
DCHECK(send_packet_after_migration_);
send_packet_after_migration_ = false;
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->WritePacketToSocket(std::move(packet_));
return;
}
// Unblock the connection, which may send queued packets.
connection()->OnCanWrite();
if (send_packet_after_migration_) {
send_packet_after_migration_ = false;
if (!connection()->writer()->IsWriteBlocked()) {
connection()->SendPing();
}
}
}
void QuicChromiumClientSession::OnPathDegrading() {
migration_info_.event_count.path_degrading_num =
base::CheckAdd(migration_info_.event_count.path_degrading_num, 1)
.ValueOrDefault(std::numeric_limits<uint32_t>::max());
if (most_recent_path_degrading_timestamp_ == base::TimeTicks()) {
most_recent_path_degrading_timestamp_ = tick_clock_->NowTicks();
}
handles::NetworkHandle current_network = GetCurrentNetwork();
for (auto& observer : connectivity_observer_list_) {
observer.OnSessionPathDegrading(this, current_network);
}
// Proxied sessions should not attempt migration when the path degrades, as
// there is nowhere for such a session to migrate to. If the degradation is
// due to degradation of the underlying session, then that session may attempt
// migration.
if (!session_key_.proxy_chain().is_direct()) {
return;
}
if (!session_pool_ || connection()->multi_port_stats()) {
return;
}
if (allow_port_migration_ && !migrate_session_early_v2_) {
MaybeMigrateToDifferentPortOnPathDegrading();
return;
}
MaybeMigrateToAlternateNetworkOnPathDegrading();
}
void QuicChromiumClientSession::OnForwardProgressMadeAfterPathDegrading() {
handles::NetworkHandle current_network = GetCurrentNetwork();
for (auto& observer : connectivity_observer_list_) {
observer.OnSessionResumedPostPathDegrading(this, current_network);
}
}
void QuicChromiumClientSession::SendRetireConnectionId(
uint64_t sequence_number) {
RegisterQuicConnectionClosePayload();
quic::QuicSpdySession::SendRetireConnectionId(sequence_number);
}
void QuicChromiumClientSession::OnKeyUpdate(quic::KeyUpdateReason reason) {
net_log_.AddEventWithStringParams(NetLogEventType::QUIC_SESSION_KEY_UPDATE,
"reason",
quic::KeyUpdateReasonString(reason));
base::UmaHistogramEnumeration("Net.QuicSession.KeyUpdate.Reason", reason);
last_key_update_reason_ = reason;
}
void QuicChromiumClientSession::OnProofValid(
const quic::QuicCryptoClientConfig::CachedState& cached) {
DCHECK(cached.proof_valid());
if (!server_info_) {
return;
}
QuicServerInfo::State* state = server_info_->mutable_state();
state->server_config = cached.server_config();
state->source_address_token = cached.source_address_token();
state->cert_sct = cached.cert_sct();
state->chlo_hash = cached.chlo_hash();
state->server_config_sig = cached.signature();
state->certs = cached.certs();
server_info_->Persist();
}
void QuicChromiumClientSession::OnProofVerifyDetailsAvailable(
const quic::ProofVerifyDetails& verify_details) {
const ProofVerifyDetailsChromium* verify_details_chromium =
reinterpret_cast<const ProofVerifyDetailsChromium*>(&verify_details);
cert_verify_result_ = std::make_unique<CertVerifyResult>(
verify_details_chromium->cert_verify_result);
logger_->OnCertificateVerified(*cert_verify_result_);
pkp_bypassed_ = verify_details_chromium->pkp_bypassed;
is_fatal_cert_error_ = verify_details_chromium->is_fatal_cert_error;
}
void QuicChromiumClientSession::StartReading() {
for (auto& packet_reader : packet_readers_) {
packet_reader->StartReading();
}
}
void QuicChromiumClientSession::CloseSessionOnError(
int net_error,
quic::QuicErrorCode quic_error,
quic::ConnectionCloseBehavior behavior) {
base::UmaHistogramSparse("Net.QuicSession.CloseSessionOnError", -net_error);
if (!callback_.is_null()) {
std::move(callback_).Run(net_error);
}
NotifyAllStreamsOfError(net_error);
net_log_.AddEventWithIntParams(NetLogEventType::QUIC_SESSION_CLOSE_ON_ERROR,
"net_error", net_error);
if (connection()->connected()) {
connection()->CloseConnection(quic_error, "net error", behavior);
}
DCHECK(!connection()->connected());
CloseAllHandles(net_error);
NotifyFactoryOfSessionClosed();
}
void QuicChromiumClientSession::CloseSessionOnErrorLater(
int net_error,
quic::QuicErrorCode quic_error,
quic::ConnectionCloseBehavior behavior) {
base::UmaHistogramSparse("Net.QuicSession.CloseSessionOnError", -net_error);
if (!callback_.is_null()) {
std::move(callback_).Run(net_error);
}
NotifyAllStreamsOfError(net_error);
net_log_.AddEventWithIntParams(NetLogEventType::QUIC_SESSION_CLOSE_ON_ERROR,
"net_error", net_error);
if (connection()->connected()) {
connection()->CloseConnection(quic_error, "net error", behavior);
}
DCHECK(!connection()->connected());
CloseAllHandles(net_error);
NotifyFactoryOfSessionClosedLater();
}
void QuicChromiumClientSession::NotifyAllStreamsOfError(int net_error) {
PerformActionOnActiveStreams([net_error](quic::QuicStream* stream) {
static_cast<QuicChromiumClientStream*>(stream)->OnError(net_error);
return true;
});
}
void QuicChromiumClientSession::CloseAllHandles(int net_error) {
while (!handles_.empty()) {
Handle* handle = *handles_.begin();
handles_.erase(handle);
handle->OnSessionClosed(
connection()->version(), net_error, error(), source_,
port_migration_detected_, quic_connection_migration_attempted_,
quic_connection_migration_successful_, GetConnectTiming(),
WasConnectionEverUsed(), migration_info_);
}
}
void QuicChromiumClientSession::CancelAllRequests(int net_error) {
UMA_HISTOGRAM_COUNTS_1000("Net.QuicSession.AbortedPendingStreamRequests",
stream_requests_.size());
while (!stream_requests_.empty()) {
StreamRequest* request = stream_requests_.front();
stream_requests_.pop_front();
request->OnRequestCompleteFailure(net_error);
}
}
void QuicChromiumClientSession::NotifyRequestsOfConfirmation(int net_error) {
// Post tasks to avoid reentrancy.
for (auto& callback : waiting_for_confirmation_callbacks_) {
task_runner_->PostTask(FROM_HERE,
base::BindOnce(std::move(callback), net_error));
}
waiting_for_confirmation_callbacks_.clear();
}
void QuicChromiumClientSession::MaybeMigrateToDifferentPortOnPathDegrading() {
DCHECK(allow_port_migration_ && !migrate_session_early_v2_);
current_migration_cause_ = CHANGE_PORT_ON_PATH_DEGRADING;
// Migration before handshake confirmed is not allowed.
if (!connection()->IsHandshakeConfirmed()) {
HistogramAndLogMigrationFailure(
MIGRATION_STATUS_PATH_DEGRADING_BEFORE_HANDSHAKE_CONFIRMED,
connection_id(), "Path degrading before handshake confirmed");
return;
}
if (config()->DisableConnectionMigration()) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_DISABLED_BY_CONFIG,
connection_id(),
"Migration disabled by config");
return;
}
net_log_.BeginEvent(NetLogEventType::QUIC_PORT_MIGRATION_TRIGGERED);
if (!session_pool_) {
return;
}
// Probe a different port, session will migrate to the probed port on success.
// DoNothingAs is passed in for `probing_callback` as the return value of
// StartProbing is not needed.
StartProbing(base::DoNothingAs<void(ProbingResult)>(), default_network_,
peer_address());
net_log_.EndEvent(NetLogEventType::QUIC_PORT_MIGRATION_TRIGGERED);
}
void QuicChromiumClientSession::
MaybeMigrateToAlternateNetworkOnPathDegrading() {
net_log_.AddEvent(
NetLogEventType::QUIC_CONNECTION_MIGRATION_ON_PATH_DEGRADING);
current_migration_cause_ = CHANGE_NETWORK_ON_PATH_DEGRADING;
if (!migrate_session_early_v2_) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_PATH_DEGRADING_NOT_ENABLED,
connection_id(),
"Migration on path degrading not enabled");
return;
}
if (GetCurrentNetwork() == default_network_ &&
current_migrations_to_non_default_network_on_path_degrading_ >=
max_migrations_to_non_default_network_on_path_degrading_) {
HistogramAndLogMigrationFailure(
MIGRATION_STATUS_ON_PATH_DEGRADING_DISABLED, connection_id(),
"Exceeds maximum number of migrations on path degrading");
return;
}
handles::NetworkHandle alternate_network =
session_pool_->FindAlternateNetwork(GetCurrentNetwork());
if (alternate_network == handles::kInvalidNetworkHandle) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_NO_ALTERNATE_NETWORK,
connection_id(),
"No alternative network on path degrading");
return;
}
LogHandshakeStatusOnMigrationSignal();
if (!connection()->IsHandshakeConfirmed()) {
HistogramAndLogMigrationFailure(
MIGRATION_STATUS_PATH_DEGRADING_BEFORE_HANDSHAKE_CONFIRMED,
connection_id(), "Path degrading before handshake confirmed");
return;
}
net_log_.BeginEventWithStringParams(
NetLogEventType::QUIC_CONNECTION_MIGRATION_TRIGGERED, "trigger",
"PathDegrading");
// Probe the alternative network, session will migrate to the probed
// network and decide whether it wants to migrate back to the default
// network on success. DoNothingAs is passed in for `probing_callback` as the
// return value of MaybeStartProbing is not needed.
MaybeStartProbing(base::DoNothingAs<void(ProbingResult)>(), alternate_network,
peer_address());
net_log_.EndEvent(NetLogEventType::QUIC_CONNECTION_MIGRATION_TRIGGERED);
}
void QuicChromiumClientSession::MaybeStartProbing(
ProbingCallback probing_callback,
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address) {
if (!session_pool_) {
task_runner_->PostTask(
FROM_HERE, base::BindOnce(std::move(probing_callback),
ProbingResult::DISABLED_WITH_IDLE_SESSION));
return;
}
CHECK_NE(handles::kInvalidNetworkHandle, network);
if (!migrate_idle_session_ && !HasActiveRequestStreams()) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_NO_MIGRATABLE_STREAMS,
connection_id(), "No active streams");
CloseSessionOnErrorLater(
ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_NO_MIGRATABLE_STREAMS,
quic::ConnectionCloseBehavior::SEND_CONNECTION_CLOSE_PACKET);
task_runner_->PostTask(
FROM_HERE, base::BindOnce(std::move(probing_callback),
ProbingResult::DISABLED_WITH_IDLE_SESSION));
return;
}
if (migrate_idle_session_ && CheckIdleTimeExceedsIdleMigrationPeriod()) {
task_runner_->PostTask(
FROM_HERE, base::BindOnce(std::move(probing_callback),
ProbingResult::DISABLED_WITH_IDLE_SESSION));
return;
}
if (config()->DisableConnectionMigration()) {
DVLOG(1) << "Client disables probing network with connection migration "
<< "disabled by config";
HistogramAndLogMigrationFailure(MIGRATION_STATUS_DISABLED_BY_CONFIG,
connection_id(),
"Migration disabled by config");
task_runner_->PostTask(FROM_HERE,
base::BindOnce(std::move(probing_callback),
ProbingResult::DISABLED_BY_CONFIG));
return;
}
StartProbing(std::move(probing_callback), network, peer_address);
}
void QuicChromiumClientSession::CreateContextForMultiPortPath(
std::unique_ptr<quic::MultiPortPathContextObserver> context_observer) {
// Create and configure socket on default network
std::unique_ptr<DatagramClientSocket> probing_socket =
session_pool_->CreateSocket(net_log_.net_log(), net_log_.source());
if (base::FeatureList::IsEnabled(net::features::kAsyncMultiPortPath)) {
DatagramClientSocket* probing_socket_ptr = probing_socket.get();
CompletionOnceCallback configure_callback = base::BindOnce(
&QuicChromiumClientSession::FinishCreateContextForMultiPortPath,
weak_factory_.GetWeakPtr(), std::move(context_observer),
std::move(probing_socket));
session_pool_->ConnectAndConfigureSocket(
std::move(configure_callback), probing_socket_ptr,
ToIPEndPoint(peer_address()), default_network_,
session_key_.socket_tag());
return;
}
if (session_pool_->ConfigureSocket(
probing_socket.get(), ToIPEndPoint(peer_address()), default_network_,
session_key_.socket_tag()) != OK) {
return;
}
FinishCreateContextForMultiPortPath(std::move(context_observer),
std::move(probing_socket), OK);
}
void QuicChromiumClientSession::FinishCreateContextForMultiPortPath(
std::unique_ptr<quic::MultiPortPathContextObserver> context_observer,
std::unique_ptr<DatagramClientSocket> probing_socket,
int rv) {
if (rv != OK) {
context_observer->OnMultiPortPathContextAvailable(nullptr);
return;
}
// Create new packet writer and reader on the probing socket.
auto probing_writer = std::make_unique<QuicChromiumPacketWriter>(
probing_socket.get(), task_runner_);
auto probing_reader = std::make_unique<QuicChromiumPacketReader>(
std::move(probing_socket), clock_, this, yield_after_packets_,
yield_after_duration_, net_log_);
probing_reader->StartReading();
path_validation_writer_delegate_.set_network(default_network_);
path_validation_writer_delegate_.set_peer_address(peer_address());
probing_writer->set_delegate(&path_validation_writer_delegate_);
IPEndPoint local_address;
probing_reader->socket()->GetLocalAddress(&local_address);
context_observer->OnMultiPortPathContextAvailable(
std::make_unique<QuicChromiumPathValidationContext>(
ToQuicSocketAddress(local_address), peer_address(), default_network_,
std::move(probing_writer), std::move(probing_reader)));
}
void QuicChromiumClientSession::MigrateToMultiPortPath(
std::unique_ptr<quic::QuicPathValidationContext> context) {
DCHECK_NE(nullptr, context);
auto* chrome_context =
static_cast<QuicChromiumPathValidationContext*>(context.get());
std::unique_ptr<QuicChromiumPacketWriter> owned_writer =
chrome_context->ReleaseWriter();
// Remove |this| as the old packet writer's delegate. Write error on old
// writers will be ignored.
// Set |this| to listen on socket write events on the packet writer
// that was used for probing.
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_delegate(nullptr);
owned_writer->set_delegate(this);
if (!MigrateToSocket(
chrome_context->self_address(), chrome_context->peer_address(),
chrome_context->ReleaseReader(), std::move(owned_writer))) {
LogMigrateToSocketStatus(false);
return;
}
LogMigrateToSocketStatus(true);
num_migrations_++;
}
void QuicChromiumClientSession::StartProbing(
ProbingCallback probing_callback,
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address) {
// Check if probing manager is probing the same path.
auto* existing_context = static_cast<QuicChromiumPathValidationContext*>(
connection()->GetPathValidationContext());
if (existing_context && existing_context->network() == network &&
existing_context->peer_address() == peer_address) {
task_runner_->PostTask(FROM_HERE,
base::BindOnce(std::move(probing_callback),
ProbingResult::DISABLED_BY_CONFIG));
return;
}
// Create and configure socket on |network|.
std::unique_ptr<DatagramClientSocket> probing_socket =
session_pool_->CreateSocket(net_log_.net_log(), net_log_.source());
DatagramClientSocket* probing_socket_ptr = probing_socket.get();
CompletionOnceCallback configure_callback =
base::BindOnce(&QuicChromiumClientSession::FinishStartProbing,
weak_factory_.GetWeakPtr(), std::move(probing_callback),
std::move(probing_socket), network, peer_address);
if (current_migration_cause_ != UNKNOWN_CAUSE &&
!MidMigrationCallbackForTesting().is_null()) {
std::move(MidMigrationCallbackForTesting()).Run(); // IN-TEST
}
session_pool_->ConnectAndConfigureSocket(
std::move(configure_callback), probing_socket_ptr,
ToIPEndPoint(peer_address), network, session_key_.socket_tag());
return;
}
void QuicChromiumClientSession::FinishStartProbing(
ProbingCallback probing_callback,
std::unique_ptr<DatagramClientSocket> probing_socket,
handles::NetworkHandle network,
const quic::QuicSocketAddress& peer_address,
int rv) {
if (rv != OK) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_INTERNAL_ERROR,
connection_id(),
"Socket configuration failed");
task_runner_->PostTask(FROM_HERE,
base::BindOnce(std::move(probing_callback),
ProbingResult::INTERNAL_ERROR));
return;
}
// Create new packet writer and reader on the probing socket.
auto probing_writer = std::make_unique<QuicChromiumPacketWriter>(
probing_socket.get(), task_runner_);
auto probing_reader = std::make_unique<QuicChromiumPacketReader>(
std::move(probing_socket), clock_, this, yield_after_packets_,
yield_after_duration_, net_log_);
probing_reader->StartReading();
path_validation_writer_delegate_.set_network(network);
path_validation_writer_delegate_.set_peer_address(peer_address);
probing_writer->set_delegate(&path_validation_writer_delegate_);
IPEndPoint local_address;
probing_reader->socket()->GetLocalAddress(&local_address);
auto context = std::make_unique<QuicChromiumPathValidationContext>(
ToQuicSocketAddress(local_address), peer_address, network,
std::move(probing_writer), std::move(probing_reader));
switch (current_migration_cause_) {
case CHANGE_PORT_ON_PATH_DEGRADING:
ValidatePath(
std::move(context),
std::make_unique<PortMigrationValidationResultDelegate>(this),
quic::PathValidationReason::kPortMigration);
break;
case ON_SERVER_PREFERRED_ADDRESS_AVAILABLE:
ValidatePath(
std::move(context),
std::make_unique<ServerPreferredAddressValidationResultDelegate>(
this),
quic::PathValidationReason::kServerPreferredAddressMigration);
break;
default:
ValidatePath(
std::move(context),
std::make_unique<ConnectionMigrationValidationResultDelegate>(this),
quic::PathValidationReason::kConnectionMigration);
break;
}
task_runner_->PostTask(FROM_HERE, base::BindOnce(std::move(probing_callback),
ProbingResult::PENDING));
}
void QuicChromiumClientSession::StartMigrateBackToDefaultNetworkTimer(
base::TimeDelta delay) {
if (current_migration_cause_ != ON_NETWORK_MADE_DEFAULT) {
current_migration_cause_ = ON_MIGRATE_BACK_TO_DEFAULT_NETWORK;
}
CancelMigrateBackToDefaultNetworkTimer();
// Post a task to try migrate back to default network after |delay|.
migrate_back_to_default_timer_.Start(
FROM_HERE, delay,
base::BindOnce(
&QuicChromiumClientSession::MaybeRetryMigrateBackToDefaultNetwork,
weak_factory_.GetWeakPtr()));
}
void QuicChromiumClientSession::CancelMigrateBackToDefaultNetworkTimer() {
retry_migrate_back_count_ = 0;
migrate_back_to_default_timer_.Stop();
}
void QuicChromiumClientSession::TryMigrateBackToDefaultNetwork(
base::TimeDelta timeout) {
if (default_network_ == handles::kInvalidNetworkHandle) {
DVLOG(1) << "Default network is not connected";
return;
}
net_log_.AddEventWithInt64Params(
NetLogEventType::QUIC_CONNECTION_MIGRATION_ON_MIGRATE_BACK, "retry_count",
retry_migrate_back_count_);
// Start probe default network immediately, if manager is probing
// the same network, this will be a no-op. Otherwise, previous probe
// will be cancelled and manager starts to probe |default_network_|
// immediately.
MaybeStartProbing(
base::BindOnce(
&QuicChromiumClientSession::FinishTryMigrateBackToDefaultNetwork,
weak_factory_.GetWeakPtr(), timeout),
default_network_, peer_address());
}
void QuicChromiumClientSession::FinishTryMigrateBackToDefaultNetwork(
base::TimeDelta timeout,
ProbingResult result) {
if (result != ProbingResult::PENDING) {
// Session is not allowed to migrate, mark session as going away, cancel
// migrate back to default timer.
NotifyFactoryOfSessionGoingAway();
CancelMigrateBackToDefaultNetworkTimer();
return;
}
retry_migrate_back_count_++;
migrate_back_to_default_timer_.Start(
FROM_HERE, timeout,
base::BindOnce(
&QuicChromiumClientSession::MaybeRetryMigrateBackToDefaultNetwork,
weak_factory_.GetWeakPtr()));
}
void QuicChromiumClientSession::MaybeRetryMigrateBackToDefaultNetwork() {
base::TimeDelta retry_migrate_back_timeout =
base::Seconds(UINT64_C(1) << retry_migrate_back_count_);
if (pending_migrate_session_on_write_error_) {
StartMigrateBackToDefaultNetworkTimer(base::TimeDelta());
return;
}
if (default_network_ == GetCurrentNetwork()) {
// If session has been back on the default already by other direct
// migration attempt, cancel migrate back now.
CancelMigrateBackToDefaultNetworkTimer();
return;
}
if (retry_migrate_back_timeout > max_time_on_non_default_network_) {
// Mark session as going away to accept no more streams.
NotifyFactoryOfSessionGoingAway();
return;
}
TryMigrateBackToDefaultNetwork(retry_migrate_back_timeout);
}
bool QuicChromiumClientSession::CheckIdleTimeExceedsIdleMigrationPeriod() {
if (!migrate_idle_session_) {
return false;
}
if (HasActiveRequestStreams()) {
return false;
}
// There are no active/drainning streams, check the last stream's finish time.
if (tick_clock_->NowTicks() - most_recent_stream_close_time_ <
idle_migration_period_) {
// Still within the idle migration period.
return false;
}
HistogramAndLogMigrationFailure(MIGRATION_STATUS_IDLE_MIGRATION_TIMEOUT,
connection_id(),
"Ilde migration period exceeded");
CloseSessionOnErrorLater(ERR_NETWORK_CHANGED, quic::QUIC_NETWORK_IDLE_TIMEOUT,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return true;
}
void QuicChromiumClientSession::ResetNonMigratableStreams() {
// TODO(zhongyi): may close non-migratable draining streams as well to avoid
// sending additional data on alternate networks.
PerformActionOnActiveStreams([](quic::QuicStream* stream) {
QuicChromiumClientStream* chrome_stream =
static_cast<QuicChromiumClientStream*>(stream);
if (!chrome_stream->can_migrate_to_cellular_network()) {
// Close the stream in both direction by resetting the stream.
// TODO(zhongyi): use a different error code to reset streams for
// connection migration.
chrome_stream->Reset(quic::QUIC_STREAM_CANCELLED);
}
return true;
});
}
void QuicChromiumClientSession::LogMetricsOnNetworkDisconnected() {
if (most_recent_path_degrading_timestamp_ != base::TimeTicks()) {
most_recent_network_disconnected_timestamp_ = tick_clock_->NowTicks();
base::TimeDelta degrading_duration =
most_recent_network_disconnected_timestamp_ -
most_recent_path_degrading_timestamp_;
UMA_HISTOGRAM_CUSTOM_TIMES(
"Net.QuicNetworkDegradingDurationTillDisconnected", degrading_duration,
base::Milliseconds(1), base::Minutes(10), 100);
}
if (most_recent_write_error_timestamp_ != base::TimeTicks()) {
base::TimeDelta write_error_to_disconnection_gap =
most_recent_network_disconnected_timestamp_ -
most_recent_write_error_timestamp_;
UMA_HISTOGRAM_CUSTOM_TIMES(
"Net.QuicNetworkGapBetweenWriteErrorAndDisconnection",
write_error_to_disconnection_gap, base::Milliseconds(1),
base::Minutes(10), 100);
base::UmaHistogramSparse("Net.QuicSession.WriteError.NetworkDisconnected",
-most_recent_write_error_);
most_recent_write_error_ = 0;
most_recent_write_error_timestamp_ = base::TimeTicks();
}
}
void QuicChromiumClientSession::LogMetricsOnNetworkMadeDefault() {
if (most_recent_path_degrading_timestamp_ != base::TimeTicks()) {
if (most_recent_network_disconnected_timestamp_ != base::TimeTicks()) {
// NetworkDiscconected happens before NetworkMadeDefault, the platform
// is dropping WiFi.
base::TimeTicks now = tick_clock_->NowTicks();
base::TimeDelta disconnection_duration =
now - most_recent_network_disconnected_timestamp_;
base::TimeDelta degrading_duration =
now - most_recent_path_degrading_timestamp_;
UMA_HISTOGRAM_CUSTOM_TIMES("Net.QuicNetworkDisconnectionDuration",
disconnection_duration, base::Milliseconds(1),
base::Minutes(10), 100);
UMA_HISTOGRAM_CUSTOM_TIMES(
"Net.QuicNetworkDegradingDurationTillNewNetworkMadeDefault",
degrading_duration, base::Milliseconds(1), base::Minutes(10), 100);
most_recent_network_disconnected_timestamp_ = base::TimeTicks();
}
most_recent_path_degrading_timestamp_ = base::TimeTicks();
}
}
void QuicChromiumClientSession::LogMigrationResultToHistogram(
QuicConnectionMigrationStatus status) {
if (current_migration_cause_ == CHANGE_PORT_ON_PATH_DEGRADING) {
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.PortMigration", status,
MIGRATION_STATUS_MAX);
current_migration_cause_ = UNKNOWN_CAUSE;
return;
}
if (current_migration_cause_ == ON_SERVER_PREFERRED_ADDRESS_AVAILABLE) {
UMA_HISTOGRAM_ENUMERATION(
"Net.QuicSession.OnServerPreferredAddressAvailable", status,
MIGRATION_STATUS_MAX);
current_migration_cause_ = UNKNOWN_CAUSE;
return;
}
UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ConnectionMigration", status,
MIGRATION_STATUS_MAX);
// Log the connection migraiton result to different histograms based on the
// cause of the connection migration.
std::string histogram_name = "Net.QuicSession.ConnectionMigration." +
MigrationCauseToString(current_migration_cause_);
base::UmaHistogramEnumeration(histogram_name, status, MIGRATION_STATUS_MAX);
current_migration_cause_ = UNKNOWN_CAUSE;
}
void QuicChromiumClientSession::LogHandshakeStatusOnMigrationSignal() const {
if (current_migration_cause_ == CHANGE_PORT_ON_PATH_DEGRADING) {
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.HandshakeStatusOnPortMigration",
OneRttKeysAvailable());
return;
}
if (current_migration_cause_ == ON_SERVER_PREFERRED_ADDRESS_AVAILABLE) {
UMA_HISTOGRAM_BOOLEAN(
"Net.QuicSession.HandshakeStatusOnMigratingToServerPreferredAddress",
OneRttKeysAvailable());
return;
}
UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.HandshakeStatusOnConnectionMigration",
OneRttKeysAvailable());
const std::string histogram_name =
"Net.QuicSession.HandshakeStatusOnConnectionMigration." +
MigrationCauseToString(current_migration_cause_);
STATIC_HISTOGRAM_POINTER_GROUP(
histogram_name, current_migration_cause_, MIGRATION_CAUSE_MAX,
AddBoolean(OneRttKeysAvailable()),
base::BooleanHistogram::FactoryGet(
histogram_name, base::HistogramBase::kUmaTargetedHistogramFlag));
}
void QuicChromiumClientSession::HistogramAndLogMigrationFailure(
QuicConnectionMigrationStatus status,
quic::QuicConnectionId connection_id,
const char* reason) {
NetLogEventType event_type =
NetLogEventType::QUIC_CONNECTION_MIGRATION_FAILURE;
if (current_migration_cause_ == CHANGE_PORT_ON_PATH_DEGRADING) {
event_type = NetLogEventType::QUIC_PORT_MIGRATION_FAILURE;
} else if (current_migration_cause_ ==
ON_SERVER_PREFERRED_ADDRESS_AVAILABLE) {
event_type =
NetLogEventType::QUIC_FAILED_TO_VALIDATE_SERVER_PREFERRED_ADDRESS;
}
net_log_.AddEvent(event_type, [&] {
return NetLogQuicMigrationFailureParams(connection_id, reason);
});
// |current_migration_cause_| will be reset afterwards.
LogMigrationResultToHistogram(status);
}
void QuicChromiumClientSession::HistogramAndLogMigrationSuccess(
quic::QuicConnectionId connection_id) {
NetLogEventType event_type =
NetLogEventType::QUIC_CONNECTION_MIGRATION_SUCCESS;
if (current_migration_cause_ == CHANGE_PORT_ON_PATH_DEGRADING) {
event_type = NetLogEventType::QUIC_PORT_MIGRATION_SUCCESS;
} else if (current_migration_cause_ ==
ON_SERVER_PREFERRED_ADDRESS_AVAILABLE) {
event_type =
NetLogEventType::QUIC_SUCCESSFULLY_MIGRATED_TO_SERVER_PREFERRED_ADDRESS;
}
net_log_.AddEvent(event_type, [&] {
return NetLogQuicMigrationSuccessParams(connection_id);
});
// |current_migration_cause_| will be reset afterwards.
LogMigrationResultToHistogram(MIGRATION_STATUS_SUCCESS);
}
base::Value::Dict QuicChromiumClientSession::GetInfoAsValue(
const std::set<HostPortPair>& aliases) {
base::Value::Dict dict;
dict.Set("version", ParsedQuicVersionToString(connection()->version()));
dict.Set("open_streams", static_cast<int>(GetNumActiveStreams()));
base::Value::List stream_list;
auto* stream_list_ptr = &stream_list;
PerformActionOnActiveStreams([stream_list_ptr](quic::QuicStream* stream) {
stream_list_ptr->Append(base::NumberToString(stream->id()));
return true;
});
dict.Set("active_streams", std::move(stream_list));
dict.Set("total_streams", static_cast<int>(num_total_streams_));
dict.Set("peer_address", peer_address().ToString());
dict.Set("network_anonymization_key",
session_key_.network_anonymization_key().ToDebugString());
dict.Set("connection_id", connection_id().ToString());
if (!connection()->client_connection_id().IsEmpty()) {
dict.Set("client_connection_id",
connection()->client_connection_id().ToString());
}
dict.Set("connected", connection()->connected());
const quic::QuicConnectionStats& stats = connection()->GetStats();
dict.Set("packets_sent", static_cast<int>(stats.packets_sent));
dict.Set("packets_received", static_cast<int>(stats.packets_received));
dict.Set("packets_lost", static_cast<int>(stats.packets_lost));
SSLInfo ssl_info;
base::Value::List alias_list;
for (const auto& alias : aliases) {
alias_list.Append(alias.ToString());
}
dict.Set("aliases", std::move(alias_list));
return dict;
}
bool QuicChromiumClientSession::gquic_zero_rtt_disabled() const {
if (!session_pool_) {
return false;
}
return session_pool_->gquic_zero_rtt_disabled();
}
std::unique_ptr<QuicChromiumClientSession::Handle>
QuicChromiumClientSession::CreateHandle(url::SchemeHostPort destination) {
return std::make_unique<QuicChromiumClientSession::Handle>(
weak_factory_.GetWeakPtr(), std::move(destination));
}
bool QuicChromiumClientSession::OnReadError(
int result,
const DatagramClientSocket* socket) {
DCHECK(socket != nullptr);
base::UmaHistogramSparse("Net.QuicSession.ReadError.AnyNetwork", -result);
if (socket != GetDefaultSocket()) {
DVLOG(1) << "Ignoring read error " << ErrorToString(result)
<< " on old socket";
base::UmaHistogramSparse("Net.QuicSession.ReadError.OtherNetworks",
-result);
// Ignore read errors from sockets that are not affecting the current
// network, i.e., sockets that are no longer active and probing socket.
// TODO(jri): Maybe clean up old sockets on error.
return false;
}
if (ignore_read_error_) {
DVLOG(1) << "Ignoring read error " << ErrorToString(result)
<< " during pending migration";
// Ignore read errors during pending migration. Connection will be closed if
// pending migration failed or timed out.
base::UmaHistogramSparse("Net.QuicSession.ReadError.PendingMigration",
-result);
return false;
}
base::UmaHistogramSparse("Net.QuicSession.ReadError.CurrentNetwork", -result);
if (OneRttKeysAvailable()) {
base::UmaHistogramSparse(
"Net.QuicSession.ReadError.CurrentNetwork.HandshakeConfirmed", -result);
}
DVLOG(1) << "Closing session on read error " << ErrorToString(result);
connection()->CloseConnection(quic::QUIC_PACKET_READ_ERROR,
ErrorToString(result),
quic::ConnectionCloseBehavior::SILENT_CLOSE);
return false;
}
bool QuicChromiumClientSession::OnPacket(
const quic::QuicReceivedPacket& packet,
const quic::QuicSocketAddress& local_address,
const quic::QuicSocketAddress& peer_address) {
ProcessUdpPacket(local_address, peer_address, packet);
if (!connection()->connected()) {
NotifyFactoryOfSessionClosedLater();
return false;
}
return true;
}
void QuicChromiumClientSession::NotifyFactoryOfSessionGoingAway() {
going_away_ = true;
if (session_pool_) {
session_pool_->OnSessionGoingAway(this);
}
}
void QuicChromiumClientSession::NotifyFactoryOfSessionClosedLater() {
going_away_ = true;
DCHECK_EQ(0u, GetNumActiveStreams());
DCHECK(!connection()->connected());
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::NotifyFactoryOfSessionClosed,
weak_factory_.GetWeakPtr()));
}
void QuicChromiumClientSession::NotifyFactoryOfSessionClosed() {
going_away_ = true;
DCHECK_EQ(0u, GetNumActiveStreams());
// Will delete |this|.
if (session_pool_) {
session_pool_->OnSessionClosed(this);
}
}
void QuicChromiumClientSession::OnCryptoHandshakeComplete() {
if (session_pool_) {
session_pool_->set_has_quic_ever_worked_on_current_network(true);
}
// Update |connect_end| only when handshake is confirmed. This should also
// take care of any failed 0-RTT request.
connect_timing_.connect_end = tick_clock_->NowTicks();
DCHECK_LE(connect_timing_.connect_start, connect_timing_.connect_end);
base::TimeDelta handshake_confirmed_time =
connect_timing_.connect_end - connect_timing_.connect_start;
UMA_HISTOGRAM_TIMES("Net.QuicSession.HandshakeConfirmedTime",
handshake_confirmed_time);
// Indicate that the handshake is complete so that we can safely send pings
// to the peer.
crypto_handshake_complete_ = true;
// We explicitly kick off pings here, since we do not want to ping when there
// are no available encrypters available.
if (enable_periodic_ping_) {
connection()->SendPing();
}
// Also record the handshake time when ECH was advertised in DNS. The ECH
// experiment does not change DNS behavior, so this measures the same servers
// in both experiment and control groups.
if (!ech_config_list_.empty()) {
UMA_HISTOGRAM_TIMES("Net.QuicSession.HandshakeConfirmedTime.ECH",
handshake_confirmed_time);
}
// Also record the handshake time when Trust Anchor IDs was advertised in DNS.
// The Trust Anchor IDs experiment does not change DNS behavior, so this
// measures the same servers in both experiment and control groups.
if (!trust_anchor_ids_.empty()) {
base::UmaHistogramTimes(
"Net.QuicSession.HandshakeConfirmedTime.TrustAnchorIDs",
handshake_confirmed_time);
}
// Track how long it has taken to finish handshake after we have finished
// DNS host resolution.
if (!connect_timing_.domain_lookup_end.is_null()) {
UMA_HISTOGRAM_TIMES(
"Net.QuicSession.HostResolution.HandshakeConfirmedTime",
tick_clock_->NowTicks() - connect_timing_.domain_lookup_end);
}
auto it = handles_.begin();
while (it != handles_.end()) {
Handle* handle = *it;
++it;
handle->OnCryptoHandshakeConfirmed();
}
NotifyRequestsOfConfirmation(OK);
// Attempt to migrate back to the default network after handshake has been
// confirmed if the session is not created on the default network.
if (migrate_session_on_network_change_v2_ &&
default_network_ != handles::kInvalidNetworkHandle &&
GetCurrentNetwork() != default_network_) {
current_migration_cause_ = ON_MIGRATE_BACK_TO_DEFAULT_NETWORK;
StartMigrateBackToDefaultNetworkTimer(
base::Seconds(kMinRetryTimeForDefaultNetworkSecs));
}
}
void QuicChromiumClientSession::Migrate(handles::NetworkHandle network,
IPEndPoint peer_address,
bool close_session_on_error,
MigrationCallback migration_callback) {
quic_connection_migration_attempted_ = true;
quic_connection_migration_successful_ = false;
if (!session_pool_) {
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::DoMigrationCallback,
weak_factory_.GetWeakPtr(),
std::move(migration_callback),
MigrationResult::FAILURE));
return;
}
if (network != handles::kInvalidNetworkHandle) {
// This is a migration attempt from connection migration.
ResetNonMigratableStreams();
if (!migrate_idle_session_ && !HasActiveRequestStreams()) {
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::DoMigrationCallback,
weak_factory_.GetWeakPtr(),
std::move(migration_callback),
MigrationResult::FAILURE));
// If idle sessions can not be migrated, close the session if needed.
if (close_session_on_error) {
CloseSessionOnErrorLater(
ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_NO_MIGRATABLE_STREAMS,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
}
return;
}
}
// Create and configure socket on |network|.
std::unique_ptr<DatagramClientSocket> socket(
session_pool_->CreateSocket(net_log_.net_log(), net_log_.source()));
DatagramClientSocket* socket_ptr = socket.get();
DVLOG(1) << "Force blocking the packet writer";
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_force_write_blocked(true);
if (base::FeatureList::IsEnabled(features::kDisableBlackholeOnNoNewNetwork)) {
// Turn off the black hole detector since the writer is blocked.
// Blackhole will be re-enabled once a packet is sent again.
connection()->blackhole_detector().StopDetection(false);
}
CompletionOnceCallback connect_callback = base::BindOnce(
&QuicChromiumClientSession::FinishMigrate, weak_factory_.GetWeakPtr(),
std::move(socket), peer_address, close_session_on_error,
std::move(migration_callback));
if (!MidMigrationCallbackForTesting().is_null()) {
std::move(MidMigrationCallbackForTesting()).Run(); // IN-TEST
}
session_pool_->ConnectAndConfigureSocket(std::move(connect_callback),
socket_ptr, peer_address, network,
session_key_.socket_tag());
}
void QuicChromiumClientSession::FinishMigrate(
std::unique_ptr<DatagramClientSocket> socket,
IPEndPoint peer_address,
bool close_session_on_error,
MigrationCallback callback,
int rv) {
if (rv != OK) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_INTERNAL_ERROR,
connection_id(),
"Socket configuration failed");
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_force_write_blocked(false);
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::DoMigrationCallback,
weak_factory_.GetWeakPtr(), std::move(callback),
MigrationResult::FAILURE));
if (close_session_on_error) {
CloseSessionOnErrorLater(ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_INTERNAL_ERROR,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
}
return;
}
// Create new packet reader and writer on the new socket.
auto new_reader = std::make_unique<QuicChromiumPacketReader>(
std::move(socket), clock_, this, yield_after_packets_,
yield_after_duration_, net_log_);
new_reader->StartReading();
auto new_writer = std::make_unique<QuicChromiumPacketWriter>(
new_reader->socket(), task_runner_);
static_cast<QuicChromiumPacketWriter*>(connection()->writer())
->set_delegate(nullptr);
new_writer->set_delegate(this);
IPEndPoint self_address;
new_reader->socket()->GetLocalAddress(&self_address);
// Migrate to the new socket.
if (!MigrateToSocket(ToQuicSocketAddress(self_address),
ToQuicSocketAddress(peer_address), std::move(new_reader),
std::move(new_writer))) {
task_runner_->PostTask(
FROM_HERE,
base::BindOnce(&QuicChromiumClientSession::DoMigrationCallback,
weak_factory_.GetWeakPtr(), std::move(callback),
MigrationResult::FAILURE));
if (close_session_on_error) {
CloseSessionOnErrorLater(ERR_NETWORK_CHANGED,
quic::QUIC_CONNECTION_MIGRATION_TOO_MANY_CHANGES,
quic::ConnectionCloseBehavior::SILENT_CLOSE);
}
return;
}
quic_connection_migration_successful_ = true;
HistogramAndLogMigrationSuccess(connection_id());
task_runner_->PostTask(
FROM_HERE, base::BindOnce(&QuicChromiumClientSession::DoMigrationCallback,
weak_factory_.GetWeakPtr(), std::move(callback),
MigrationResult::SUCCESS));
}
void QuicChromiumClientSession::DoMigrationCallback(MigrationCallback callback,
MigrationResult rv) {
std::move(callback).Run(rv);
}
bool QuicChromiumClientSession::MigrateToSocket(
const quic::QuicSocketAddress& self_address,
const quic::QuicSocketAddress& peer_address,
std::unique_ptr<QuicChromiumPacketReader> reader,
std::unique_ptr<QuicChromiumPacketWriter> writer) {
// Writer must be destroyed before reader, since it points to the socket owned
// by reader. C++ doesn't have any guarantees about destruction order of
// arguments.
std::unique_ptr<QuicChromiumPacketWriter> writer_moved = std::move(writer);
// Sessions carried via a proxy should never migrate, and that is ensured
// elsewhere (for each possible migration trigger).
DUMP_WILL_BE_CHECK(session_key_.proxy_chain().is_direct());
// TODO(zhongyi): figure out whether we want to limit the number of
// connection migrations for v2, which includes migration on platform signals,
// write error events, and path degrading on original network.
if (!migrate_session_on_network_change_v2_ &&
packet_readers_.size() >= kMaxReadersPerQuicSession) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_TOO_MANY_CHANGES,
connection_id(), "Too many changes");
return false;
}
packet_readers_.push_back(std::move(reader));
// Force the writer to be blocked to prevent it being used until
// WriteToNewSocket completes.
DVLOG(1) << "Force blocking the packet writer";
writer_moved->set_force_write_blocked(true);
// UnregisterQuicConnectionClosePayload must be called before MigratePath, and
// RegisterQuicConnectionClosePayload must be called after. MigratePath
// replaces the packet writer, and these unregister/register methods operate
// on the current writer.
UnregisterQuicConnectionClosePayload();
int rv = MigratePath(self_address, peer_address, writer_moved.release(),
/*owns_writer=*/true);
RegisterQuicConnectionClosePayload();
if (!rv) {
HistogramAndLogMigrationFailure(MIGRATION_STATUS_NO_UNUSED_CONNECTION_ID,
connection_id(),
"No unused server connection ID");
DVLOG(1) << "MigratePath fails as there is no CID available";
return false;
}
// Post task to write the pending packet or a PING packet to the new
// socket. This avoids reentrancy issues if there is a write error
// on the write to the new socket.
task_runner_->PostTask(
FROM_HERE, base::BindOnce(&QuicChromiumClientSession::WriteToNewSocket,
weak_factory_.GetWeakPtr()));
return true;
}
void QuicChromiumClientSession::PopulateNetErrorDetails(
NetErrorDetails* details) const {
details->quic_port_migration_detected = port_migration_detected_;
details->quic_connection_error = error();
details->source = source_;
details->quic_connection_migration_attempted =
quic_connection_migration_attempted_;
details->quic_connection_migration_successful =
quic_connection_migration_successful_;
}
const DatagramClientSocket* QuicChromiumClientSession::GetDefaultSocket()
const {
DCHECK(packet_readers_.back()->socket() != nullptr);
// The most recently added socket is the currently active one.
return packet_readers_.back()->socket();
}
handles::NetworkHandle QuicChromiumClientSession::GetCurrentNetwork() const {
// If connection migration is enabled, alternate network interface may be
// used to send packet, it is identified as the bound network of the default
// socket. Otherwise, always use |default_network_|.
return migrate_session_on_network_change_v2_
? GetDefaultSocket()->GetBoundNetwork()
: default_network_;
}
void QuicChromiumClientSession::OnServerPreferredAddressAvailable(
const quic::QuicSocketAddress& server_preferred_address) {
// If this is a proxied connection, we cannot perform any migration, so
// ignore the server preferred address.
if (!session_key_.proxy_chain().is_direct()) {
net_log_.AddEvent(NetLogEventType::QUIC_CONNECTION_MIGRATION_FAILURE, [&] {
return NetLogQuicMigrationFailureParams(
connection_id(),
"Ignored server preferred address received via proxied connection");
});
return;
}
if (!allow_server_preferred_address_) {
return;
}
current_migration_cause_ = ON_SERVER_PREFERRED_ADDRESS_AVAILABLE;
net_log_.BeginEvent(
NetLogEventType::QUIC_ON_SERVER_PREFERRED_ADDRESS_AVAILABLE);
if (!session_pool_) {
return;
}
StartProbing(base::DoNothingAs<void(ProbingResult)>(), default_network_,
server_preferred_address);
net_log_.EndEvent(
NetLogEventType::QUIC_START_VALIDATING_SERVER_PREFERRED_ADDRESS);
}
const LoadTimingInfo::ConnectTiming&
QuicChromiumClientSession::GetConnectTiming() {
connect_timing_.ssl_start = connect_timing_.connect_start;
connect_timing_.ssl_end = connect_timing_.connect_end;
return connect_timing_;
}
quic::ParsedQuicVersion QuicChromiumClientSession::GetQuicVersion() const {
return connection()->version();
}
void QuicChromiumClientSession::SendPing() {
return connection()->SendPing();
}
const std::set<std::string>&
QuicChromiumClientSession::GetDnsAliasesForSessionKey(
const QuicSessionKey& key) const {
static const base::NoDestructor<std::set<std::string>> emptyset_result;
return session_pool_ ? session_pool_->GetDnsAliasesForSessionKey(key)
: *emptyset_result;
}
quic::QuicPacketLength
QuicChromiumClientSession::Handle::GetGuaranteedLargestMessagePayload() const {
if (!session_) {
return 0;
}
return session_->GetGuaranteedLargestMessagePayload();
}
const ConnectionMigrationInformation
QuicChromiumClientSession::Handle::GetConnectionMigrationInfoSinceInit() const {
if (!session_) {
return last_migration_information_ - initial_migration_information_;
}
return session_->migration_info() - initial_migration_information_;
}
#if BUILDFLAG(ENABLE_WEBSOCKETS)
std::unique_ptr<WebSocketQuicStreamAdapter>
QuicChromiumClientSession::CreateWebSocketQuicStreamAdapterImpl(
WebSocketQuicStreamAdapter::Delegate* delegate) {
DCHECK(connection()->connected());
DCHECK(CanOpenNextOutgoingBidirectionalStream());
auto websocket_quic_spdy_stream = std::make_unique<WebSocketQuicSpdyStream>(
GetNextOutgoingBidirectionalStreamId(), this, quic::BIDIRECTIONAL);
auto adapter = std::make_unique<WebSocketQuicStreamAdapter>(
websocket_quic_spdy_stream.get(), delegate);
ActivateStream(std::move(websocket_quic_spdy_stream));
++num_total_streams_;
return adapter;
}
std::unique_ptr<WebSocketQuicStreamAdapter>
QuicChromiumClientSession::CreateWebSocketQuicStreamAdapter(
WebSocketQuicStreamAdapter::Delegate* delegate,
base::OnceCallback<void(std::unique_ptr<WebSocketQuicStreamAdapter>)>
callback,
StreamRequest* stream_request) {
DCHECK(connection()->connected());
if (!CanOpenNextOutgoingBidirectionalStream()) {
stream_request->pending_start_time_ = tick_clock_->NowTicks();
stream_request->for_websockets_ = true;
stream_request->websocket_adapter_delegate_ = delegate;
stream_request->start_websocket_callback_ = std::move(callback);
stream_requests_.push_back(stream_request);
UMA_HISTOGRAM_COUNTS_1000("Net.QuicSession.NumPendingStreamRequests",
stream_requests_.size());
return nullptr;
}
return CreateWebSocketQuicStreamAdapterImpl(delegate);
}
#endif // BUILDFLAG(ENABLE_WEBSOCKETS)
} // namespace net