Remove calls to deprecated MessageLoop methods on Windows and Linux.

media/audio/win/audio_low_latency_input_win_unittest.cc

 // Copyright (c) 2012 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 "media/audio/win/audio_low_latency_input_win.h"
 
 #include <windows.h>
 #include <mmsystem.h>
 #include <stddef.h>
 #include <stdint.h>
 
 #include <memory>
 
 #include "base/environment.h"
 #include "base/files/file_util.h"
 #include "base/macros.h"
 #include "base/message_loop/message_loop.h"
 #include "base/path_service.h"
+#include "base/run_loop.h"
 #include "base/test/test_timeouts.h"
 #include "base/win/scoped_com_initializer.h"
 #include "media/audio/audio_device_description.h"
 #include "media/audio/audio_io.h"
 #include "media/audio/audio_manager.h"
 #include "media/audio/audio_unittest_util.h"
 #include "media/audio/win/core_audio_util_win.h"
 #include "media/base/seekable_buffer.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using ::testing::_;
 using ::testing::AnyNumber;
 using ::testing::AtLeast;
 using ::testing::Gt;
 using ::testing::NotNull;
 
 namespace media {
 
-ACTION_P3(CheckCountAndPostQuitTask, count, limit, loop) {
-  if (++*count >= limit) {
-    loop->PostTask(FROM_HERE, base::MessageLoop::QuitWhenIdleClosure());
-  }
+ACTION_P3(CheckCountAndPostQuitTask, count, limit, run_loop) {
+  if (++*count >= limit)
+    run_loop->QuitWhenIdle();
 }
 
 class MockAudioInputCallback : public AudioInputStream::AudioInputCallback {
  public:
   MOCK_METHOD4(OnData,
                void(AudioInputStream* stream,
                     const AudioBus* src,
                     uint32_t hardware_delay_bytes,
                     double volume));
   MOCK_METHOD1(OnError, void(AudioInputStream* stream));
@@ skipping 201 matching lines @@
   AudioInputStream* stream_;
 
   DISALLOW_COPY_AND_ASSIGN(ScopedAudioInputStream);
 };
 
 class WinAudioInputTest : public ::testing::Test {
  public:
   WinAudioInputTest() {
     audio_manager_ =
         AudioManager::CreateForTesting(message_loop_.task_runner());
-    message_loop_.RunUntilIdle();
+    base::RunLoop().RunUntilIdle();
   }
   ~WinAudioInputTest() override {
     audio_manager_.reset();
-    message_loop_.RunUntilIdle();
+    base::RunLoop().RunUntilIdle();
   }
 
  protected:
   base::MessageLoop message_loop_;
   ScopedAudioManagerPtr audio_manager_;
 };
 
 // Verify that we can retrieve the current hardware/mixing sample rate
 // for all available input devices.
 TEST_F(WinAudioInputTest, WASAPIAudioInputStreamHardwareSampleRate) {
@@ skipping 94 matching lines @@
   AudioInputStreamWrapper aisw(audio_manager_.get());
   ScopedAudioInputStream ais(aisw.Create());
   EXPECT_TRUE(ais->Open());
 
   MockAudioInputCallback sink;
 
   // Derive the expected size in bytes of each recorded packet.
   uint32_t bytes_per_packet =
       aisw.channels() * aisw.frames_per_buffer() * (aisw.bits_per_sample() / 8);
 
-  // We use 10ms packets and will run the test until ten packets are received.
-  // All should contain valid packets of the same size and a valid delay
-  // estimate.
-  EXPECT_CALL(sink, OnData(ais.get(), NotNull(), _, _))
-      .Times(AtLeast(10))
-      .WillRepeatedly(CheckCountAndPostQuitTask(&count, 10, &message_loop_));
-  ais->Start(&sink);
-  message_loop_.Run();
-  ais->Stop();
+  {
+    // We use 10ms packets and will run the test until ten packets are received.
+    // All should contain valid packets of the same size and a valid delay
+    // estimate.
+    base::RunLoop run_loop;
+    EXPECT_CALL(sink, OnData(ais.get(), NotNull(), _, _))
+        .Times(AtLeast(10))
+        .WillRepeatedly(CheckCountAndPostQuitTask(&count, 10, &run_loop));
+    ais->Start(&sink);
+    run_loop.Run();
+    ais->Stop();
+  }
 
   // Store current packet size (to be used in the subsequent tests).
   int frames_per_buffer_10ms = aisw.frames_per_buffer();
 
   ais.Close();
 
   // 20 ms packet size.
 
   count = 0;
   ais.Reset(aisw.Create(2 * frames_per_buffer_10ms));
   EXPECT_TRUE(ais->Open());
   bytes_per_packet = aisw.channels() * aisw.frames_per_buffer() *
       (aisw.bits_per_sample() / 8);
 
-  EXPECT_CALL(sink, OnData(ais.get(), NotNull(), _, _))
-      .Times(AtLeast(10))
-      .WillRepeatedly(CheckCountAndPostQuitTask(&count, 10, &message_loop_));
-  ais->Start(&sink);
-  message_loop_.Run();
-  ais->Stop();
-  ais.Close();
+  {
+    base::RunLoop run_loop;
+    EXPECT_CALL(sink, OnData(ais.get(), NotNull(), _, _))
+        .Times(AtLeast(10))
+        .WillRepeatedly(CheckCountAndPostQuitTask(&count, 10, &run_loop));
+    ais->Start(&sink);
+    run_loop.Run();
+    ais->Stop();
+    ais.Close();
+  }
 
   // 5 ms packet size.
 
   count = 0;
   ais.Reset(aisw.Create(frames_per_buffer_10ms / 2));
   EXPECT_TRUE(ais->Open());
   bytes_per_packet = aisw.channels() * aisw.frames_per_buffer() *
     (aisw.bits_per_sample() / 8);
 
-  EXPECT_CALL(sink, OnData(ais.get(), NotNull(), _, _))
-      .Times(AtLeast(10))
-      .WillRepeatedly(CheckCountAndPostQuitTask(&count, 10, &message_loop_));
-  ais->Start(&sink);
-  message_loop_.Run();
-  ais->Stop();
-  ais.Close();
+  {
+    base::RunLoop run_loop;
+    EXPECT_CALL(sink, OnData(ais.get(), NotNull(), _, _))
+        .Times(AtLeast(10))
+        .WillRepeatedly(CheckCountAndPostQuitTask(&count, 10, &run_loop));
+    ais->Start(&sink);
+    run_loop.Run();
+    ais->Stop();
+    ais.Close();
+  }
 }
 
 // Test that we can capture a stream in loopback.
 TEST_F(WinAudioInputTest, WASAPIAudioInputStreamLoopback) {
   ABORT_AUDIO_TEST_IF_NOT(audio_manager_->HasAudioOutputDevices() &&
                           CoreAudioUtil::IsSupported());
 
   AudioParameters params = audio_manager_->GetInputStreamParameters(
       AudioDeviceDescription::kLoopbackInputDeviceId);
   EXPECT_EQ(params.effects(), 0);
@@ skipping 40 matching lines @@
   WriteToFileAudioSink file_sink(file_name, aisw.bits_per_sample());
   VLOG(0) << ">> Speak into the default microphone while recording.";
   ais->Start(&file_sink);
   base::PlatformThread::Sleep(TestTimeouts::action_timeout());
   ais->Stop();
   VLOG(0) << ">> Recording has stopped.";
   ais.Close();
 }
 
 }  // namespace media