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

content/child/resource_dispatcher.h

 // Copyright (c) 2012 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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #ifndef CONTENT_CHILD_RESOURCE_DISPATCHER_H_
 #define CONTENT_CHILD_RESOURCE_DISPATCHER_H_
 
 #include <stdint.h>
 
 #include <deque>
 #include <map>
 #include <string>
 
 #include "base/containers/hash_tables.h"
 #include "base/macros.h"
 #include "base/memory/linked_ptr.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/shared_memory.h"
 #include "base/memory/weak_ptr.h"
 #include "base/single_thread_task_runner.h"
 #include "base/time/time.h"
 #include "content/common/content_export.h"
 #include "content/public/common/resource_type.h"
 #include "ipc/ipc_listener.h"
 #include "ipc/ipc_sender.h"
+#include "mojo/public/cpp/system/data_pipe.h"
+#include "mojo/public/cpp/system/watcher.h"
 #include "net/base/request_priority.h"
 #include "url/gurl.h"
 
 struct ResourceHostMsg_Request;
 struct ResourceMsg_RequestCompleteData;
 
 namespace net {
 struct RedirectInfo;
 }
 
@@ skipping 29 matching lines @@
   // use this if you really need it!  There is also no way for the caller to
   // interrupt this method. Errors are reported via the status field of the
   // response parameter.
   void StartSync(const RequestInfo& request_info,
                  ResourceRequestBody* request_body,
                  SyncLoadResponse* response);
 
   // Call this method to initiate the request. If this method succeeds, then
   // the peer's methods will be called asynchronously to report various events.
   // Returns the request id.
-  virtual int StartAsync(const RequestInfo& request_info,
-                         ResourceRequestBody* request_body,
-                         scoped_ptr<RequestPeer> peer);
+  virtual int StartAsync(
+      const RequestInfo& request_info,
+      ResourceRequestBody* request_body,
+      scoped_ptr<RequestPeer> peer,
+      mojo::ScopedDataPipeConsumerHandle mojo_data_pipe_handle,
+      int browser_request_id);
 
   // Removes a request from the |pending_requests_| list, returning true if the
   // request was found and removed.
   bool RemovePendingRequest(int request_id);
 
   // Cancels a request in the |pending_requests_| list.  The request will be
   // removed from the dispatcher as well.
   virtual void Cancel(int request_id);
 
   // Toggles the is_deferred attribute for the specified request.
@@ skipping 60 matching lines @@
     GURL response_url;
     bool download_to_file;
     scoped_ptr<IPC::Message> pending_redirect_message;
     base::TimeTicks request_start;
     base::TimeTicks response_start;
     base::TimeTicks completion_time;
     linked_ptr<base::SharedMemory> buffer;
     scoped_refptr<SharedMemoryReceivedDataFactory> received_data_factory;
     scoped_ptr<SiteIsolationResponseMetaData> site_isolation_metadata;
     int buffer_size;
+
+    mojo::ScopedDataPipeConsumerHandle mojo_data_pipe_handle;
+    mojo::Watcher mojo_watcher;
+    uint32_t mojo_total_bytes;
   };
   using PendingRequestMap = std::map<int, scoped_ptr<PendingRequestInfo>>;
 
   // Helper to lookup the info based on the request_id.
   // May return NULL if the request as been canceled from the client side.
   PendingRequestInfo* GetPendingRequestInfo(int request_id);
 
   // Follows redirect, if any, for the given request.
   void FollowPendingRedirect(int request_id, PendingRequestInfo* request_info);
 
@@ skipping 20 matching lines @@
       int request_id,
       const ResourceMsg_RequestCompleteData& request_complete_data);
 
   // Dispatch the message to one of the message response handlers.
   void DispatchMessage(const IPC::Message& message);
 
   // Dispatch any deferred messages for the given request, provided it is not
   // again in the deferred state. This method may mutate |pending_requests_|.
   void FlushDeferredMessages(int request_id);
 
+  // PlzNavigate: Mojo data streaming methods
+  void WaitForMojoData(int request_id, PendingRequestInfo* request_info);
+  void ReceivedMojoData(int request_id, MojoResult);
+  void AcceptMojoMessage(PendingRequestInfo* request_info,
+                         const void* buffer,
+                         uint32_t num_bytes);
+
   void ToResourceResponseInfo(const PendingRequestInfo& request_info,
                               const ResourceResponseHead& browser_info,
                               ResourceResponseInfo* renderer_info) const;
 
   base::TimeTicks ToRendererCompletionTime(
       const PendingRequestInfo& request_info,
       const base::TimeTicks& browser_completion_time) const;
 
   // Returns timestamp provided by IO thread. If no timestamp is supplied,
   // then current time is returned. Saved timestamp is reset, so following
@@ skipping 33 matching lines @@
   scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter_;
 
   base::WeakPtrFactory<ResourceDispatcher> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(ResourceDispatcher);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_CHILD_RESOURCE_DISPATCHER_H_