Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/renderer/media/video_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/video_pipeline_proxy.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/memory/shared_memory.h"
 #include "base/message_loop/message_loop.h"
@@ skipping 169 matching lines @@
   status_cb_ = status_cb;
 }
 
 void VideoPipelineProxyInternal::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(&VideoPipelineProxyInternal::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(&VideoPipelineProxyInternal::param_fn, \
+                            base::Unretained(proxy_.get()), ##__VA_ARGS__))
 
 VideoPipelineProxy::VideoPipelineProxy(
-    scoped_refptr<base::MessageLoopProxy> io_message_loop_proxy,
+    scoped_refptr<base::SingleThreadTaskRunner> io_task_runner,
     scoped_refptr<MediaChannelProxy> media_channel_proxy)
-    : io_message_loop_proxy_(io_message_loop_proxy),
+    : io_task_runner_(io_task_runner),
       proxy_(new VideoPipelineProxyInternal(media_channel_proxy)),
       video_streamer_(new AvStreamerProxy()),
       weak_factory_(this) {
-  DCHECK(io_message_loop_proxy_.get());
+  DCHECK(io_task_runner_.get());
   weak_this_ = weak_factory_.GetWeakPtr();
   thread_checker_.DetachFromThread();
 }
 
 VideoPipelineProxy::~VideoPipelineProxy() {
   DCHECK(thread_checker_.CalledOnValidThread());
   // Release the underlying object on the right thread.
-  io_message_loop_proxy_->PostTask(
+  io_task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&VideoPipelineProxyInternal::Release, base::Passed(&proxy_)));
 }
 
 void VideoPipelineProxy::SetClient(
     const VideoPipelineClient& video_client) {
   DCHECK(thread_checker_.CalledOnValidThread());
   base::Closure pipe_read_cb =
       ::media::BindToCurrentLoop(
           base::Bind(&VideoPipelineProxy::OnPipeRead, weak_this_));
@@ skipping 66 matching lines @@
 }
 
 void VideoPipelineProxy::OnPipeRead() {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (video_streamer_)
     video_streamer_->OnFifoReadEvent();
 }
 
 }  // namespace media
 }  // namespace chromecast