Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/media/cma/ipc_streamer/av_streamer_unittest.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 <list>
 #include <vector>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
+#include "base/thread_task_runner_handle.h"
 #include "base/threading/thread.h"
 #include "base/time/time.h"
 #include "chromecast/media/cma/base/decoder_buffer_base.h"
 #include "chromecast/media/cma/ipc/media_memory_chunk.h"
 #include "chromecast/media/cma/ipc/media_message_fifo.h"
 #include "chromecast/media/cma/ipc_streamer/av_streamer_proxy.h"
 #include "chromecast/media/cma/ipc_streamer/coded_frame_provider_host.h"
 #include "chromecast/media/cma/test/frame_generator_for_test.h"
 #include "chromecast/media/cma/test/mock_frame_consumer.h"
 #include "chromecast/media/cma/test/mock_frame_provider.h"
@@ skipping 115 matching lines @@
 
   frame_consumer_.reset(
       new MockFrameConsumer(coded_frame_provider_host_.get()));
   frame_consumer_->Configure(
       consumer_delayed_pattern,
       false,
       frame_generator_consumer.Pass());
 }
 
 void AvStreamerTest::Start() {
-  base::MessageLoopProxy::current()->PostTask(
-      FROM_HERE,
-      base::Bind(&AvStreamerProxy::Start,
-                 base::Unretained(av_buffer_proxy_.get())));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&AvStreamerProxy::Start,
+                            base::Unretained(av_buffer_proxy_.get())));
 
   frame_consumer_->Start(
       base::Bind(&AvStreamerTest::OnTestCompleted,
                  base::Unretained(this)));
 }
 
 void AvStreamerTest::OnTestTimeout() {
   ADD_FAILURE() << "Test timed out";
   if (base::MessageLoop::current())
     base::MessageLoop::current()->QuitWhenIdle();
 }
 
 void AvStreamerTest::OnTestCompleted() {
   base::MessageLoop::current()->QuitWhenIdle();
 }
 
 void AvStreamerTest::OnFifoWrite() {
-  base::MessageLoopProxy::current()->PostTask(
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(&CodedFrameProviderHost::OnFifoWriteEvent,
                  base::Unretained(coded_frame_provider_host_.get())));
 }
 
 void AvStreamerTest::OnFifoRead() {
-  base::MessageLoopProxy::current()->PostTask(
-      FROM_HERE,
-      base::Bind(&AvStreamerProxy::OnFifoReadEvent,
-                 base::Unretained(av_buffer_proxy_.get())));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&AvStreamerProxy::OnFifoReadEvent,
+                            base::Unretained(av_buffer_proxy_.get())));
 }
 
 TEST_F(AvStreamerTest, FastProviderSlowConsumer) {
   bool provider_delayed_pattern[] = { false };
   bool consumer_delayed_pattern[] = { true };
 
   const size_t frame_count = 100u;
   Configure(
       frame_count,
       std::vector<bool>(
@@ skipping 55 matching lines @@
 
   scoped_ptr<base::MessageLoop> message_loop(new base::MessageLoop());
   message_loop->PostTask(
       FROM_HERE,
       base::Bind(&AvStreamerTest::Start, base::Unretained(this)));
   message_loop->Run();
 };
 
 }  // namespace media
 }  // namespace chromecast