Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/media/cma/ipc/media_message_fifo.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/media/cma/ipc/media_message_fifo.h"
 
 #include "base/atomicops.h"
 #include "base/bind.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 "base/thread_task_runner_handle.h"
 #include "chromecast/media/cma/base/cma_logging.h"
 #include "chromecast/media/cma/ipc/media_memory_chunk.h"
 #include "chromecast/media/cma/ipc/media_message.h"
 #include "chromecast/media/cma/ipc/media_message_type.h"
 
 namespace chromecast {
 namespace media {
 
 class MediaMessageFlag
     : public base::RefCountedThreadSafe<MediaMessageFlag> {
@@ skipping 49 matching lines @@
   scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
   base::Closure release_msg_cb_;
 
   void* const data_;
   const size_t size_;
   scoped_refptr<MediaMessageFlag> flag_;
 
   DISALLOW_COPY_AND_ASSIGN(FifoOwnedMemory);
 };
 
-FifoOwnedMemory::FifoOwnedMemory(
-    void* data, size_t size,
-    const scoped_refptr<MediaMessageFlag>& flag,
-    const base::Closure& release_msg_cb)
-  : task_runner_(base::MessageLoopProxy::current()),
-    release_msg_cb_(release_msg_cb),
-    data_(data),
-    size_(size),
-    flag_(flag) {
+FifoOwnedMemory::FifoOwnedMemory(void* data,
+                                 size_t size,
+                                 const scoped_refptr<MediaMessageFlag>& flag,
+                                 const base::Closure& release_msg_cb)
+    : task_runner_(base::ThreadTaskRunnerHandle::Get()),
+      release_msg_cb_(release_msg_cb),
+      data_(data),
+      size_(size),
+      flag_(flag) {
 }
 
 FifoOwnedMemory::~FifoOwnedMemory() {
   // Release the flag before notifying that the message has been released.
   flag_ = scoped_refptr<MediaMessageFlag>();
   if (!release_msg_cb_.is_null()) {
     if (task_runner_->BelongsToCurrentThread()) {
       release_msg_cb_.Run();
     } else {
       task_runner_->PostTask(FROM_HERE, release_msg_cb_);
@@ skipping 294 matching lines @@
 void MediaMessageFifo::CommitInternalRead(size_t new_rd_offset) {
   internal_rd_offset_ = new_rd_offset;
 }
 
 void MediaMessageFifo::CommitInternalWrite(size_t new_wr_offset) {
   internal_wr_offset_ = new_wr_offset;
 }
 
 }  // namespace media
 }  // namespace chromecast