Add a ResourceScheduler to ResourceDispatcherHost.

content/browser/renderer_host/render_process_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.
 
 // Represents the browser side of the browser <--> renderer communication
 // channel. There will be one RenderProcessHost per renderer process.
 
 #include "content/browser/renderer_host/render_process_host_impl.h"
 
 #include <algorithm>
@@ skipping 38 matching lines @@
 #include "content/browser/download/mhtml_generation_manager.h"
 #include "content/browser/fileapi/chrome_blob_storage_context.h"
 #include "content/browser/fileapi/fileapi_message_filter.h"
 #include "content/browser/geolocation/geolocation_dispatcher_host.h"
 #include "content/browser/gpu/gpu_data_manager_impl.h"
 #include "content/browser/gpu/gpu_process_host.h"
 #include "content/browser/histogram_message_filter.h"
 #include "content/browser/hyphenator/hyphenator_message_filter.h"
 #include "content/browser/in_process_webkit/indexed_db_context_impl.h"
 #include "content/browser/in_process_webkit/indexed_db_dispatcher_host.h"
+#include "content/browser/loader/resource_dispatcher_host_impl.h"
 #include "content/browser/loader/resource_message_filter.h"
+#include "content/browser/loader/resource_scheduler.h"
+#include "content/browser/loader/resource_scheduler_filter.h"
 #include "content/browser/mime_registry_message_filter.h"
 #include "content/browser/plugin_service_impl.h"
 #include "content/browser/profiler_message_filter.h"
 #include "content/browser/renderer_host/clipboard_message_filter.h"
 #include "content/browser/renderer_host/database_message_filter.h"
 #include "content/browser/renderer_host/file_utilities_message_filter.h"
 #include "content/browser/renderer_host/gamepad_browser_message_filter.h"
 #include "content/browser/renderer_host/gpu_message_filter.h"
 #include "content/browser/renderer_host/media/audio_input_renderer_host.h"
 #include "content/browser/renderer_host/media/audio_renderer_host.h"
@@ skipping 402 matching lines @@
 
     fast_shutdown_started_ = false;
   }
 
   is_initialized_ = true;
   return true;
 }
 
 void RenderProcessHostImpl::CreateMessageFilters() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  channel_->AddFilter(new ResourceSchedulerFilter(GetID()));
   MediaObserver* media_observer =
       GetContentClient()->browser()->GetMediaObserver();
   // Add BrowserPluginMessageFilter to ensure it gets the first stab at messages
   // from guests.
   if (IsGuest()) {
     scoped_refptr<BrowserPluginMessageFilter> bp_message_filter(
         new BrowserPluginMessageFilter(
             GetID(),
             GetBrowserContext()));
     channel_->AddFilter(bp_message_filter);
@@ skipping 956 matching lines @@
   child_process_launcher_.reset();
   channel_.reset();
   gpu_message_filter_ = NULL;
 
   IDMap<RenderWidgetHost>::iterator iter(&render_widget_hosts_);
   while (!iter.IsAtEnd()) {
     RenderWidgetHostImpl::From(iter.GetCurrentValue())->OnMessageReceived(
         ViewHostMsg_RenderViewGone(iter.GetCurrentKey(),
                                    static_cast<int>(status),
                                    exit_code));
+    if (ResourceDispatcherHostImpl::Get()) {
+      ResourceDispatcherHostImpl::Get()->scheduler()->OnDestroy(

[darin (slow to review), 2012/12/15 05:17:24]

This looks like it is the main thread, and I don't think
ResourceScheduler::OnDestroy is safe to call off of the IO thread.  You should
probably make ResourceScheduler inherit from NonThreadSafe.  It might be nice to
find some other way to communicate the destruction of a RenderView to the
scheduler.

Also, this is only trapping process destruction.  RenderViews can be closed well
before process destruction.  OnCreate seems to be called when a RenderView is
created, so I assumed OnDestroy was intended to be called when a RenderView is
destroyed.  Seems not to be how it works though.

[James Simonsen, 2012/12/17 21:31:38]

Done. Let me know if I should separate out or rename
RenderWidgetHelper::OnCancelResourceRequests.

+          GetID(), iter.GetCurrentKey());
+    }
     iter.Advance();
   }
 
   ClearTransportDIBCache();
 
   // this object is not deleted at this point and may be reused later.
   // TODO(darin): clean this up
 }
 
 int RenderProcessHostImpl::GetActiveViewCount() {
@@ skipping 121 matching lines @@
       int32 gpu_process_host_id) {
   TRACE_EVENT0("renderer_host",
                "RenderWidgetHostImpl::OnCompositorSurfaceBuffersSwappedNoHost");
   RenderWidgetHostImpl::AcknowledgeBufferPresent(route_id,
                                                  gpu_process_host_id,
                                                  surface_handle,
                                                  0);
 }
 
 }  // namespace content