PROTOTYPE: PlzNavigate: use a Mojo data pipe to stream navigation data to the renderer.

content/child/web_url_loader_impl.cc

 // Copyright 2014 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 "content/child/web_url_loader_impl.h"
 
 #include <stdint.h>
 #include <algorithm>
 #include <string>
 #include <utility>
@@ skipping 271 matching lines @@
   blink::WebURLResponse::WebSecurityDetails webSecurityDetails(
       WebString::fromUTF8(protocol), WebString::fromUTF8(key_exchange),
       WebString::fromUTF8(cipher), WebString::fromUTF8(mac),
       ssl_status.cert_id, num_unknown_scts, num_invalid_scts, num_valid_scts);
 
   response->setSecurityDetails(webSecurityDetails);
 }
 
 }  // namespace
 
+StreamOverrideParameters::StreamOverrideParameters() : browser_request_id(-1) {}
+
+StreamOverrideParameters::~StreamOverrideParameters() {}
+
 // This inner class exists since the WebURLLoader may be deleted while inside a
 // call to WebURLLoaderClient.  Refcounting is to keep the context from being
 // deleted if it may have work to do after calling into the client.
 class WebURLLoaderImpl::Context : public base::RefCounted<Context> {
  public:
   using ReceivedData = RequestPeer::ReceivedData;
 
   Context(WebURLLoaderImpl* loader,
           ResourceDispatcher* resource_dispatcher,
           scoped_ptr<blink::WebTaskRunner> task_runner);
@@ skipping 233 matching lines @@
       GetRequestContextTypeForWebURLRequest(request);
   request_info.fetch_frame_type =
       GetRequestContextFrameTypeForWebURLRequest(request);
   request_info.extra_data = request.getExtraData();
   request_info.report_raw_headers = request.reportRawHeaders();
   request_info.loading_web_task_runner.reset(web_task_runner_->clone());
 
   scoped_refptr<ResourceRequestBody> request_body =
       GetRequestBodyForWebURLRequest(request).get();
 
-  // PlzNavigate: during navigation, the renderer should request a stream which
-  // contains the body of the response. The network request has already been
-  // made by the browser.
-  if (stream_override_.get()) {
-    CHECK(IsBrowserSideNavigationEnabled());
-    DCHECK(!sync_load_response);
-    DCHECK_NE(WebURLRequest::FrameTypeNone, request.getFrameType());
-    request_info.resource_body_stream_url = stream_override_->stream_url;
-  }
-
   if (sync_load_response) {
+    DCHECK(!stream_override_);
     resource_dispatcher_->StartSync(
         request_info, request_body.get(), sync_load_response);
     return;
   }
 
+  // PlzNavigate: during navigation, the browser should have sent a consumer
+  // handle for a Mojo data pipe along with the respective browser generated
+  // request id. The network request has already been made by the browser.
+  mojo::ScopedDataPipeConsumerHandle mojo_data_pipe_handle;
+  int browser_request_id = -1;
+  if (stream_override_) {
+    CHECK(IsBrowserSideNavigationEnabled());
+    DCHECK(!sync_load_response);
+    DCHECK_NE(WebURLRequest::FrameTypeNone, request.getFrameType());
+    DCHECK(stream_override_->mojo_handle.is_valid());
+    DCHECK_LT(stream_override_->browser_request_id, -1);
+    mojo_data_pipe_handle = std::move(stream_override_->mojo_handle);
+    browser_request_id = stream_override_->browser_request_id;
+  }
+
   request_id_ = resource_dispatcher_->StartAsync(
       request_info, request_body.get(),
-      make_scoped_ptr(new WebURLLoaderImpl::RequestPeerImpl(this)));
+      make_scoped_ptr(new WebURLLoaderImpl::RequestPeerImpl(this)),
+      std::move(mojo_data_pipe_handle), browser_request_id);
 }
 
 void WebURLLoaderImpl::Context::SetWebTaskRunner(
     scoped_ptr<blink::WebTaskRunner> web_task_runner) {
   web_task_runner_ = std::move(web_task_runner);
 }
 
 void WebURLLoaderImpl::Context::OnUploadProgress(uint64_t position,
                                                  uint64_t size) {
   if (client_)
@@ skipping 598 matching lines @@
     response->clearHTTPHeaderField(webStringName);
     while (response_headers->EnumerateHeader(&iterator, name, &value)) {
       response->addHTTPHeaderField(webStringName,
                                    WebString::fromLatin1(value));
     }
   }
   return true;
 }
 
 }  // namespace content