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/command_line.h"
@@ skipping 906 matching lines @@
 
 // Called when the renderer navigates.  For every frame loaded, we'll get this
 // notification containing parameters identifying the navigation.
 //
 // Subframes are identified by the page transition type.  For subframes loaded
 // as part of a wider page load, the page_id will be the same as for the top
 // level frame.  If the user explicitly requests a subframe navigation, we will
 // get a new page_id because we need to create a new navigation entry for that
 // action.
 void RenderFrameHostImpl::OnDidCommitProvisionalLoad(const IPC::Message& msg) {
+  LOG(ERROR)
+      << "RenderFrameHostImpl::OnDidCommitProvisionalLoad frame_tree_node_id: "
+      << frame_tree_node()->frame_tree_node_id();
   RenderProcessHost* process = GetProcess();
 
   // Read the parameters out of the IPC message directly to avoid making another
   // copy when we filter the URLs.
   base::PickleIterator iter(msg);
   FrameHostMsg_DidCommitProvisionalLoad_Params validated_params;
   if (!IPC::ParamTraits<FrameHostMsg_DidCommitProvisionalLoad_Params>::
       Read(&msg, &iter, &validated_params)) {
     bad_message::ReceivedBadMessage(
         process, bad_message::RFH_COMMIT_DESERIALIZATION_FAILED);
@@ skipping 1072 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(), "GET");
   if (IsBrowserSideNavigationEnabled()) {
-    CommitNavigation(nullptr, nullptr, common_params,
-                     RequestNavigationParams());
+    CommitNavigation(nullptr, common_params, RequestNavigationParams(),
+                     mojo::ScopedDataPipeConsumerHandle(), -1);
   } 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 107 matching lines @@
   // correctly while waiting for a response.
   if (is_waiting && dialog_was_suppressed) {
     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()) ||
-          !ShouldMakeNetworkRequestForURL(common_params.url));
+    const RequestNavigationParams& request_params,
+    // TODO(carlosk): these default parameters are a hack and has to go away.
+    mojo::ScopedDataPipeConsumerHandle data_consumer_handle =
+        mojo::ScopedDataPipeConsumerHandle(),
+    int request_id = -1) {
+  DCHECK((response && 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);
 
-  const GURL body_url = body.get() ? body->GetURL() : GURL();
+  // Sends the consumer data handle to the renderer via Mojo.
+  // TODO(carlosk): See if there's a way to bind the server earlier then this
+  // so that we don't have to wait for the binding to commit. Is there a
+  // notification received by the browser that a RenderFrame was created on the
+  // renderer?
+  // TODO(carlosk): possibly store the server 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), request_id, current_commit_id);
+  }
+
   const ResourceResponseHead head = response ?
       response->head : ResourceResponseHead();
-  Send(new FrameMsg_CommitNavigation(routing_id_, head, body_url, common_params,
-                                     request_params));
-
-  // TODO(clamy): Release the stream handle once the renderer has finished
-  // reading it.
-  stream_handle_ = std::move(body);
+  Send(new FrameMsg_CommitNavigation(routing_id_, head, GURL(), common_params,
+                                     request_params, current_commit_id));
 
   // When navigating to a Javascript url, no commit is expected from the
   // RenderFrameHost, nor should the throbber start. The NavigationRequest is
   // also not stored in the FrameTreeNode. Therefore do not reset it, as this
   // could cancel an existing pending navigation.
   if (!common_params.url.SchemeIs(url::kJavaScriptScheme)) {
     pending_commit_ = true;
     is_loading_ = true;
     frame_tree_node_->ResetNavigationRequest(true);
   }
@@ skipping 528 matching lines @@
   FrameTreeNode* focused_frame_tree_node = frame_tree_->GetFocusedFrame();
   if (!focused_frame_tree_node)
     return;
   RenderFrameHostImpl* focused_frame =
       focused_frame_tree_node->current_frame_host();
   DCHECK(focused_frame);
   dst->focused_tree_id = focused_frame->GetAXTreeID();
 }
 
 }  // namespace content