1 // Copyright 2024 The Chromium Authors
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "net/quic/quic_session_pool_job.h"
6
7 #include "base/memory/weak_ptr.h"
8 #include "base/not_fatal_until.h"
9 #include "net/base/completion_once_callback.h"
10 #include "net/base/network_change_notifier.h"
11 #include "net/base/network_handle.h"
12 #include "net/base/proxy_chain.h"
13 #include "net/base/request_priority.h"
14 #include "net/base/trace_constants.h"
15 #include "net/base/tracing.h"
16 #include "net/dns/host_resolver.h"
17 #include "net/log/net_log_with_source.h"
18 #include "net/quic/address_utils.h"
19 #include "net/quic/quic_crypto_client_config_handle.h"
20 #include "net/quic/quic_http_stream.h"
21 #include "net/quic/quic_session_pool.h"
22 #include "net/third_party/quiche/src/quiche/quic/core/quic_versions.h"
23
24 namespace net {
25
26 namespace {
27
NetLogQuicSessionPoolJobParams(const QuicSessionAliasKey * key)28 base::Value::Dict NetLogQuicSessionPoolJobParams(
29 const QuicSessionAliasKey* key) {
30 const ProxyChain& proxy_chain = key->session_key().proxy_chain();
31 return base::Value::Dict()
32 .Set("host", key->server_id().host())
33 .Set("port", key->server_id().port())
34 .Set("privacy_mode",
35 PrivacyModeToDebugString(key->session_key().privacy_mode()))
36 .Set("proxy_chain",
37 proxy_chain.IsValid() ? proxy_chain.ToDebugString() : "invalid")
38 .Set("network_anonymization_key",
39 key->session_key().network_anonymization_key().ToDebugString());
40 }
41
42 } // namespace
43
Job(QuicSessionPool * pool,QuicSessionAliasKey key,std::unique_ptr<CryptoClientConfigHandle> client_config_handle,RequestPriority priority,const NetLogWithSource & net_log)44 QuicSessionPool::Job::Job(
45 QuicSessionPool* pool,
46 QuicSessionAliasKey key,
47 std::unique_ptr<CryptoClientConfigHandle> client_config_handle,
48 RequestPriority priority,
49 const NetLogWithSource& net_log)
50 : pool_(pool),
51 key_(std::move(key)),
52 client_config_handle_(std::move(client_config_handle)),
53 priority_(priority),
54 net_log_(net_log) {
55 net_log_.BeginEvent(NetLogEventType::QUIC_SESSION_POOL_JOB,
56 [&] { return NetLogQuicSessionPoolJobParams(&key_); });
57 }
58
~Job()59 QuicSessionPool::Job::~Job() {
60 net_log_.EndEvent(NetLogEventType::QUIC_SESSION_POOL_JOB);
61 }
62
AddRequest(QuicSessionRequest * request)63 void QuicSessionPool::Job::AddRequest(QuicSessionRequest* request) {
64 requests_.insert(request);
65 SetRequestExpectations(request);
66 }
67
RemoveRequest(QuicSessionRequest * request)68 void QuicSessionPool::Job::RemoveRequest(QuicSessionRequest* request) {
69 auto request_iter = requests_.find(request);
70 CHECK(request_iter != requests_.end(), base::NotFatalUntil::M130);
71 requests_.erase(request_iter);
72 }
73
SetPriority(RequestPriority priority)74 void QuicSessionPool::Job::SetPriority(RequestPriority priority) {
75 UpdatePriority(priority_, priority);
76 priority_ = priority;
77 }
78
AssociateWithNetLogSource(const NetLogWithSource & http_stream_job_net_log) const79 void QuicSessionPool::Job::AssociateWithNetLogSource(
80 const NetLogWithSource& http_stream_job_net_log) const {
81 net_log().AddEventReferencingSource(
82 NetLogEventType::QUIC_SESSION_POOL_JOB_BOUND_TO,
83 http_stream_job_net_log.source());
84 http_stream_job_net_log.AddEventReferencingSource(
85 NetLogEventType::BOUND_TO_QUIC_SESSION_POOL_JOB, net_log().source());
86 }
87
GetQuicSessionPool()88 QuicSessionPool* QuicSessionPool::Job::GetQuicSessionPool() {
89 return pool();
90 }
91
GetKey()92 const QuicSessionAliasKey& QuicSessionPool::Job::GetKey() {
93 return key();
94 }
95
GetNetLog()96 const NetLogWithSource& QuicSessionPool::Job::GetNetLog() {
97 return net_log();
98 }
99
OnConnectionFailedOnDefaultNetwork()100 void QuicSessionPool::Job::OnConnectionFailedOnDefaultNetwork() {
101 for (QuicSessionRequest* request : requests()) {
102 request->OnConnectionFailedOnDefaultNetwork();
103 }
104 }
105
OnQuicSessionCreationComplete(int rv)106 void QuicSessionPool::Job::OnQuicSessionCreationComplete(int rv) {
107 for (QuicSessionRequest* request : requests()) {
108 request->OnQuicSessionCreationComplete(rv);
109 }
110 }
111
UpdatePriority(RequestPriority old_priority,RequestPriority new_priority)112 void QuicSessionPool::Job::UpdatePriority(RequestPriority old_priority,
113 RequestPriority new_priority) {}
114
115 } // namespace net
116