Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/renderer/media/audio_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/audio_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 177 matching lines @@
                                kAudioTrackId, volume)));
 }
 
 void AudioPipelineProxyInternal::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(&AudioPipelineProxyInternal::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(&AudioPipelineProxyInternal::param_fn, \
+                            base::Unretained(proxy_.get()), ##__VA_ARGS__))
 
 AudioPipelineProxy::AudioPipelineProxy(
-    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 AudioPipelineProxyInternal(media_channel_proxy)),
       audio_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();
 }
 
 AudioPipelineProxy::~AudioPipelineProxy() {
   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(&AudioPipelineProxyInternal::Release, base::Passed(&proxy_)));
 }
 
 void AudioPipelineProxy::SetClient(
     const AvPipelineClient& client) {
   DCHECK(thread_checker_.CalledOnValidThread());
   base::Closure pipe_read_cb = ::media::BindToCurrentLoop(
       base::Bind(&AudioPipelineProxy::OnPipeRead, weak_this_));
   FORWARD_ON_IO_THREAD(SetClient, pipe_read_cb, client);
@@ skipping 70 matching lines @@
 }
 
 void AudioPipelineProxy::OnPipeRead() {
   DCHECK(thread_checker_.CalledOnValidThread());
   if (audio_streamer_)
     audio_streamer_->OnFifoReadEvent();
 }
 
 }  // namespace cma
 }  // namespace chromecast