Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/renderer/media/media_pipeline_proxy.cc

 // Copyright 2014 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 "chromecast/renderer/media/media_pipeline_proxy.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/location.h"
 #include "base/logging.h"
-#include "base/message_loop/message_loop_proxy.h"
+#include "base/single_thread_task_runner.h"
 #include "chromecast/common/media/cma_messages.h"
 #include "chromecast/media/cma/base/coded_frame_provider.h"
 #include "chromecast/renderer/media/audio_pipeline_proxy.h"
 #include "chromecast/renderer/media/media_channel_proxy.h"
 #include "chromecast/renderer/media/video_pipeline_proxy.h"
 
 namespace chromecast {
 namespace media {
 
 // MediaPipelineProxyInternal -
@@ skipping 120 matching lines @@
           media_channel_proxy_->GetId(), playback_rate)));
 }
 
 void MediaPipelineProxyInternal::OnStateChanged(
     ::media::PipelineStatus status) {
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK(!status_cb_.is_null());
   base::ResetAndReturn(&status_cb_).Run(status);
 }
 
-
-// A macro runs current member function on |io_message_loop_proxy_| thread.
-#define FORWARD_ON_IO_THREAD(param_fn, ...) \
-  io_message_loop_proxy_->PostTask( \
-      FROM_HERE, \
-      base::Bind(&MediaPipelineProxyInternal::param_fn, \
-                 base::Unretained(proxy_.get()), ##__VA_ARGS__))
+// A macro runs current member function on |io_task_runner_| thread.
+#define FORWARD_ON_IO_THREAD(param_fn, ...)                        \
+  io_task_runner_->PostTask(                                       \
+      FROM_HERE, base::Bind(&MediaPipelineProxyInternal::param_fn, \
+                            base::Unretained(proxy_.get()), ##__VA_ARGS__))
 
 MediaPipelineProxy::MediaPipelineProxy(
     int render_frame_id,
-    scoped_refptr<base::MessageLoopProxy> io_message_loop_proxy,
+    scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
     LoadType load_type)
-    : io_message_loop_proxy_(io_message_loop_proxy),
+    : io_task_runner_(io_task_runner),
       render_frame_id_(render_frame_id),
       media_channel_proxy_(new MediaChannelProxy),
       proxy_(new MediaPipelineProxyInternal(media_channel_proxy_)),
       has_audio_(false),
       has_video_(false),
-      audio_pipeline_(new AudioPipelineProxy(
-          io_message_loop_proxy, media_channel_proxy_)),
-      video_pipeline_(new VideoPipelineProxy(
-          io_message_loop_proxy, media_channel_proxy_)),
+      audio_pipeline_(
+          new AudioPipelineProxy(io_task_runner, media_channel_proxy_)),
+      video_pipeline_(
+          new VideoPipelineProxy(io_task_runner, media_channel_proxy_)),
       weak_factory_(this) {
   weak_this_ = weak_factory_.GetWeakPtr();
-  io_message_loop_proxy_->PostTask(
+  io_task_runner_->PostTask(
       FROM_HERE,
-      base::Bind(&MediaChannelProxy::Open, media_channel_proxy_,
-                 load_type));
+      base::Bind(&MediaChannelProxy::Open, media_channel_proxy_, load_type));
   thread_checker_.DetachFromThread();
 }
 
 MediaPipelineProxy::~MediaPipelineProxy() {
-  io_message_loop_proxy_->PostTask(
+  io_task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&MediaPipelineProxyInternal::Release, base::Passed(&proxy_)));
-  io_message_loop_proxy_->PostTask(
-      FROM_HERE,
-      base::Bind(&MediaChannelProxy::Close, media_channel_proxy_));
+  io_task_runner_->PostTask(
+      FROM_HERE, base::Bind(&MediaChannelProxy::Close, media_channel_proxy_));
 }
 
 void MediaPipelineProxy::SetClient(
     const MediaPipelineClient& client) {
   DCHECK(thread_checker_.CalledOnValidThread());
   FORWARD_ON_IO_THREAD(SetClient, client);
 }
 
 void MediaPipelineProxy::SetCdm(int cdm_id) {
   DCHECK(thread_checker_.CalledOnValidThread());
@@ skipping 74 matching lines @@
   FORWARD_ON_IO_THREAD(Stop);
 }
 
 void MediaPipelineProxy::SetPlaybackRate(double playback_rate) {
   DCHECK(thread_checker_.CalledOnValidThread());
   FORWARD_ON_IO_THREAD(SetPlaybackRate, playback_rate);
 }
 
 }  // namespace cma
 }  // namespace chromecast