Implement multiple alternative services per origin.

net/http/http_stream_factory_impl.cc

 // 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.
 
 #include "net/http/http_stream_factory_impl.h"
 
 #include <string>
 
 #include "base/logging.h"
 #include "base/stl_util.h"
@@ skipping 75 matching lines @@
     const BoundNetLog& net_log) {
   Request* request = new Request(request_info.url,
                                  this,
                                  delegate,
                                  websocket_handshake_stream_create_helper,
                                  net_log);
   Job* job = new Job(this, session_, request_info, priority, server_ssl_config,
                      proxy_ssl_config, net_log.net_log());
   request->AttachJob(job);
 
-  AlternativeService alternative_service =
-      GetAlternativeServiceFor(request_info.url);
-  if (alternative_service.protocol != UNINITIALIZED_ALTERNATE_PROTOCOL) {
+  const AlternativeServiceVector alternative_service_vector =
+      GetAlternativeServicesFor(request_info.url);
+  if (!alternative_service_vector.empty()) {
+    // TODO(bnc): Pass on multiple alternative services to Job.
+    const AlternativeService& alternative_service =
+        alternative_service_vector[0];
     // Never share connection with other jobs for FTP requests.
     DCHECK(!request_info.url.SchemeIs("ftp"));
 
     Job* alternative_job =
         new Job(this, session_, request_info, priority, server_ssl_config,
                 proxy_ssl_config, alternative_service, net_log.net_log());
     request->AttachJob(alternative_job);
 
     job->WaitFor(alternative_job);
     // Make sure to wait until we call WaitFor(), before starting
     // |alternative_job|, otherwise |alternative_job| will not notify |job|
     // appropriately.
     alternative_job->Start(request);
   }
 
   // Even if |alternative_job| has already finished, it will not have notified
   // the request yet, since we defer that to the next iteration of the
   // MessageLoop, so starting |job| is always safe.
   job->Start(request);
   return request;
 }
 
 void HttpStreamFactoryImpl::PreconnectStreams(
     int num_streams,
     const HttpRequestInfo& request_info,
     RequestPriority priority,
     const SSLConfig& server_ssl_config,
     const SSLConfig& proxy_ssl_config) {
   DCHECK(!for_websockets_);
-  AlternativeService alternative_service =
-      GetAlternativeServiceFor(request_info.url);
-  Job* job =
-      new Job(this, session_, request_info, priority, server_ssl_config,
-              proxy_ssl_config, alternative_service, session_->net_log());
+  AlternativeServiceVector alternative_service_vector =
+      GetAlternativeServicesFor(request_info.url);
+  Job* job;
+  if (alternative_service_vector.empty()) {
+    job = new Job(this, session_, request_info, priority, server_ssl_config,
+                  proxy_ssl_config, session_->net_log());
+  } else {
+    // TODO(bnc): Pass on multiple alternative services to Job.
+    const AlternativeService& alternative_service =
+        alternative_service_vector[0];
+    job = new Job(this, session_, request_info, priority, server_ssl_config,
+                  proxy_ssl_config, alternative_service, session_->net_log());
+  }

[Ryan Hamilton, 2015/06/29 21:15:53]

nit: instead of having an if with two bodies that create Job, it might be
simpler to just have a AlternativeService alternative_service;
local variable which is initialize to be empty and only assigned to if the
vector is non-empty.

[Bence, 2015/06/30 19:16:14]

Done.

   preconnect_job_set_.insert(job);
   job->Preconnect(num_streams);
 }
 
 const HostMappingRules* HttpStreamFactoryImpl::GetHostMappingRules() const {
   return session_->params().host_mapping_rules;
 }
 
-AlternativeService HttpStreamFactoryImpl::GetAlternativeServiceFor(
+AlternativeServiceVector HttpStreamFactoryImpl::GetAlternativeServicesFor(
     const GURL& original_url) {
-  const AlternativeService kNoAlternativeService;
-
   if (!session_->params().use_alternate_protocols)
-    return kNoAlternativeService;
+    return AlternativeServiceVector();
 
   if (original_url.SchemeIs("ftp"))
-    return kNoAlternativeService;
+    return AlternativeServiceVector();
 
   HostPortPair origin = HostPortPair::FromURL(original_url);
   HttpServerProperties& http_server_properties =
       *session_->http_server_properties();
-  const AlternativeService alternative_service =
-      http_server_properties.GetAlternativeService(origin);
+  const AlternativeServiceVector alternative_service_vector =
+      http_server_properties.GetAlternativeServices(origin);
+  if (alternative_service_vector.empty())
+    return AlternativeServiceVector();
 
-  if (alternative_service.protocol == UNINITIALIZED_ALTERNATE_PROTOCOL)
-    return kNoAlternativeService;
-  if (http_server_properties.IsAlternativeServiceBroken(alternative_service)) {
-    HistogramAlternateProtocolUsage(ALTERNATE_PROTOCOL_USAGE_BROKEN);
-    return kNoAlternativeService;
+  AlternativeServiceVector enabled_alternative_service_vector;
+  for (const AlternativeService& alternative_service :
+       alternative_service_vector) {
+    DCHECK(IsAlternateProtocolValid(alternative_service.protocol));
+    if (http_server_properties.IsAlternativeServiceBroken(
+            alternative_service)) {
+      HistogramAlternateProtocolUsage(ALTERNATE_PROTOCOL_USAGE_BROKEN);
+      continue;
+    }
+
+    // Some shared unix systems may have user home directories (like
+    // http://foo.com/~mike) which allow users to emit headers.  This is a bad
+    // idea already, but with Alternate-Protocol, it provides the ability for a
+    // single user on a multi-user system to hijack the alternate protocol.
+    // These systems also enforce ports <1024 as restricted ports.  So don't
+    // allow protocol upgrades to user-controllable ports.
+    const int kUnrestrictedPort = 1024;
+    if (!session_->params().enable_user_alternate_protocol_ports &&
+        (alternative_service.port >= kUnrestrictedPort &&
+         origin.port() < kUnrestrictedPort))
+      continue;
+
+    origin.set_port(alternative_service.port);
+    if (alternative_service.protocol >= NPN_SPDY_MINIMUM_VERSION &&
+        alternative_service.protocol <= NPN_SPDY_MAXIMUM_VERSION) {
+      if (!HttpStreamFactory::spdy_enabled())
+        continue;
+
+      if (session_->HasSpdyExclusion(origin))
+        continue;
+
+      enabled_alternative_service_vector.push_back(alternative_service);
+      continue;
+    }
+
+    DCHECK_EQ(QUIC, alternative_service.protocol);
+    if (!session_->params().enable_quic)
+      continue;
+
+    if (session_->quic_stream_factory()->IsQuicDisabled(origin.port()))
+      continue;
+
+    if (session_->params().disable_insecure_quic &&
+        !original_url.SchemeIs("https")) {
+      continue;
+    }
+
+    enabled_alternative_service_vector.push_back(alternative_service);
   }
-  if (!IsAlternateProtocolValid(alternative_service.protocol)) {
-    NOTREACHED();
-    return kNoAlternativeService;
-  }
-
-  // Some shared unix systems may have user home directories (like
-  // http://foo.com/~mike) which allow users to emit headers.  This is a bad
-  // idea already, but with Alternate-Protocol, it provides the ability for a
-  // single user on a multi-user system to hijack the alternate protocol.
-  // These systems also enforce ports <1024 as restricted ports.  So don't
-  // allow protocol upgrades to user-controllable ports.
-  const int kUnrestrictedPort = 1024;
-  if (!session_->params().enable_user_alternate_protocol_ports &&
-      (alternative_service.port >= kUnrestrictedPort &&
-       origin.port() < kUnrestrictedPort))
-    return kNoAlternativeService;
-
-  origin.set_port(alternative_service.port);
-  if (alternative_service.protocol >= NPN_SPDY_MINIMUM_VERSION &&
-      alternative_service.protocol <= NPN_SPDY_MAXIMUM_VERSION) {
-    if (!HttpStreamFactory::spdy_enabled())
-      return kNoAlternativeService;
-
-    if (session_->HasSpdyExclusion(origin))
-      return kNoAlternativeService;
-
-    return alternative_service;
-  }
-
-  DCHECK_EQ(QUIC, alternative_service.protocol);
-  if (!session_->params().enable_quic)
-    return kNoAlternativeService;
-
-  if (session_->quic_stream_factory()->IsQuicDisabled(origin.port()))
-    return kNoAlternativeService;
-
-  if (session_->params().disable_insecure_quic &&
-      !original_url.SchemeIs("https")) {
-    return kNoAlternativeService;
-  }
-
-  return alternative_service;
+  return enabled_alternative_service_vector;
 }
 
 void HttpStreamFactoryImpl::OrphanJob(Job* job, const Request* request) {
   DCHECK(ContainsKey(request_map_, job));
   DCHECK_EQ(request_map_[job], request);
   DCHECK(!ContainsKey(orphaned_job_set_, job));
 
   request_map_.erase(job);
 
   orphaned_job_set_.insert(job);
@@ skipping 48 matching lines @@
   delete job;
 }
 
 void HttpStreamFactoryImpl::OnPreconnectsComplete(const Job* job) {
   preconnect_job_set_.erase(job);
   delete job;
   OnPreconnectsCompleteInternal();
 }
 
 }  // namespace net