OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef NET_HTTP_HTTP_STREAM_FACTORY_IMPL_JOB_H_ | 5 #ifndef NET_HTTP_HTTP_STREAM_FACTORY_IMPL_JOB_H_ |
6 #define NET_HTTP_HTTP_STREAM_FACTORY_IMPL_JOB_H_ | 6 #define NET_HTTP_HTTP_STREAM_FACTORY_IMPL_JOB_H_ |
7 | 7 |
8 #include "base/memory/ref_counted.h" | 8 #include "base/memory/ref_counted.h" |
9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "base/memory/weak_ptr.h" | 10 #include "base/memory/weak_ptr.h" |
(...skipping 18 matching lines...) Expand all Loading... |
29 class HttpAuthController; | 29 class HttpAuthController; |
30 class HttpNetworkSession; | 30 class HttpNetworkSession; |
31 class HttpStream; | 31 class HttpStream; |
32 class SpdySessionPool; | 32 class SpdySessionPool; |
33 class QuicHttpStream; | 33 class QuicHttpStream; |
34 | 34 |
35 // An HttpStreamRequestImpl exists for each stream which is in progress of being | 35 // An HttpStreamRequestImpl exists for each stream which is in progress of being |
36 // created for the StreamFactory. | 36 // created for the StreamFactory. |
37 class HttpStreamFactoryImpl::Job { | 37 class HttpStreamFactoryImpl::Job { |
38 public: | 38 public: |
| 39 // Constructor for non-alternative Job. |
39 Job(HttpStreamFactoryImpl* stream_factory, | 40 Job(HttpStreamFactoryImpl* stream_factory, |
40 HttpNetworkSession* session, | 41 HttpNetworkSession* session, |
41 const HttpRequestInfo& request_info, | 42 const HttpRequestInfo& request_info, |
42 RequestPriority priority, | 43 RequestPriority priority, |
43 const SSLConfig& server_ssl_config, | 44 const SSLConfig& server_ssl_config, |
44 const SSLConfig& proxy_ssl_config, | 45 const SSLConfig& proxy_ssl_config, |
45 NetLog* net_log); | 46 NetLog* net_log); |
| 47 // Constructor for alternative Job. |
| 48 Job(HttpStreamFactoryImpl* stream_factory, |
| 49 HttpNetworkSession* session, |
| 50 const HttpRequestInfo& request_info, |
| 51 RequestPriority priority, |
| 52 const SSLConfig& server_ssl_config, |
| 53 const SSLConfig& proxy_ssl_config, |
| 54 AlternativeService alternative_service, |
| 55 NetLog* net_log); |
46 ~Job(); | 56 ~Job(); |
47 | 57 |
48 // Start initiates the process of creating a new HttpStream. |request| will be | 58 // Start initiates the process of creating a new HttpStream. |request| will be |
49 // notified upon completion if the Job has not been Orphan()'d. | 59 // notified upon completion if the Job has not been Orphan()'d. |
50 void Start(Request* request); | 60 void Start(Request* request); |
51 | 61 |
52 // Preconnect will attempt to request |num_streams| sockets from the | 62 // Preconnect will attempt to request |num_streams| sockets from the |
53 // appropriate ClientSocketPool. | 63 // appropriate ClientSocketPool. |
54 int Preconnect(int num_streams); | 64 int Preconnect(int num_streams); |
55 | 65 |
56 int RestartTunnelWithProxyAuth(const AuthCredentials& credentials); | 66 int RestartTunnelWithProxyAuth(const AuthCredentials& credentials); |
57 LoadState GetLoadState() const; | 67 LoadState GetLoadState() const; |
58 | 68 |
59 // Marks this Job as the "alternate" job, from Alternate-Protocol or Alt-Svc | |
60 // using the specified alternate service. | |
61 void MarkAsAlternate(AlternativeService alternative_service); | |
62 | |
63 // Tells |this| to wait for |job| to resume it. | 69 // Tells |this| to wait for |job| to resume it. |
64 void WaitFor(Job* job); | 70 void WaitFor(Job* job); |
65 | 71 |
66 // Tells |this| that |job| has determined it still needs to continue | 72 // Tells |this| that |job| has determined it still needs to continue |
67 // connecting, so allow |this| to continue. If this is not called, then | 73 // connecting, so allow |this| to continue. If this is not called, then |
68 // |request_| is expected to cancel |this| by deleting it. | 74 // |request_| is expected to cancel |this| by deleting it. |
69 void Resume(Job* job); | 75 void Resume(Job* job); |
70 | 76 |
71 // Used to detach the Job from |request|. | 77 // Used to detach the Job from |request|. |
72 void Orphan(const Request* request); | 78 void Orphan(const Request* request); |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
139 STATUS_BROKEN, | 145 STATUS_BROKEN, |
140 STATUS_SUCCEEDED | 146 STATUS_SUCCEEDED |
141 }; | 147 }; |
142 | 148 |
143 // Wrapper class for SpdySessionPool methods to enforce certificate | 149 // Wrapper class for SpdySessionPool methods to enforce certificate |
144 // requirements for SpdySessions. | 150 // requirements for SpdySessions. |
145 class ValidSpdySessionPool { | 151 class ValidSpdySessionPool { |
146 public: | 152 public: |
147 ValidSpdySessionPool(SpdySessionPool* spdy_session_pool, | 153 ValidSpdySessionPool(SpdySessionPool* spdy_session_pool, |
148 GURL& origin_url, | 154 GURL& origin_url, |
149 bool is_spdy_alternate); | 155 bool is_spdy_alternative); |
150 | 156 |
151 // Returns OK if a SpdySession was not found (in which case |spdy_session| | 157 // Returns OK if a SpdySession was not found (in which case |spdy_session| |
152 // is set to nullptr), or if one was found (in which case |spdy_session| is | 158 // is set to nullptr), or if one was found (in which case |spdy_session| is |
153 // set to it) and it has an associated SSL certificate with is valid for | 159 // set to it) and it has an associated SSL certificate with is valid for |
154 // |origin_url_|, or if this requirement does not apply because the Job is | 160 // |origin_url_|, or if this requirement does not apply because the Job is |
155 // not a SPDY alternate job. Returns the appropriate error code otherwise, | 161 // not a SPDY alternative job. Returns the appropriate error code |
| 162 // otherwise, |
156 // in which case |spdy_session| should not be used. | 163 // in which case |spdy_session| should not be used. |
157 int FindAvailableSession(const SpdySessionKey& key, | 164 int FindAvailableSession(const SpdySessionKey& key, |
158 const BoundNetLog& net_log, | 165 const BoundNetLog& net_log, |
159 base::WeakPtr<SpdySession>* spdy_session); | 166 base::WeakPtr<SpdySession>* spdy_session); |
160 | 167 |
161 // Creates a SpdySession and sets |spdy_session| to point to it. Returns OK | 168 // Creates a SpdySession and sets |spdy_session| to point to it. Returns OK |
162 // if the associated SSL certificate is valid for |origin_url_|, or if this | 169 // if the associated SSL certificate is valid for |origin_url_|, or if this |
163 // requirement does not apply because the Job is not a SPDY alternate job. | 170 // requirement does not apply because the Job is not a SPDY alternative job. |
164 // Returns the appropriate error code otherwise, in which case | 171 // Returns the appropriate error code otherwise, in which case |
165 // |spdy_session| should not be used. | 172 // |spdy_session| should not be used. |
166 int CreateAvailableSessionFromSocket( | 173 int CreateAvailableSessionFromSocket( |
167 const SpdySessionKey& key, | 174 const SpdySessionKey& key, |
168 scoped_ptr<ClientSocketHandle> connection, | 175 scoped_ptr<ClientSocketHandle> connection, |
169 const BoundNetLog& net_log, | 176 const BoundNetLog& net_log, |
170 int certificate_error_code, | 177 int certificate_error_code, |
171 bool is_secure, | 178 bool is_secure, |
172 base::WeakPtr<SpdySession>* spdy_session); | 179 base::WeakPtr<SpdySession>* spdy_session); |
173 | 180 |
174 private: | 181 private: |
175 // Returns OK if |spdy_session| has an associated SSL certificate with is | 182 // Returns OK if |spdy_session| has an associated SSL certificate with is |
176 // valid for |origin_url_|, or if this requirement does not apply because | 183 // valid for |origin_url_|, or if this requirement does not apply because |
177 // the Job is not a SPDY alternate job, or if |spdy_session| is null. | 184 // the Job is not a SPDY alternative job, or if |spdy_session| is null. |
178 // Returns appropriate error code otherwise. | 185 // Returns appropriate error code otherwise. |
179 int CheckAlternativeServiceValidityForOrigin( | 186 int CheckAlternativeServiceValidityForOrigin( |
180 base::WeakPtr<SpdySession> spdy_session); | 187 base::WeakPtr<SpdySession> spdy_session); |
181 | 188 |
182 SpdySessionPool* const spdy_session_pool_; | 189 SpdySessionPool* const spdy_session_pool_; |
183 const GURL origin_url_; | 190 const GURL origin_url_; |
184 const bool is_spdy_alternate_; | 191 const bool is_spdy_alternative_; |
185 }; | 192 }; |
186 | 193 |
187 void OnStreamReadyCallback(); | 194 void OnStreamReadyCallback(); |
188 void OnWebSocketHandshakeStreamReadyCallback(); | 195 void OnWebSocketHandshakeStreamReadyCallback(); |
189 // This callback function is called when a new SPDY session is created. | 196 // This callback function is called when a new SPDY session is created. |
190 void OnNewSpdySessionReadyCallback(); | 197 void OnNewSpdySessionReadyCallback(); |
191 void OnStreamFailedCallback(int result); | 198 void OnStreamFailedCallback(int result); |
192 void OnCertificateErrorCallback(int result, const SSLInfo& ssl_info); | 199 void OnCertificateErrorCallback(int result, const SSLInfo& ssl_info); |
193 void OnNeedsProxyAuthCallback(const HttpResponseInfo& response_info, | 200 void OnNeedsProxyAuthCallback(const HttpResponseInfo& response_info, |
194 HttpAuthController* auth_controller); | 201 HttpAuthController* auth_controller); |
(...skipping 29 matching lines...) Expand all Loading... |
224 int SetSpdyHttpStream(base::WeakPtr<SpdySession> session, bool direct); | 231 int SetSpdyHttpStream(base::WeakPtr<SpdySession> session, bool direct); |
225 | 232 |
226 // Returns to STATE_INIT_CONNECTION and resets some state. | 233 // Returns to STATE_INIT_CONNECTION and resets some state. |
227 void ReturnToStateInitConnection(bool close_connection); | 234 void ReturnToStateInitConnection(bool close_connection); |
228 | 235 |
229 // Set the motivation for this request onto the underlying socket. | 236 // Set the motivation for this request onto the underlying socket. |
230 void SetSocketMotivation(); | 237 void SetSocketMotivation(); |
231 | 238 |
232 bool IsHttpsProxyAndHttpUrl() const; | 239 bool IsHttpsProxyAndHttpUrl() const; |
233 | 240 |
234 // Returns true iff this Job is an alternate, that is, iff MarkAsAlternate has | 241 // Is this a SPDY or QUIC alternative Job? |
235 // been called. | 242 bool IsSpdyAlternative() const; |
236 bool IsAlternate() const; | 243 bool IsQuicAlternative() const; |
237 | |
238 // Returns true if this Job is a SPDY alternate job. | |
239 bool IsSpdyAlternate() const; | |
240 | 244 |
241 // Sets several fields of |ssl_config| for |server| based on the proxy info | 245 // Sets several fields of |ssl_config| for |server| based on the proxy info |
242 // and other factors. | 246 // and other factors. |
243 void InitSSLConfig(const HostPortPair& server, | 247 void InitSSLConfig(const HostPortPair& server, |
244 SSLConfig* ssl_config, | 248 SSLConfig* ssl_config, |
245 bool is_proxy) const; | 249 bool is_proxy) const; |
246 | 250 |
247 // Retrieve SSLInfo from our SSL Socket. | 251 // Retrieve SSLInfo from our SSL Socket. |
248 // This must only be called when we are using an SSLSocket. | 252 // This must only be called when we are using an SSLSocket. |
249 // After calling, the caller can use ssl_info_. | 253 // After calling, the caller can use ssl_info_. |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
312 SSLInfo ssl_info_; | 316 SSLInfo ssl_info_; |
313 | 317 |
314 // The server we are trying to reach, could be that of the origin or of the | 318 // The server we are trying to reach, could be that of the origin or of the |
315 // alternative service. | 319 // alternative service. |
316 HostPortPair server_; | 320 HostPortPair server_; |
317 | 321 |
318 // The origin url we're trying to reach. This url may be different from the | 322 // The origin url we're trying to reach. This url may be different from the |
319 // original request when host mapping rules are set-up. | 323 // original request when host mapping rules are set-up. |
320 GURL origin_url_; | 324 GURL origin_url_; |
321 | 325 |
322 // AlternateProtocol for this job if this is an alternate job. | 326 // AlternativeService for this Job if this is an alternative Job. |
323 AlternativeService alternative_service_; | 327 const AlternativeService alternative_service_; |
324 | 328 |
325 // AlternateProtocol for the other job if this is not an alternate job. | 329 // AlternativeService for the other Job if this is not an alternative Job. |
326 AlternativeService other_job_alternative_service_; | 330 AlternativeService other_job_alternative_service_; |
327 | 331 |
328 // This is the Job we're dependent on. It will notify us if/when it's OK to | 332 // This is the Job we're dependent on. It will notify us if/when it's OK to |
329 // proceed. | 333 // proceed. |
330 Job* blocking_job_; | 334 Job* blocking_job_; |
331 | 335 |
332 // |waiting_job_| is a Job waiting to see if |this| can reuse a connection. | 336 // |waiting_job_| is a Job waiting to see if |this| can reuse a connection. |
333 // If |this| is unable to do so, we'll notify |waiting_job_| that it's ok to | 337 // If |this| is unable to do so, we'll notify |waiting_job_| that it's ok to |
334 // proceed and then race the two Jobs. | 338 // proceed and then race the two Jobs. |
335 Job* waiting_job_; | 339 Job* waiting_job_; |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
388 JobStatus other_job_status_; | 392 JobStatus other_job_status_; |
389 | 393 |
390 base::WeakPtrFactory<Job> ptr_factory_; | 394 base::WeakPtrFactory<Job> ptr_factory_; |
391 | 395 |
392 DISALLOW_COPY_AND_ASSIGN(Job); | 396 DISALLOW_COPY_AND_ASSIGN(Job); |
393 }; | 397 }; |
394 | 398 |
395 } // namespace net | 399 } // namespace net |
396 | 400 |
397 #endif // NET_HTTP_HTTP_STREAM_FACTORY_IMPL_JOB_H_ | 401 #endif // NET_HTTP_HTTP_STREAM_FACTORY_IMPL_JOB_H_ |
OLD | NEW |