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

content/renderer/render_frame_impl.h

 // 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.
 
 #ifndef CONTENT_RENDERER_RENDER_FRAME_IMPL_H_
 #define CONTENT_RENDERER_RENDER_FRAME_IMPL_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <string>
 #include <vector>
 
 #include "base/files/file_path.h"
 #include "base/gtest_prod_util.h"
 #include "base/id_map.h"
 #include "base/macros.h"
 #include "base/memory/linked_ptr.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/observer_list.h"
 #include "base/process/process_handle.h"
 #include "build/build_config.h"
 #include "content/common/accessibility_mode_enums.h"
 #include "content/common/frame_message_enums.h"
 #include "content/common/mojo/service_registry_impl.h"
+#include "content/common/navigation_params.h"
 #include "content/public/common/console_message_level.h"
 #include "content/public/common/javascript_message_type.h"
 #include "content/public/common/referrer.h"
+#include "content/public/common/resource_response.h"
 #include "content/public/common/stop_find_action.h"
 #include "content/public/renderer/render_frame.h"
 #include "content/renderer/render_frame_proxy.h"
 #include "content/renderer/renderer_webcookiejar_impl.h"
 #include "ipc/ipc_message.h"
 #include "ipc/ipc_platform_file.h"
 #include "media/blink/webmediaplayer_delegate.h"
 #include "media/blink/webmediaplayer_params.h"
 #include "mojo/shell/public/interfaces/connector.mojom.h"
 #include "mojo/shell/public/interfaces/interface_provider.mojom.h"
@@ skipping 97 matching lines @@
 class RendererMediaSessionManager;
 class RendererPpapiHost;
 class RendererSurfaceViewManager;
 class RenderFrameObserver;
 class RenderViewImpl;
 class RenderWidget;
 class RenderWidgetFullscreenPepper;
 class ScreenOrientationDispatcher;
 class UserMediaClientImpl;
 class WakeLockDispatcher;
-struct CommonNavigationParams;
 struct CustomContextMenuContext;
 struct FrameReplicationState;
 struct NavigationParams;
-struct RequestNavigationParams;
-struct ResourceResponseHead;
 struct StartNavigationParams;
 struct StreamOverrideParameters;
 class VRDispatcher;
