Schedule ResourceDispatch messages via a Filter

content/renderer/render_thread_impl.cc

Index: content/renderer/render_thread_impl.cc
diff --git a/content/renderer/render_thread_impl.cc b/content/renderer/render_thread_impl.cc
index b9fd1826127a5ab937811bdb1913975da7eb17bf..f76416be4cf2d16e05813281993106964a2631b1 100644
--- a/content/renderer/render_thread_impl.cc
+++ b/content/renderer/render_thread_impl.cc
@@ -44,6 +44,7 @@
 #include "content/child/npapi/npobject_util.h"
 #include "content/child/plugin_messages.h"
 #include "content/child/resource_dispatcher.h"
+#include "content/child/resource_scheduling_filter.h"
 #include "content/child/runtime_features.h"
 #include "content/child/thread_safe_sender.h"
 #include "content/child/web_database_observer_impl.h"
@@ -852,6 +853,14 @@ void RenderThreadImpl::EnsureWebKitInitialized() {
 
   main_thread_compositor_task_runner_ = base::MessageLoopProxy::current();
 
+  // Add a filter that forces resource messages to be dispatched via a
+  // particular task runner.
+  // FIXME: hook this up to the blink scheduler.
+  resource_scheduling_filter_ = new ResourceSchedulingFilter(
+      base::MessageLoopProxy::current(), resource_dispatcher());
+  GetChannel()->AddFilter(resource_scheduling_filter_.get());
+  channel()->AddFilter(resource_scheduling_filter_.get());
+
   bool enable = !command_line.HasSwitch(switches::kDisableThreadedCompositing);
   if (enable) {
 #if defined(OS_ANDROID)