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 #include "net/http/http_stream_factory_impl.h" | 5 #include "net/http/http_stream_factory_impl.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
(...skipping 168 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
179 | 179 |
180 if (!session_->params().use_alternate_protocols) | 180 if (!session_->params().use_alternate_protocols) |
181 return kNoAlternativeService; | 181 return kNoAlternativeService; |
182 | 182 |
183 if (original_url.SchemeIs("ftp")) | 183 if (original_url.SchemeIs("ftp")) |
184 return kNoAlternativeService; | 184 return kNoAlternativeService; |
185 | 185 |
186 HostPortPair origin = HostPortPair::FromURL(original_url); | 186 HostPortPair origin = HostPortPair::FromURL(original_url); |
187 HttpServerProperties& http_server_properties = | 187 HttpServerProperties& http_server_properties = |
188 *session_->http_server_properties(); | 188 *session_->http_server_properties(); |
189 const AlternateProtocolInfo alternate = | 189 const AlternativeService alternative_service = |
190 http_server_properties.GetAlternateProtocol(origin); | 190 http_server_properties.GetAlternativeService(origin); |
191 | 191 |
192 if (alternate.protocol == UNINITIALIZED_ALTERNATE_PROTOCOL) | 192 if (alternative_service.protocol == UNINITIALIZED_ALTERNATE_PROTOCOL) |
193 return kNoAlternativeService; | 193 return kNoAlternativeService; |
194 const AlternativeService alternative_service(alternate.protocol, | 194 // TODO(bnc): Make sure that callers connect to the specified host, and that |
195 origin.host(), alternate.port); | 195 // certificate requirements are enforced. Then remove the following two |
| 196 // lines. |
| 197 if (alternative_service.host != origin.host()) |
| 198 return kNoAlternativeService; |
196 if (http_server_properties.IsAlternativeServiceBroken(alternative_service)) { | 199 if (http_server_properties.IsAlternativeServiceBroken(alternative_service)) { |
197 HistogramAlternateProtocolUsage(ALTERNATE_PROTOCOL_USAGE_BROKEN); | 200 HistogramAlternateProtocolUsage(ALTERNATE_PROTOCOL_USAGE_BROKEN); |
198 return kNoAlternativeService; | 201 return kNoAlternativeService; |
199 } | 202 } |
200 if (!IsAlternateProtocolValid(alternate.protocol)) { | 203 if (!IsAlternateProtocolValid(alternative_service.protocol)) { |
201 NOTREACHED(); | 204 NOTREACHED(); |
202 return kNoAlternativeService; | 205 return kNoAlternativeService; |
203 } | 206 } |
204 | 207 |
205 // Some shared unix systems may have user home directories (like | 208 // Some shared unix systems may have user home directories (like |
206 // http://foo.com/~mike) which allow users to emit headers. This is a bad | 209 // http://foo.com/~mike) which allow users to emit headers. This is a bad |
207 // idea already, but with Alternate-Protocol, it provides the ability for a | 210 // idea already, but with Alternate-Protocol, it provides the ability for a |
208 // single user on a multi-user system to hijack the alternate protocol. | 211 // single user on a multi-user system to hijack the alternate protocol. |
209 // These systems also enforce ports <1024 as restricted ports. So don't | 212 // These systems also enforce ports <1024 as restricted ports. So don't |
210 // allow protocol upgrades to user-controllable ports. | 213 // allow protocol upgrades to user-controllable ports. |
211 const int kUnrestrictedPort = 1024; | 214 const int kUnrestrictedPort = 1024; |
212 if (!session_->params().enable_user_alternate_protocol_ports && | 215 if (!session_->params().enable_user_alternate_protocol_ports && |
213 (alternate.port >= kUnrestrictedPort && | 216 (alternative_service.port >= kUnrestrictedPort && |
214 origin.port() < kUnrestrictedPort)) | 217 origin.port() < kUnrestrictedPort)) |
215 return kNoAlternativeService; | 218 return kNoAlternativeService; |
216 | 219 |
217 origin.set_port(alternate.port); | 220 origin.set_port(alternative_service.port); |
218 if (alternate.protocol >= NPN_SPDY_MINIMUM_VERSION && | 221 if (alternative_service.protocol >= NPN_SPDY_MINIMUM_VERSION && |
219 alternate.protocol <= NPN_SPDY_MAXIMUM_VERSION) { | 222 alternative_service.protocol <= NPN_SPDY_MAXIMUM_VERSION) { |
220 if (!HttpStreamFactory::spdy_enabled()) | 223 if (!HttpStreamFactory::spdy_enabled()) |
221 return kNoAlternativeService; | 224 return kNoAlternativeService; |
222 | 225 |
223 if (session_->HasSpdyExclusion(origin)) | 226 if (session_->HasSpdyExclusion(origin)) |
224 return kNoAlternativeService; | 227 return kNoAlternativeService; |
225 | 228 |
226 *alternate_url = UpgradeUrlToHttps(original_url, alternate.port); | 229 *alternate_url = UpgradeUrlToHttps(original_url, alternative_service.port); |
227 } else { | 230 } else { |
228 DCHECK_EQ(QUIC, alternate.protocol); | 231 DCHECK_EQ(QUIC, alternative_service.protocol); |
229 if (!session_->params().enable_quic) | 232 if (!session_->params().enable_quic) |
230 return kNoAlternativeService; | 233 return kNoAlternativeService; |
231 | 234 |
232 // TODO(rch): Figure out how to make QUIC iteract with PAC | 235 // TODO(rch): Figure out how to make QUIC iteract with PAC |
233 // scripts. By not re-writing the URL, we will query the PAC script | 236 // scripts. By not re-writing the URL, we will query the PAC script |
234 // for the proxy to use to reach the original URL via TCP. But | 237 // for the proxy to use to reach the original URL via TCP. But |
235 // the alternate request will be going via UDP to a different port. | 238 // the alternate request will be going via UDP to a different port. |
236 *alternate_url = original_url; | 239 *alternate_url = original_url; |
237 } | 240 } |
238 return AlternativeService(alternate.protocol, origin.host(), alternate.port); | 241 return alternative_service; |
239 } | 242 } |
240 | 243 |
241 void HttpStreamFactoryImpl::OrphanJob(Job* job, const Request* request) { | 244 void HttpStreamFactoryImpl::OrphanJob(Job* job, const Request* request) { |
242 DCHECK(ContainsKey(request_map_, job)); | 245 DCHECK(ContainsKey(request_map_, job)); |
243 DCHECK_EQ(request_map_[job], request); | 246 DCHECK_EQ(request_map_[job], request); |
244 DCHECK(!ContainsKey(orphaned_job_set_, job)); | 247 DCHECK(!ContainsKey(orphaned_job_set_, job)); |
245 | 248 |
246 request_map_.erase(job); | 249 request_map_.erase(job); |
247 | 250 |
248 orphaned_job_set_.insert(job); | 251 orphaned_job_set_.insert(job); |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
297 delete job; | 300 delete job; |
298 } | 301 } |
299 | 302 |
300 void HttpStreamFactoryImpl::OnPreconnectsComplete(const Job* job) { | 303 void HttpStreamFactoryImpl::OnPreconnectsComplete(const Job* job) { |
301 preconnect_job_set_.erase(job); | 304 preconnect_job_set_.erase(job); |
302 delete job; | 305 delete job; |
303 OnPreconnectsCompleteInternal(); | 306 OnPreconnectsCompleteInternal(); |
304 } | 307 } |
305 | 308 |
306 } // namespace net | 309 } // namespace net |
OLD | NEW |