1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
// 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.
#ifndef NET_HTTP_HTTP_STREAM_FACTORY_H_
#define NET_HTTP_HTTP_STREAM_FACTORY_H_
#include <stddef.h>
#include <map>
#include <memory>
#include <set>
#include <string>
#include "base/containers/unique_ptr_adapters.h"
#include "base/gtest_prod_util.h"
#include "base/memory/raw_ptr.h"
#include "base/memory/ref_counted.h"
#include "net/base/host_port_pair.h"
#include "net/base/load_states.h"
#include "net/base/net_export.h"
#include "net/base/privacy_mode.h"
#include "net/base/proxy_server.h"
#include "net/base/request_priority.h"
#include "net/http/http_request_info.h"
#include "net/http/http_server_properties.h"
#include "net/http/http_stream_request.h"
#include "net/log/net_log_source.h"
#include "net/log/net_log_with_source.h"
#include "net/proxy_resolution/proxy_info.h"
#include "net/socket/ssl_client_socket.h"
#include "net/spdy/spdy_session_key.h"
#include "net/ssl/ssl_config.h"
#include "net/websockets/websocket_handshake_stream_base.h"
namespace net {
class HostMappingRules;
class HttpNetworkSession;
class HttpResponseHeaders;
class NET_EXPORT HttpStreamFactory {
public:
class NET_EXPORT_PRIVATE Job;
class NET_EXPORT_PRIVATE JobController;
class NET_EXPORT_PRIVATE JobFactory;
enum JobType {
// Job that will connect via HTTP/1 or HTTP/2. This may be paused for a
// while when ALTERNATIVE or DNS_ALPN_H3 job was created.
MAIN,
// Job that will connect via HTTP/3 iff Chrome has received an Alt-Svc
// header from the origin.
ALTERNATIVE,
// Job that will connect via HTTP/3 iff an "h3" value was found in the ALPN
// list of an HTTPS DNS record.
DNS_ALPN_H3,
// Job that will preconnect. This uses HTTP/3 iff Chrome has received an
// Alt-Svc header from the origin. Otherwise, it use HTTP/1 or HTTP/2.
PRECONNECT,
// Job that will preconnect via HTTP/3 iff an "h3" value was found in the
// ALPN list of an HTTPS DNS record.
PRECONNECT_DNS_ALPN_H3,
};
explicit HttpStreamFactory(HttpNetworkSession* session);
HttpStreamFactory(const HttpStreamFactory&) = delete;
HttpStreamFactory& operator=(const HttpStreamFactory&) = delete;
virtual ~HttpStreamFactory();
void ProcessAlternativeServices(
HttpNetworkSession* session,
const net::NetworkAnonymizationKey& network_anonymization_key,
const HttpResponseHeaders* headers,
const url::SchemeHostPort& http_server);
// Request a stream.
// Will call delegate->OnStreamReady on successful completion.
std::unique_ptr<HttpStreamRequest> RequestStream(
const HttpRequestInfo& info,
RequestPriority priority,
const SSLConfig& server_ssl_config,
const SSLConfig& proxy_ssl_config,
HttpStreamRequest::Delegate* delegate,
bool enable_ip_based_pooling,
bool enable_alternative_services,
const NetLogWithSource& net_log);
// Request a WebSocket handshake stream.
// Will call delegate->OnWebSocketHandshakeStreamReady on successful
// completion.
std::unique_ptr<HttpStreamRequest> RequestWebSocketHandshakeStream(
const HttpRequestInfo& info,
RequestPriority priority,
const SSLConfig& server_ssl_config,
const SSLConfig& proxy_ssl_config,
HttpStreamRequest::Delegate* delegate,
WebSocketHandshakeStreamBase::CreateHelper* create_helper,
bool enable_ip_based_pooling,
bool enable_alternative_services,
const NetLogWithSource& net_log);
// Request a BidirectionalStreamImpl.
// Will call delegate->OnBidirectionalStreamImplReady on successful
// completion.
// TODO(https://crbug.com/836823): This method is virtual to avoid cronet_test
// failure on iOS that is caused by Network Thread TLS getting the wrong slot.
virtual std::unique_ptr<HttpStreamRequest> RequestBidirectionalStreamImpl(
const HttpRequestInfo& info,
RequestPriority priority,
const SSLConfig& server_ssl_config,
const SSLConfig& proxy_ssl_config,
HttpStreamRequest::Delegate* delegate,
bool enable_ip_based_pooling,
bool enable_alternative_services,
const NetLogWithSource& net_log);
// Requests that enough connections for |num_streams| be opened.
void PreconnectStreams(int num_streams, HttpRequestInfo& info);
const HostMappingRules* GetHostMappingRules() const;
private:
FRIEND_TEST_ALL_PREFIXES(HttpStreamRequestTest, SetPriority);
friend class HttpStreamFactoryPeer;
using JobControllerSet =
std::set<std::unique_ptr<JobController>, base::UniquePtrComparator>;
url::SchemeHostPort RewriteHost(const url::SchemeHostPort& server);
// Values must not be changed or reused. Keep in sync with identically named
// enum in histograms.xml.
enum AlternativeServiceType {
NO_ALTERNATIVE_SERVICE = 0,
QUIC_SAME_DESTINATION = 1,
QUIC_DIFFERENT_DESTINATION = 2,
NOT_QUIC_SAME_DESTINATION = 3,
NOT_QUIC_DIFFERENT_DESTINATION = 4,
MAX_ALTERNATIVE_SERVICE_TYPE
};
std::unique_ptr<HttpStreamRequest> RequestStreamInternal(
const HttpRequestInfo& info,
RequestPriority priority,
const SSLConfig& server_ssl_config,
const SSLConfig& proxy_ssl_config,
HttpStreamRequest::Delegate* delegate,
WebSocketHandshakeStreamBase::CreateHelper* create_helper,
HttpStreamRequest::StreamType stream_type,
bool is_websocket,
bool enable_ip_based_pooling,
bool enable_alternative_services,
const NetLogWithSource& net_log);
// Called when the Job detects that the endpoint indicated by the
// Alternate-Protocol does not work. Lets the factory update
// HttpAlternateProtocols with the failure and resets the SPDY session key.
void OnBrokenAlternateProtocol(const Job*, const HostPortPair& origin);
// Called when the Preconnect completes. Used for testing.
virtual void OnPreconnectsCompleteInternal() {}
// Called when the JobController finishes service. Delete the JobController
// from |job_controller_set_|.
void OnJobControllerComplete(JobController* controller);
const raw_ptr<HttpNetworkSession> session_;
// All Requests/Preconnects are assigned with a JobController to manage
// serving Job(s). JobController might outlive Request when Request
// is served while there's some working Job left. JobController will be
// deleted from |job_controller_set_| when it determines the completion of
// its work.
JobControllerSet job_controller_set_;
// Factory used by job controllers for creating jobs.
std::unique_ptr<JobFactory> job_factory_;
};
} // namespace net
#endif // NET_HTTP_HTTP_STREAM_FACTORY_H_
|
