Pass WebKit priority changes and parsing messages up to the browser process.

content/browser/loader/resource_dispatcher_host_impl.cc

 // 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
 
 #include "content/browser/loader/resource_dispatcher_host_impl.h"
 
 #include <set>
 #include <vector>
@@ skipping 185 matching lines @@
 #if defined(OS_WIN)
 #pragma warning(disable: 4748)
 #pragma optimize("", off)
 #endif
 
 #if defined(OS_WIN)
 #pragma optimize("", on)
 #pragma warning(default: 4748)
 #endif
 
-net::RequestPriority DetermineRequestPriority(
-    const ResourceHostMsg_Request& request_data) {
-  switch (request_data.priority) {
+net::RequestPriority ConvertWebKitPriorityToNetPriority(
+    const WebKit::WebURLRequest::Priority& priority) {
+  switch (priority) {
     case WebKit::WebURLRequest::PriorityVeryHigh:
       return net::HIGHEST;
 
     case WebKit::WebURLRequest::PriorityHigh:
       return net::MEDIUM;
 
     case WebKit::WebURLRequest::PriorityMedium:
       return net::LOW;
 
     case WebKit::WebURLRequest::PriorityLow:
@@ skipping 566 matching lines @@
   IPC_BEGIN_MESSAGE_MAP_EX(ResourceDispatcherHostImpl, message, *message_was_ok)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_RequestResource, OnRequestResource)
     IPC_MESSAGE_HANDLER_DELAY_REPLY(ResourceHostMsg_SyncLoad, OnSyncLoad)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_ReleaseDownloadedFile,
                         OnReleaseDownloadedFile)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_DataReceived_ACK, OnDataReceivedACK)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_DataDownloaded_ACK, OnDataDownloadedACK)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_UploadProgress_ACK, OnUploadProgressACK)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_CancelRequest, OnCancelRequest)
     IPC_MESSAGE_HANDLER(ResourceHostMsg_FollowRedirect, OnFollowRedirect)
+    IPC_MESSAGE_HANDLER(ResourceHostMsg_DidChangePriority, OnDidChangePriority)
     IPC_MESSAGE_HANDLER(ViewHostMsg_SwapOut_ACK, OnSwapOutACK)
     IPC_MESSAGE_HANDLER(ViewHostMsg_DidLoadResourceFromMemoryCache,
                         OnDidLoadResourceFromMemoryCache)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP_EX()
 
   if (message.type() == ViewHostMsg_DidLoadResourceFromMemoryCache::ID) {
     // We just needed to peek at this message. We still want it to reach its
     // normal destination.
     handled = false;
@@ skipping 110 matching lines @@
     net::HttpRequestHeaders headers;
     headers.AddHeadersFromString(request_data.headers);
     request->SetExtraRequestHeaders(headers);
   }
 
   // TODO(darin): Do we really need all of these URLRequest setters in the
   // transferred navigation case?
 
   request->set_load_flags(load_flags);
 
-  request->set_priority(DetermineRequestPriority(request_data));
+  request->set_priority(ConvertWebKitPriorityToNetPriority(
+      request_data.priority));
 
   // Resolve elements from request_body and prepare upload data.
   if (request_data.request_body) {
     request->set_upload(make_scoped_ptr(
         request_data.request_body->ResolveElementsAndCreateUploadDataStream(
             filter_->blob_storage_context()->controller(),
             filter_->file_system_context(),
             BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE))));
   }
 
@@ skipping 184 matching lines @@
   }
 
   ResourceRequestInfoImpl* info = loader->GetRequestInfo();
   if (info->async_handler()) {
     info->async_handler()->OnFollowRedirect(
         has_new_first_party_for_cookies,
         new_first_party_for_cookies);
   }
 }
 
+void ResourceDispatcherHostImpl::OnDidChangePriority(
+    int request_id,
+    WebKit::WebURLRequest::Priority priority) {
+  int child_id = filter_->child_id();
+  LoaderMap::iterator it = pending_loaders_.find(
+      GlobalRequestID(child_id, request_id));
+  if (it == pending_loaders_.end()) {
+    // PendingRequest likely removed while this IPC was in flight.
+    return;
+  }
+  const linked_ptr<ResourceLoader>& loader = it->second;
+  loader->ChangePriority(ConvertWebKitPriorityToNetPriority(priority));

[darin (slow to review), 2013/02/06 05:04:13]

Maybe instead of routing this notification through the ResourceHandler and
ResourceThrottle interfaces, you could just pass the notification directly to
the ResourceScheduler.  It could maintain a mapping from (child_id, request_id)
to scheduled requests.

+}
+
 ResourceRequestInfoImpl* ResourceDispatcherHostImpl::CreateRequestInfo(
     int child_id,
     int route_id,
     bool download,
     ResourceContext* context) {
   return new ResourceRequestInfoImpl(
       PROCESS_TYPE_RENDERER,
       child_id,
       route_id,
       0,
@@ skipping 560 matching lines @@
 
   return i->second.get();
 }
 
 ResourceLoader* ResourceDispatcherHostImpl::GetLoader(int child_id,
                                                       int request_id) const {
   return GetLoader(GlobalRequestID(child_id, request_id));
 }
 
 }  // namespace content