123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186 |
- // Copyright (c) 2012 The Chromium Authors. All rights reserved.
- // Use of this source code is governed by a BSD-style license that can be
- // found in the LICENSE file.
- #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::NetworkIsolationKey& network_isolation_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, const 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_
|