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

content/browser/frame_host/render_frame_host_impl.cc

 // Copyright 2013 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/browser/frame_host/render_frame_host_impl.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/containers/hash_tables.h"
@@ skipping 1901 matching lines @@
 
 void RenderFrameHostImpl::NavigateToInterstitialURL(const GURL& data_url) {
   DCHECK(data_url.SchemeIs(url::kDataScheme));
   CommonNavigationParams common_params(
       data_url, Referrer(), ui::PAGE_TRANSITION_LINK,
       FrameMsg_Navigate_Type::NORMAL, false, false, base::TimeTicks::Now(),
       FrameMsg_UILoadMetricsReportType::NO_REPORT, GURL(), GURL(), LOFI_OFF,
       base::TimeTicks::Now());
   if (IsBrowserSideNavigationEnabled()) {
     CommitNavigation(nullptr, nullptr, common_params,
-                     RequestNavigationParams());
+                     RequestNavigationParams(), mojo::ScopedDataPipeConsumerHandle());
   } else {
     Navigate(common_params, StartNavigationParams(), RequestNavigationParams());
   }
 }
 
 void RenderFrameHostImpl::OpenURL(const FrameHostMsg_OpenURL_Params& params,
                                   SiteInstance* source_site_instance) {
   GURL validated_url(params.url);
   GetProcess()->FilterURL(false, &validated_url);
 
@@ skipping 109 matching lines @@
     render_view_host_->GetWidget()->delegate()->RendererUnresponsive(
         render_view_host_->GetWidget());
   }
 }
 
 // PlzNavigate
 void RenderFrameHostImpl::CommitNavigation(
     ResourceResponse* response,
     scoped_ptr<StreamHandle> body,
     const CommonNavigationParams& common_params,
-    const RequestNavigationParams& request_params) {
-  DCHECK((response && body.get()) ||
+    const RequestNavigationParams& request_params,
+    mojo::ScopedDataPipeConsumerHandle data_consumer_handle = mojo::ScopedDataPipeConsumerHandle()) {
+  DCHECK((response && (body.get() || data_consumer_handle.is_valid())) ||
           !ShouldMakeNetworkRequestForURL(common_params.url));
   UpdatePermissionsForNavigation(common_params, request_params);
 
   // Get back to a clean state, in case we start a new navigation without
   // completing a RFH swap or unload handler.
   SetState(RenderFrameHostImpl::STATE_DEFAULT);
 
+  // SENDS THE CONSUMER DATA HANDLE TO THE RENDERER VIA MOJO
+  // TODO: OPTIMIZE THIS
+  // - SEE IF THERE'S A WAY TO BIND THE SERVER EARLIER THEN THIS. Is there a
+  // notification received by the browser that a RenderFrame was created on the renderer?
+  // - POSSIBLY STORE THE REFERENCE SOMEWHERE... IS THAT EVEN NEEDED OR IS MOJO
+  // SMART ABOUT CACHING BOUND REMOTE REFERENCES?
+  int32_t current_commit_id = -1;
+  if (data_consumer_handle.is_valid()) {
+    static int32_t commit_id = 0;
+    DataPipeConsumerHandleReceiverPtr consumer_receiver;
+    GetServiceRegistry()->ConnectToRemoteService(mojo::GetProxy(&consumer_receiver));
+    current_commit_id = ++commit_id;
+    consumer_receiver->ReceiveDataPipeConsumerHandle(
+        std::move(data_consumer_handle), current_commit_id);
+  }
+
   const GURL body_url = body.get() ? body->GetURL() : GURL();
   const ResourceResponseHead head = response ?
       response->head : ResourceResponseHead();
   Send(new FrameMsg_CommitNavigation(routing_id_, head, body_url, common_params,
-                                     request_params));
+                                     request_params, current_commit_id));
 
   // TODO(clamy): Release the stream handle once the renderer has finished
   // reading it.
   stream_handle_ = std::move(body);
 
   // When navigating to a Javascript url, no commit is expected from the
   // RenderFrameHost, nor should the throbber start.
   if (!common_params.url.SchemeIs(url::kJavaScriptScheme)) {
     pending_commit_ = true;
     is_loading_ = true;
@@ skipping 477 matching lines @@
   *dst = src;
 
   if (src.routing_id != -1)
     dst->tree_id = RoutingIDToAXTreeID(src.routing_id);
 
   if (src.parent_routing_id != -1)
     dst->parent_tree_id = RoutingIDToAXTreeID(src.parent_routing_id);
 }
 
 }  // namespace content