content/child: Remove use of MessageLoopProxy and deprecated MessageLoop APIs

content/child/npapi/plugin_instance.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/child/npapi/plugin_instance.h"
 
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/files/file_util.h"
-#include "base/message_loop/message_loop.h"
+#include "base/location.h"
+#include "base/single_thread_task_runner.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/utf_string_conversions.h"
+#include "base/thread_task_runner_handle.h"
 #include "build/build_config.h"
 #include "content/child/npapi/plugin_host.h"
 #include "content/child/npapi/plugin_lib.h"
 #include "content/child/npapi/plugin_stream_url.h"
 #include "content/child/npapi/plugin_string_stream.h"
 #include "content/child/npapi/webplugin.h"
 #include "content/child/npapi/webplugin_delegate.h"
 #include "content/child/npapi/webplugin_resource_client.h"
 #include "content/public/common/content_constants.h"
 #include "content/public/common/content_switches.h"
@@ skipping 23 matching lines @@
 #else
       drawing_model_(NPDrawingModelQuickDraw),
 #endif
 #ifdef NP_NO_CARBON
       event_model_(NPEventModelCocoa),
 #else
       event_model_(NPEventModelCarbon),
 #endif
       currently_handled_event_(NULL),
 #endif
-      message_loop_(base::MessageLoop::current()),
+      task_runner_(base::ThreadTaskRunnerHandle::Get()),
       load_manually_(false),
       in_close_streams_(false),
       next_timer_id_(1),
       next_notify_id_(0),
       next_range_request_id_(0),
       handles_url_redirects_(false) {
   npp_ = new NPP_t();
   npp_->ndata = 0;
   npp_->pdata = 0;
 
   if (mime_type_ == kFlashPluginSwfMimeType)
     transparent_ = false;
 
   memset(&zero_padding_, 0, sizeof(zero_padding_));
-  DCHECK(message_loop_);
 }
 
 PluginInstance::~PluginInstance() {
   CloseStreams();
 
   if (npp_ != 0) {
     delete npp_;
     npp_ = 0;
   }
 
@@ skipping 349 matching lines @@
 void PluginInstance::DidManualLoadFail() {
   DCHECK(load_manually_);
   if (plugin_data_stream_.get() != NULL) {
     plugin_data_stream_->DidFail(plugin_data_stream_->ResourceId());
     plugin_data_stream_ = NULL;
   }
 }
 
 void PluginInstance::PluginThreadAsyncCall(void (*func)(void*),
                                            void* user_data) {
-  message_loop_->PostTask(
+  task_runner_->PostTask(
       FROM_HERE, base::Bind(&PluginInstance::OnPluginThreadAsyncCall, this,
                             func, user_data));
 }
 
 void PluginInstance::OnPluginThreadAsyncCall(void (*func)(void*),
                                              void* user_data) {
   // Do not invoke the callback if NPP_Destroy has already been invoked.
   if (webplugin_)
     func(user_data);
 }
 
 uint32 PluginInstance::ScheduleTimer(uint32 interval,
                                      NPBool repeat,
                                      void (*func)(NPP id, uint32 timer_id)) {
   // Use next timer id.
   uint32 timer_id;
   timer_id = next_timer_id_;
   ++next_timer_id_;
   DCHECK(next_timer_id_ != 0);
 
   // Record timer interval and repeat.
   TimerInfo info;
   info.interval = interval;
   info.repeat = repeat ? true : false;
   timers_[timer_id] = info;
 
   // Schedule the callback.
-  base::MessageLoop::current()->PostDelayedTask(
+  base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
       FROM_HERE,
       base::Bind(&PluginInstance::OnTimerCall, this, func, npp_, timer_id),
       base::TimeDelta::FromMilliseconds(interval));
   return timer_id;
 }
 
 void PluginInstance::UnscheduleTimer(uint32 timer_id) {
   // Remove info about the timer.
   TimerMap::iterator it = timers_.find(timer_id);
   if (it != timers_.end())
@@ skipping 21 matching lines @@
 
   func(id, timer_id);
 
   // If the timer was unscheduled by the callback, just free up the timer id.
   if (timers_.find(timer_id) == timers_.end())
     return;
 
   // Reschedule repeating timers after invoking the callback so callback is not
   // re-entered if it pumps the message loop.
   if (info.repeat) {
-    base::MessageLoop::current()->PostDelayedTask(
+    base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
         FROM_HERE,
         base::Bind(&PluginInstance::OnTimerCall, this, func, npp_, timer_id),
         base::TimeDelta::FromMilliseconds(info.interval));
   } else {
     timers_.erase(it);
   }
 }
 
 void PluginInstance::PushPopupsEnabledState(bool enabled) {
   popups_enabled_stack_.push(enabled);
@@ skipping 166 matching lines @@
     if (plugin_stream->notify_data() == notify_data) {
       PluginStreamUrl* plugin_stream_url =
           static_cast<PluginStreamUrl*>(plugin_stream);
       plugin_stream_url->URLRedirectResponse(allow);
       break;
     }
   }
 }
 
 }  // namespace content