Redirect HTML resource bytes directly to parser thread (Chrome side CL)

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 <deque>
@@ skipping 38 matching lines @@
                         const GURL& frame_origin,
                         const GURL& request_url);
 
   // 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.
   void CancelPendingRequest(int request_id);
 
+  // Stop sending ACKs back for received data packets.
+  void StopSendingDataACKs(int request_id);
+
+  // ACK a data packet.
+  void SendDataACK(int request_id);
+
   IPC::Sender* message_sender() const {
     return message_sender_;
   }
 
   // Toggles the is_deferred attribute for the specified request.
   void SetDefersLoading(int request_id, bool value);
 
   // Indicates the priority of the specified request changed.
   void DidChangePriority(int routing_id, int request_id,
                          net::RequestPriority new_priority);
 
+  // Construct a WebThreadedResourceProvider for passing back to Blink.
+  blink::WebThreadedResourceProvider* CreateThreadedResourceProvider(
+      int request_id);
+
   // This does not take ownership of the delegate. It is expected that the
   // delegate have a longer lifetime than the ResourceDispatcher.
   void set_delegate(ResourceDispatcherDelegate* delegate) {
     delegate_ = delegate;
   }
 
   // Remembers IO thread timestamp for next resource message.
   void set_io_timestamp(base::TimeTicks io_timestamp) {
     io_timestamp_ = io_timestamp;
   }
@@ skipping 26 matching lines @@
     // The security origin of the frame that initiates this request.
     GURL frame_origin;
     // The url of the latest response even in case of redirection.
     GURL response_url;
     linked_ptr<IPC::Message> pending_redirect_message;
     base::TimeTicks request_start;
     base::TimeTicks response_start;
     base::TimeTicks completion_time;
     linked_ptr<base::SharedMemory> buffer;
     int buffer_size;
+    bool send_data_acks;
   };
   typedef base::hash_map<int, PendingRequestInfo> PendingRequestList;
 
   // 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 75 matching lines @@
 
   // IO thread timestamp for ongoing IPC message.
   base::TimeTicks io_timestamp_;
 
   DISALLOW_COPY_AND_ASSIGN(ResourceDispatcher);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_CHILD_RESOURCE_DISPATCHER_H_