NOT FOR REVIEW: Adding prioritized incoming task queue to renderers

content/renderer/render_thread_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.
 
 #include "content/renderer/render_thread_impl.h"
 
 #include <algorithm>
 #include <limits>
 #include <map>
 #include <vector>
 
 #include "base/allocator/allocator_extension.h"
 #include "base/command_line.h"
 #include "base/debug/trace_event.h"
 #include "base/lazy_instance.h"
 #include "base/logging.h"
 #include "base/memory/discardable_memory.h"
 #include "base/memory/shared_memory.h"
+#include "base/message_loop/high_priority_task_runner.h"
 #include "base/metrics/field_trial.h"
 #include "base/metrics/histogram.h"
 #include "base/metrics/stats_table.h"
 #include "base/path_service.h"
 #include "base/strings/string16.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/string_tokenizer.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/threading/thread_local.h"
 #include "base/threading/thread_restrictions.h"
 #include "base/values.h"
 #include "cc/base/switches.h"
 #include "cc/resources/raster_worker_pool.h"
 #include "content/child/appcache/appcache_dispatcher.h"
 #include "content/child/appcache/appcache_frontend_impl.h"
 #include "content/child/child_histogram_message_filter.h"
 #include "content/child/db_message_filter.h"
+#include "content/child/high_priority_resource_filter.h"
 #include "content/child/indexed_db/indexed_db_dispatcher.h"
 #include "content/child/indexed_db/indexed_db_message_filter.h"
 #include "content/child/npapi/npobject_util.h"
 #include "content/child/plugin_messages.h"
 #include "content/child/resource_dispatcher.h"
 #include "content/child/runtime_features.h"
 #include "content/child/thread_safe_sender.h"
 #include "content/child/web_database_observer_impl.h"
 #include "content/child/worker_task_runner.h"
 #include "content/common/child_process_messages.h"
@@ skipping 508 matching lines @@
   }
 
   media_thread_.reset();
   compositor_thread_.reset();
   input_handler_manager_.reset();
   if (input_event_filter_.get()) {
     RemoveFilter(input_event_filter_.get());
     input_event_filter_ = NULL;
   }
 
+  if (high_priority_resource_filter_.get()) {
+    RemoveFilter(high_priority_resource_filter_.get());
+    high_priority_resource_filter_ = NULL;
+  }
+
   // Ramp down IDB before we ramp down WebKit (and V8), since IDB classes might
   // hold pointers to V8 objects (e.g., via pending requests).
   main_thread_indexed_db_dispatcher_.reset();
 
   if (webkit_platform_support_)
     blink::shutdown();
 
   lazy_tls.Pointer()->Set(NULL);
 
   // TODO(port)
@@ skipping 180 matching lines @@
     InputHandlerManagerClient* input_handler_manager_client = NULL;
 #if defined(OS_ANDROID)
     if (SynchronousCompositorFactory* factory =
         SynchronousCompositorFactory::GetInstance()) {
       input_handler_manager_client = factory->GetInputHandlerManagerClient();
     }
 #endif
     if (!input_handler_manager_client) {
       input_event_filter_ =
           new InputEventFilter(this, compositor_message_loop_proxy_);
+      if (high_priority_task_runner_.get()) {
+        input_event_filter_->SetHighPriorityTaskRunner(
+            high_priority_task_runner_);
+      }
       AddFilter(input_event_filter_.get());
       input_handler_manager_client = input_event_filter_.get();
     }
     input_handler_manager_.reset(
         new InputHandlerManager(compositor_message_loop_proxy_,
                                 input_handler_manager_client));
   }
 
   scoped_refptr<base::MessageLoopProxy> output_surface_loop;
   if (enable)
@@ skipping 291 matching lines @@
         &input_params, &output_params));
 
     audio_hardware_config_.reset(new media::AudioHardwareConfig(
         input_params, output_params));
     audio_message_filter_->SetAudioHardwareConfig(audio_hardware_config_.get());
   }
 
   return audio_hardware_config_.get();
 }
 
+void RenderThreadImpl::UseHighPriorityTaskRunner(
+    scoped_refptr<base::HighPriorityTaskRunner> high_priority_task_runner) {
+  DCHECK(!high_priority_resource_filter_.get());
+  DCHECK(channel());
+
+  high_priority_task_runner_ = high_priority_task_runner;
+  high_priority_resource_filter_ = new HighPriorityResourceFilter(
+      resource_dispatcher(), high_priority_task_runner);
+  resource_dispatcher()->set_high_priority_resource_filter(
+      high_priority_resource_filter_.get());
+
+  channel()->AddFilter(high_priority_resource_filter_.get());
+}
+
 base::WaitableEvent* RenderThreadImpl::GetShutdownEvent() {
   return ChildProcess::current()->GetShutDownEvent();
 }
 
 #if defined(OS_WIN)
 void RenderThreadImpl::PreCacheFontCharacters(const LOGFONT& log_font,
                                               const base::string16& str) {
   Send(new ViewHostMsg_PreCacheFontCharacters(log_font, str));
 }
 
@@ skipping 417 matching lines @@
   hidden_widget_count_--;
 
   if (!GetContentClient()->renderer()->RunIdleHandlerWhenWidgetsHidden()) {
     return;
   }
 
   ScheduleIdleHandler(kLongIdleHandlerDelayMs);
 }
 
 }  // namespace content