1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #ifndef NET_HTTP_HTTP_STREAM_FACTORY_H_
6 #define NET_HTTP_HTTP_STREAM_FACTORY_H_
12 #include "base/basictypes.h"
13 #include "base/memory/ref_counted.h"
14 #include "base/strings/string16.h"
15 #include "net/base/completion_callback.h"
16 #include "net/base/load_states.h"
17 #include "net/base/net_export.h"
18 #include "net/base/request_priority.h"
19 #include "net/http/http_server_properties.h"
20 #include "net/socket/ssl_client_socket.h"
21 // This file can be included from net/http even though
22 // it is in net/websockets because it doesn't
23 // introduce any link dependency to net/websockets.
24 #include "net/websockets/websocket_stream_base.h"
34 class AuthCredentials
;
36 class HostMappingRules
;
38 class HttpAuthController
;
39 class HttpResponseInfo
;
40 class HttpServerProperties
;
43 class SSLCertRequestInfo
;
45 struct HttpRequestInfo
;
48 // The HttpStreamRequest is the client's handle to the worker object which
49 // handles the creation of an HttpStream. While the HttpStream is being
50 // created, this object is the creator's handle for interacting with the
51 // HttpStream creation process. The request is cancelled by deleting it, after
52 // which no callbacks will be invoked.
53 class NET_EXPORT_PRIVATE HttpStreamRequest
{
55 // The HttpStreamRequest::Delegate is a set of callback methods for a
56 // HttpStreamRequestJob. Generally, only one of these methods will be
57 // called as a result of a stream request.
58 class NET_EXPORT_PRIVATE Delegate
{
60 virtual ~Delegate() {}
62 // This is the success case for RequestStream.
63 // |stream| is now owned by the delegate.
64 // |used_ssl_config| indicates the actual SSL configuration used for this
65 // stream, since the HttpStreamRequest may have modified the configuration
66 // during stream processing.
67 // |used_proxy_info| indicates the actual ProxyInfo used for this stream,
68 // since the HttpStreamRequest performs the proxy resolution.
69 virtual void OnStreamReady(
70 const SSLConfig
& used_ssl_config
,
71 const ProxyInfo
& used_proxy_info
,
72 HttpStreamBase
* stream
) = 0;
74 // This is the success case for RequestWebSocketStream.
75 // |stream| is now owned by the delegate.
76 // |used_ssl_config| indicates the actual SSL configuration used for this
77 // stream, since the HttpStreamRequest may have modified the configuration
78 // during stream processing.
79 // |used_proxy_info| indicates the actual ProxyInfo used for this stream,
80 // since the HttpStreamRequest performs the proxy resolution.
81 virtual void OnWebSocketStreamReady(
82 const SSLConfig
& used_ssl_config
,
83 const ProxyInfo
& used_proxy_info
,
84 WebSocketStreamBase
* stream
) = 0;
86 // This is the failure to create a stream case.
87 // |used_ssl_config| indicates the actual SSL configuration used for this
88 // stream, since the HttpStreamRequest may have modified the configuration
89 // during stream processing.
90 virtual void OnStreamFailed(int status
,
91 const SSLConfig
& used_ssl_config
) = 0;
93 // Called when we have a certificate error for the request.
94 // |used_ssl_config| indicates the actual SSL configuration used for this
95 // stream, since the HttpStreamRequest may have modified the configuration
96 // during stream processing.
97 virtual void OnCertificateError(int status
,
98 const SSLConfig
& used_ssl_config
,
99 const SSLInfo
& ssl_info
) = 0;
101 // This is the failure case where we need proxy authentication during
102 // proxy tunnel establishment. For the tunnel case, we were unable to
103 // create the HttpStream, so the caller provides the auth and then resumes
104 // the HttpStreamRequest.
106 // For the non-tunnel case, the caller will discover the authentication
107 // failure when reading response headers. At that point, he will handle the
108 // authentication failure and restart the HttpStreamRequest entirely.
110 // Ownership of |auth_controller| and |proxy_response| are owned
111 // by the HttpStreamRequest. |proxy_response| is not guaranteed to be usable
112 // after the lifetime of this callback. The delegate may take a reference
113 // to |auth_controller| if it is needed beyond the lifetime of this
116 // |used_ssl_config| indicates the actual SSL configuration used for this
117 // stream, since the HttpStreamRequest may have modified the configuration
118 // during stream processing.
119 virtual void OnNeedsProxyAuth(const HttpResponseInfo
& proxy_response
,
120 const SSLConfig
& used_ssl_config
,
121 const ProxyInfo
& used_proxy_info
,
122 HttpAuthController
* auth_controller
) = 0;
124 // This is the failure for SSL Client Auth
125 // Ownership of |cert_info| is retained by the HttpStreamRequest. The
126 // delegate may take a reference if it needs the cert_info beyond the
127 // lifetime of this callback.
128 virtual void OnNeedsClientAuth(const SSLConfig
& used_ssl_config
,
129 SSLCertRequestInfo
* cert_info
) = 0;
131 // This is the failure of the CONNECT request through an HTTPS proxy.
132 // Headers can be read from |response_info|, while the body can be read
135 // |used_ssl_config| indicates the actual SSL configuration used for this
136 // stream, since the HttpStreamRequest may have modified the configuration
137 // during stream processing.
139 // |used_proxy_info| indicates the actual ProxyInfo used for this stream,
140 // since the HttpStreamRequest performs the proxy resolution.
142 // Ownership of |stream| is transferred to the delegate.
143 virtual void OnHttpsProxyTunnelResponse(
144 const HttpResponseInfo
& response_info
,
145 const SSLConfig
& used_ssl_config
,
146 const ProxyInfo
& used_proxy_info
,
147 HttpStreamBase
* stream
) = 0;
150 virtual ~HttpStreamRequest() {}
152 // When a HttpStream creation process is stalled due to necessity
153 // of Proxy authentication credentials, the delegate OnNeedsProxyAuth
154 // will have been called. It now becomes the delegate's responsibility
155 // to collect the necessary credentials, and then call this method to
156 // resume the HttpStream creation process.
157 virtual int RestartTunnelWithProxyAuth(
158 const AuthCredentials
& credentials
) = 0;
160 // Returns the LoadState for the request.
161 virtual LoadState
GetLoadState() const = 0;
163 // Returns true if TLS/NPN was negotiated for this stream.
164 virtual bool was_npn_negotiated() const = 0;
166 // Protocol negotiated with the server.
167 virtual NextProto
protocol_negotiated() const = 0;
169 // Returns true if this stream is being fetched over SPDY.
170 virtual bool using_spdy() const = 0;
173 // The HttpStreamFactory defines an interface for creating usable HttpStreams.
174 class NET_EXPORT HttpStreamFactory
{
176 virtual ~HttpStreamFactory();
178 void ProcessAlternateProtocol(
179 const base::WeakPtr
<HttpServerProperties
>& http_server_properties
,
180 const std::string
& alternate_protocol_str
,
181 const HostPortPair
& http_host_port_pair
);
183 GURL
ApplyHostMappingRules(const GURL
& url
, HostPortPair
* endpoint
);
185 // Virtual interface methods.
188 // Will call delegate->OnStreamReady on successful completion.
189 virtual HttpStreamRequest
* RequestStream(
190 const HttpRequestInfo
& info
,
191 RequestPriority priority
,
192 const SSLConfig
& server_ssl_config
,
193 const SSLConfig
& proxy_ssl_config
,
194 HttpStreamRequest::Delegate
* delegate
,
195 const BoundNetLog
& net_log
) = 0;
197 // Request a WebSocket stream.
198 // Will call delegate->OnWebSocketStreamReady on successful completion.
199 virtual HttpStreamRequest
* RequestWebSocketStream(
200 const HttpRequestInfo
& info
,
201 RequestPriority priority
,
202 const SSLConfig
& server_ssl_config
,
203 const SSLConfig
& proxy_ssl_config
,
204 HttpStreamRequest::Delegate
* delegate
,
205 WebSocketStreamBase::Factory
* factory
,
206 const BoundNetLog
& net_log
) = 0;
208 // Requests that enough connections for |num_streams| be opened.
209 virtual void PreconnectStreams(int num_streams
,
210 const HttpRequestInfo
& info
,
211 RequestPriority priority
,
212 const SSLConfig
& server_ssl_config
,
213 const SSLConfig
& proxy_ssl_config
) = 0;
215 // If pipelining is supported, creates a Value summary of the currently active
216 // pipelines. Caller assumes ownership of the returned value. Otherwise,
217 // returns an empty Value.
218 virtual base::Value
* PipelineInfoToValue() const = 0;
220 virtual const HostMappingRules
* GetHostMappingRules() const = 0;
224 // Reset all static settings to initialized values. Used to init test suite.
225 static void ResetStaticSettingsToInit();
227 // Turns spdy on or off.
228 static void set_spdy_enabled(bool value
) {
229 spdy_enabled_
= value
;
230 if (!spdy_enabled_
) {
235 static bool spdy_enabled() { return spdy_enabled_
; }
237 // Controls whether or not we use the Alternate-Protocol header.
238 static void set_use_alternate_protocols(bool value
) {
239 use_alternate_protocols_
= value
;
241 static bool use_alternate_protocols() { return use_alternate_protocols_
; }
243 // Controls whether or not we use ssl when in spdy mode.
244 static void set_force_spdy_over_ssl(bool value
) {
245 force_spdy_over_ssl_
= value
;
247 static bool force_spdy_over_ssl() {
248 return force_spdy_over_ssl_
;
251 // Controls whether or not we use spdy without npn.
252 static void set_force_spdy_always(bool value
) {
253 force_spdy_always_
= value
;
255 static bool force_spdy_always() { return force_spdy_always_
; }
257 // Add a URL to exclude from forced SPDY.
258 static void add_forced_spdy_exclusion(const std::string
& value
);
259 // Check if a HostPortPair is excluded from using spdy.
260 static bool HasSpdyExclusion(const HostPortPair
& endpoint
);
262 // Sets http/1.1 as the only protocol supported via NPN or Alternate-Protocol.
263 static void EnableNpnHttpOnly();
265 // Sets http/1.1, quic and spdy/2 (the default spdy protocol) as the protocols
266 // supported via NPN or Alternate-Protocol.
267 static void EnableNpnSpdy();
269 // Sets http/1.1, quic, spdy/2, and spdy/3 as the protocols supported via NPN
270 // or Alternate-Protocol.
271 static void EnableNpnSpdy3();
273 // Sets http/1.1, quic, spdy/2, spdy/3, and spdy/3.1 as the protocols
274 // supported via NPN or Alternate-Protocol.
275 static void EnableNpnSpdy31();
277 // Sets http/1.1, quic, spdy/2, spdy/3, spdy/3.1, and spdy/4a2 as
278 // the protocols supported via NPN or Alternate-Protocol.
279 static void EnableNpnSpdy4a2();
281 // Sets http/1.1, quic, spdy/2, spdy/3, spdy/3.1, spdy/4a2, and
282 // http/2 draft 04 as the protocols supported via NPN or
283 // Alternate-Protocol.
284 static void EnableNpnHttp2Draft04();
286 // Sets the protocols supported by NPN (next protocol negotiation) during the
287 // SSL handshake as well as by HTTP Alternate-Protocol.
288 static void SetNextProtos(const std::vector
<NextProto
>& value
);
289 static bool has_next_protos() { return next_protos_
!= NULL
; }
290 static const std::vector
<std::string
>& next_protos() {
291 return *next_protos_
;
298 static std::vector
<std::string
>* next_protos_
;
299 static bool enabled_protocols_
[NUM_ALTERNATE_PROTOCOLS
];
300 static bool spdy_enabled_
;
301 static bool use_alternate_protocols_
;
302 static bool force_spdy_over_ssl_
;
303 static bool force_spdy_always_
;
304 static std::list
<HostPortPair
>* forced_spdy_exclusions_
;
306 DISALLOW_COPY_AND_ASSIGN(HttpStreamFactory
);
311 #endif // NET_HTTP_HTTP_STREAM_FACTORY_H_