| 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_server_properties_impl.h" | 5 #include "net/http/http_server_properties_impl.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
| (...skipping 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 161 void HttpServerPropertiesImpl::Clear() { | 161 void HttpServerPropertiesImpl::Clear() { |
| 162 DCHECK(CalledOnValidThread()); | 162 DCHECK(CalledOnValidThread()); |
| 163 spdy_servers_map_.Clear(); | 163 spdy_servers_map_.Clear(); |
| 164 alternate_protocol_map_.Clear(); | 164 alternate_protocol_map_.Clear(); |
| 165 canonical_host_to_origin_map_.clear(); | 165 canonical_host_to_origin_map_.clear(); |
| 166 spdy_settings_map_.Clear(); | 166 spdy_settings_map_.Clear(); |
| 167 supports_quic_map_.clear(); | 167 supports_quic_map_.clear(); |
| 168 server_network_stats_map_.Clear(); | 168 server_network_stats_map_.Clear(); |
| 169 } | 169 } |
| 170 | 170 |
| 171 bool HttpServerPropertiesImpl::SupportsSpdy( | 171 bool HttpServerPropertiesImpl::SupportsRequestPriority( |
| 172 const HostPortPair& host_port_pair) { | 172 const HostPortPair& host_port_pair) { |
| 173 DCHECK(CalledOnValidThread()); | 173 DCHECK(CalledOnValidThread()); |
| 174 if (host_port_pair.host().empty()) | 174 if (host_port_pair.host().empty()) |
| 175 return false; | 175 return false; |
| 176 | 176 |
| 177 SpdyServerHostPortMap::iterator spdy_host_port = | 177 SpdyServerHostPortMap::iterator spdy_host_port = |
| 178 spdy_servers_map_.Get(host_port_pair.ToString()); | 178 spdy_servers_map_.Get(host_port_pair.ToString()); |
| 179 if (spdy_host_port != spdy_servers_map_.end()) | 179 if (spdy_host_port != spdy_servers_map_.end() && spdy_host_port->second) |
| 180 return spdy_host_port->second; | 180 return true; |
| 181 return false; | 181 |
| 182 if (!HasAlternateProtocol(host_port_pair)) |
| 183 return false; |
| 184 |
| 185 AlternateProtocolInfo info = GetAlternateProtocol(host_port_pair); |
| 186 return info.protocol == QUIC; |
| 182 } | 187 } |
| 183 | 188 |
| 184 void HttpServerPropertiesImpl::SetSupportsSpdy( | 189 void HttpServerPropertiesImpl::SetSupportsSpdy( |
| 185 const HostPortPair& host_port_pair, | 190 const HostPortPair& host_port_pair, |
| 186 bool support_spdy) { | 191 bool support_spdy) { |
| 187 DCHECK(CalledOnValidThread()); | 192 DCHECK(CalledOnValidThread()); |
| 188 if (host_port_pair.host().empty()) | 193 if (host_port_pair.host().empty()) |
| 189 return; | 194 return; |
| 190 | 195 |
| 191 SpdyServerHostPortMap::iterator spdy_host_port = | 196 SpdyServerHostPortMap::iterator spdy_host_port = |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 227 const HostPortPair& server) { | 232 const HostPortPair& server) { |
| 228 if (g_forced_alternate_protocol) | 233 if (g_forced_alternate_protocol) |
| 229 return true; | 234 return true; |
| 230 AlternateProtocolMap::const_iterator it = | 235 AlternateProtocolMap::const_iterator it = |
| 231 GetAlternateProtocolIterator(server); | 236 GetAlternateProtocolIterator(server); |
| 232 return it != alternate_protocol_map_.end() && | 237 return it != alternate_protocol_map_.end() && |
| 233 it->second.probability >= alternate_protocol_probability_threshold_; | 238 it->second.probability >= alternate_protocol_probability_threshold_; |
| 234 } | 239 } |
| 235 | 240 |
| 236 std::string HttpServerPropertiesImpl::GetCanonicalSuffix( | 241 std::string HttpServerPropertiesImpl::GetCanonicalSuffix( |
| 237 const HostPortPair& server) { | 242 const std::string& host) { |
| 238 // If this host ends with a canonical suffix, then return the canonical | 243 // If this host ends with a canonical suffix, then return the canonical |
| 239 // suffix. | 244 // suffix. |
| 240 for (size_t i = 0; i < canonical_suffixes_.size(); ++i) { | 245 for (size_t i = 0; i < canonical_suffixes_.size(); ++i) { |
| 241 std::string canonical_suffix = canonical_suffixes_[i]; | 246 std::string canonical_suffix = canonical_suffixes_[i]; |
| 242 if (EndsWith(server.host(), canonical_suffixes_[i], false)) { | 247 if (EndsWith(host, canonical_suffixes_[i], false)) { |
| 243 return canonical_suffix; | 248 return canonical_suffix; |
| 244 } | 249 } |
| 245 } | 250 } |
| 246 return std::string(); | 251 return std::string(); |
| 247 } | 252 } |
| 248 | 253 |
| 249 AlternateProtocolInfo | 254 AlternateProtocolInfo |
| 250 HttpServerPropertiesImpl::GetAlternateProtocol( | 255 HttpServerPropertiesImpl::GetAlternateProtocol( |
| 251 const HostPortPair& server) { | 256 const HostPortPair& server) { |
| 252 DCHECK(HasAlternateProtocol(server)); | 257 DCHECK(HasAlternateProtocol(server)); |
| (...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 334 BrokenAlternateProtocolEntry entry; | 339 BrokenAlternateProtocolEntry entry; |
| 335 entry.server = server; | 340 entry.server = server; |
| 336 entry.when = base::TimeTicks::Now() + delay * (1 << (count - 1)); | 341 entry.when = base::TimeTicks::Now() + delay * (1 << (count - 1)); |
| 337 broken_alternate_protocol_list_.push_back(entry); | 342 broken_alternate_protocol_list_.push_back(entry); |
| 338 | 343 |
| 339 // Do not leave this host as canonical so that we don't infer the other | 344 // Do not leave this host as canonical so that we don't infer the other |
| 340 // hosts are also broken without testing them first. | 345 // hosts are also broken without testing them first. |
| 341 RemoveCanonicalHost(server); | 346 RemoveCanonicalHost(server); |
| 342 | 347 |
| 343 // If this is the only entry in the list, schedule an expiration task. | 348 // If this is the only entry in the list, schedule an expiration task. |
| 344 // Otherwse it will be rescheduled automatically when the pending | 349 // Otherwise it will be rescheduled automatically when the pending task runs. |
| 345 // task runs. | |
| 346 if (broken_alternate_protocol_list_.size() == 1) { | 350 if (broken_alternate_protocol_list_.size() == 1) { |
| 347 ScheduleBrokenAlternateProtocolMappingsExpiration(); | 351 ScheduleBrokenAlternateProtocolMappingsExpiration(); |
| 348 } | 352 } |
| 349 } | 353 } |
| 350 | 354 |
| 351 bool HttpServerPropertiesImpl::WasAlternateProtocolRecentlyBroken( | 355 bool HttpServerPropertiesImpl::WasAlternateProtocolRecentlyBroken( |
| 352 const HostPortPair& server) { | 356 const HostPortPair& server) { |
| 353 return ContainsKey(broken_alternate_protocol_map_, server); | 357 return ContainsKey(broken_alternate_protocol_map_, server); |
| 354 } | 358 } |
| 355 | 359 |
| (...skipping 175 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 531 base::TimeDelta delay = when > now ? when - now : base::TimeDelta(); | 535 base::TimeDelta delay = when > now ? when - now : base::TimeDelta(); |
| 532 base::MessageLoop::current()->PostDelayedTask( | 536 base::MessageLoop::current()->PostDelayedTask( |
| 533 FROM_HERE, | 537 FROM_HERE, |
| 534 base::Bind( | 538 base::Bind( |
| 535 &HttpServerPropertiesImpl::ExpireBrokenAlternateProtocolMappings, | 539 &HttpServerPropertiesImpl::ExpireBrokenAlternateProtocolMappings, |
| 536 weak_ptr_factory_.GetWeakPtr()), | 540 weak_ptr_factory_.GetWeakPtr()), |
| 537 delay); | 541 delay); |
| 538 } | 542 } |
| 539 | 543 |
| 540 } // namespace net | 544 } // namespace net |
| OLD | NEW |