+class RenderThreadImpl;
 
 class CONTENT_EXPORT RenderFrameImpl
     : public RenderFrame,
       NON_EXPORTED_BASE(public blink::WebFrameClient),
       NON_EXPORTED_BASE(public blink::WebFrameSerializerClient) {
  public:
   // Creates a new RenderFrame as the main frame of |render_view|.
   static RenderFrameImpl* CreateMainFrame(
       RenderViewImpl* render_view,
       int32_t routing_id,
@@ skipping 478 matching lines @@
 
   // Sends the current frame's navigation state to the browser.
   void SendUpdateState();
 
   // Creates a MojoBindingsController if Mojo bindings have been enabled for
   // this frame. For WebUI, this allows the page to communicate with the browser
   // process; for layout tests, this allows the test to mock out services at
   // the Mojo IPC layer.
   void MaybeEnableMojoBindings();
 
+  void ReceiveNavigationDataPipeConsumerHandle(
+      mojo::ScopedDataPipeConsumerHandle data_consumer_handle,
+      int browser_request_id,
+      int32_t handle_commit_id);
+
  protected:
   explicit RenderFrameImpl(const CreateParams& params);
 
  private:
   friend class RenderFrameImplTest;
   friend class RenderFrameObserver;
   friend class RendererAccessibilityTest;
   friend class TestRenderFrame;
   FRIEND_TEST_ALL_PREFIXES(ExternalPopupMenuDisplayNoneTest, SelectItem);
   FRIEND_TEST_ALL_PREFIXES(ExternalPopupMenuRemoveTest, RemoveOnChange);
@@ skipping 111 matching lines @@
   void OnSetFrameOwnerProperties(
       const blink::WebFrameOwnerProperties& frame_owner_properties);
   void OnAdvanceFocus(blink::WebFocusType type, int32_t source_routing_id);
   void OnSetFocusedFrame();
   void OnTextTrackSettingsChanged(
       const FrameMsg_TextTrackSettings_Params& params);
   void OnPostMessageEvent(const FrameMsg_PostMessage_Params& params);
   void OnCommitNavigation(const ResourceResponseHead& response,
                           const GURL& stream_url,
                           const CommonNavigationParams& common_params,
-                          const RequestNavigationParams& request_params);
+                          const RequestNavigationParams& request_params,
+                          int32_t navigation_commit_id);
   void OnFailedNavigation(const CommonNavigationParams& common_params,
                           const RequestNavigationParams& request_params,
                           bool has_stale_copy_in_cache,
                           int error_code);
   void OnGetSavableResourceLinks();
   void OnGetSerializedHtmlWithLocalLinks(
       const std::map<GURL, base::FilePath>& url_to_local_path,
       const std::map<int, base::FilePath>& frame_routing_id_to_local_path);
   void OnSerializeAsMHTML(const FrameMsg_SerializeAsMHTML_Params& params);
   void OnFind(int request_id,
               const base::string16& search_text,
               const blink::WebFindOptions& options);
   void OnStopFinding(StopFindAction action);
 #if defined(OS_ANDROID)
   void OnActivateNearestFindResult(int request_id, float x, float y);
   void OnFindMatchRects(int current_version);
   void OnSelectPopupMenuItems(bool canceled,
                               const std::vector<int>& selected_indices);
 #elif defined(OS_MACOSX)
   void OnSelectPopupMenuItem(int selected_index);
   void OnCopyToFindPboard();
 #endif
 
+  void NavigateIfIPCSynched(bool no_sync_needed);
+
   // Requests that the browser process navigates to |url|. If
   // |is_history_navigation_in_new_child| is true, the browser process should
   // look for a matching FrameNavigationEntry in the last committed entry to use
   // instead of |url|.
   void OpenURL(const GURL& url,
                const Referrer& referrer,
                blink::WebNavigationPolicy policy,
                bool should_replace_current_entry,
                bool is_history_navigation_in_new_child);
 
@@ skipping 371 matching lines @@
   // Manages play, pause notifications for WebMediaPlayer implementations; its
   // lifetime is tied to the RenderFrame via the RenderFrameObserver interface.
   media::RendererWebMediaPlayerDelegate* media_player_delegate_;
 
   // Whether or not this RenderFrame is using Lo-Fi mode.
   bool is_using_lofi_;
 
   // Whether or not this RenderFrame is currently pasting.
   bool is_pasting_;
 
+  // TODO(carlosk): if this hack should become a thing, all of this should be
+  // moved into a struct that holds "ongoing navigation commit data". Maybe
+  // there's a way to reuse pending_navigation_params_?
+  mojo::ScopedDataPipeConsumerHandle latest_handle_;
+  int latest_browser_request_id_;
+  int32_t latest_handle_commit_id_;
+  RenderThreadImpl* handle_render_thread_;
+  int32_t latest_navigation_commit_id_;
+  RenderThreadImpl* navigation_render_thread_;
+  ResourceResponseHead navigation_response_;
+  GURL navigation_stream_url_;
+  CommonNavigationParams navigation_common_params_;
+  RequestNavigationParams navigation_request_params_;
+
 #if defined(ENABLE_WEBVR)
   // The VR dispatcher attached to the frame, lazily initialized.
   scoped_ptr<VRDispatcher> vr_dispatcher_;
 #endif
 
 #if defined(OS_MACOSX) || defined(OS_ANDROID)
   // The external popup for the currently showing select popup.
   scoped_ptr<ExternalPopupMenu> external_popup_menu_;
 #endif
 
   base::WeakPtrFactory<RenderFrameImpl> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(RenderFrameImpl);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_RENDERER_RENDER_FRAME_IMPL_H_