Process Alternative Service headers in net::BidirectionalStream

net/http/bidirectional_stream.cc

 // Copyright 2015 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/bidirectional_stream.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/thread_task_runner_handle.h"
 #include "base/time/time.h"
 #include "base/timer/timer.h"
 #include "net/base/load_flags.h"
 #include "net/base/net_errors.h"
 #include "net/http/bidirectional_stream_request_info.h"
 #include "net/http/http_network_session.h"
+#include "net/http/http_response_headers.h"
 #include "net/http/http_stream.h"
+#include "net/spdy/spdy_http_utils.h"
 #include "net/ssl/ssl_cert_request_info.h"
 #include "net/ssl/ssl_config.h"
 #include "url/gurl.h"
 
 namespace net {
 
 BidirectionalStream::Delegate::Delegate() {}
 
 BidirectionalStream::Delegate::~Delegate() {}
 
 BidirectionalStream::BidirectionalStream(
     scoped_ptr<BidirectionalStreamRequestInfo> request_info,
     HttpNetworkSession* session,
     Delegate* delegate)
     : BidirectionalStream(std::move(request_info),
                           session,
                           delegate,
                           make_scoped_ptr(new base::Timer(false, false))) {}
 
 BidirectionalStream::BidirectionalStream(
     scoped_ptr<BidirectionalStreamRequestInfo> request_info,
     HttpNetworkSession* session,
     Delegate* delegate,
     scoped_ptr<base::Timer> timer)
     : request_info_(std::move(request_info)),
       net_log_(BoundNetLog::Make(session->net_log(),
                                  NetLog::SOURCE_BIDIRECTIONAL_STREAM)),
+      session_(session),
       delegate_(delegate),
       timer_(std::move(timer)) {
   DCHECK(delegate_);
   DCHECK(request_info_);
 
   SSLConfig server_ssl_config;
   session->ssl_config_service()->GetSSLConfig(&server_ssl_config);
   session->GetAlpnProtos(&server_ssl_config.alpn_protos);
   session->GetNpnProtos(&server_ssl_config.npn_protos);
 
@@ skipping 66 matching lines @@
 
   return stream_job_->GetTotalSentBytes();
 }
 
 void BidirectionalStream::OnHeadersSent() {
   delegate_->OnHeadersSent();
 }
 
 void BidirectionalStream::OnHeadersReceived(
     const SpdyHeaderBlock& response_headers) {
+  HttpResponseInfo response_info;
+  if (!SpdyHeadersToHttpResponse(response_headers, HTTP2, &response_info)) {
+    DLOG(WARNING) << "Invalid headers";
+    delegate_->OnFailed(ERR_FAILED);
+    return;
+  }
+
+  session_->http_stream_factory()->ProcessAlternativeServices(
+      session_, response_info.headers.get(),
+      HostPortPair::FromURL(request_info_->url));
   delegate_->OnHeadersReceived(response_headers);
 }
 
 void BidirectionalStream::OnDataRead(int bytes_read) {
   delegate_->OnDataRead(bytes_read);
 }
 
 void BidirectionalStream::OnDataSent() {
   delegate_->OnDataSent();
 }
@@ skipping 73 matching lines @@
     const ProxyInfo& used_proxy_info,
     HttpStream* stream) {
   DCHECK(stream_request_);
 
   delegate_->OnFailed(ERR_HTTPS_PROXY_TUNNEL_RESPONSE);
 }
 
 void BidirectionalStream::OnQuicBroken() {}
 
 }  // namespace net