Replace AudioSilenceDetector with an AudioPowerMonitor.

content/browser/renderer_host/media/audio_renderer_host_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 "base/bind.h"
 #include "base/environment.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/process_util.h"
 #include "base/sync_socket.h"
 #include "content/browser/browser_thread_impl.h"
 #include "content/browser/renderer_host/media/audio_input_device_manager.h"
 #include "content/browser/renderer_host/media/audio_mirroring_manager.h"
 #include "content/browser/renderer_host/media/audio_renderer_host.h"
 #include "content/browser/renderer_host/media/media_stream_manager.h"
 #include "content/browser/renderer_host/media/mock_media_observer.h"
 #include "content/common/media/audio_messages.h"
 #include "content/common/media/media_stream_options.h"
 #include "ipc/ipc_message_utils.h"
 #include "media/audio/audio_manager.h"
 #include "media/audio/audio_manager_base.h"
 #include "media/audio/fake_audio_output_stream.h"
 #include "net/url_request/url_request_context.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using ::testing::_;
-using ::testing::AtLeast;
+using ::testing::Assign;
 using ::testing::DoAll;
-using ::testing::InSequence;
 using ::testing::NotNull;
-using ::testing::Return;
-using ::testing::SaveArg;
-using ::testing::SetArgumentPointee;
 
 namespace content {
 
 static const int kRenderProcessId = 1;
 static const int kRenderViewId = 4;
 static const int kStreamId = 50;
 
 class MockAudioMirroringManager : public AudioMirroringManager {
  public:
   MockAudioMirroringManager() {}
@@ skipping 111 matching lines @@
 
   DISALLOW_COPY_AND_ASSIGN(MockAudioRendererHost);
 };
 
 ACTION_P(QuitMessageLoop, message_loop) {
   message_loop->PostTask(FROM_HERE, base::MessageLoop::QuitClosure());
 }
 
 class AudioRendererHostTest : public testing::Test {
  public:
-  AudioRendererHostTest() {}
+  AudioRendererHostTest() : is_stream_active_(false) {}
 
  protected:
   virtual void SetUp() {
     // Create a message loop so AudioRendererHost can use it.
     message_loop_.reset(new base::MessageLoop(base::MessageLoop::TYPE_IO));
 
     // Claim to be on both the UI and IO threads to pass all the DCHECKS.
     io_thread_.reset(new BrowserThreadImpl(BrowserThread::IO,
                                            message_loop_.get()));
     ui_thread_.reset(new BrowserThreadImpl(BrowserThread::UI,
@@ skipping 15 matching lines @@
     host_->OnChannelClosing();
 
     // Release the reference to the mock object.  The object will be destructed
     // on message_loop_.
     host_ = NULL;
 
     // We need to continue running message_loop_ to complete all destructions.
     SyncWithAudioThread();
     audio_manager_.reset();
 
+    // Make sure the stream has been deleted before continuing.
+    while (is_stream_active_)
+      message_loop_->Run();
+
     io_thread_.reset();
     ui_thread_.reset();
 
     // Delete the IO message loop.  This will cause the MediaStreamManager to be
     // notified so it will stop its device thread and device managers.
     message_loop_.reset();
   }
 
-  void Create() {
+  void Create(bool unified_stream) {
     EXPECT_CALL(*observer_,
                 OnSetAudioStreamStatus(_, kStreamId, "created"));
     EXPECT_CALL(*host_.get(), OnStreamCreated(kStreamId, _))
-        .WillOnce(QuitMessageLoop(message_loop_.get()));
+        .WillOnce(DoAll(Assign(&is_stream_active_, true),
+                        QuitMessageLoop(message_loop_.get())));
     EXPECT_CALL(mirroring_manager_,
                 AddDiverter(kRenderProcessId, kRenderViewId, NotNull()))
         .RetiresOnSaturation();
 
     // Send a create stream message to the audio output stream and wait until
     // we receive the created message.
-    host_->OnCreateStream(kStreamId,
-                          kRenderViewId,
-                          0,
-                          media::AudioParameters(
-                              media::AudioParameters::AUDIO_FAKE,
-                              media::CHANNEL_LAYOUT_STEREO,
-                              media::AudioParameters::kAudioCDSampleRate, 16,
-                              media::AudioParameters::kAudioCDSampleRate / 10));
+    int session_id;
+    media::AudioParameters params;
+    if (unified_stream) {
+      // Use AudioInputDeviceManager::kFakeOpenSessionId as the session id to
+      // pass the permission check.
+      session_id = AudioInputDeviceManager::kFakeOpenSessionId;
+      params = media::AudioParameters(
+          media::AudioParameters::AUDIO_FAKE,
+          media::CHANNEL_LAYOUT_STEREO,
+          2,
+          media::AudioParameters::kAudioCDSampleRate, 16,
+          media::AudioParameters::kAudioCDSampleRate / 10);
+    } else {
+      session_id = 0;
+      params = media::AudioParameters(
+          media::AudioParameters::AUDIO_FAKE,
+          media::CHANNEL_LAYOUT_STEREO,
+          media::AudioParameters::kAudioCDSampleRate, 16,
+          media::AudioParameters::kAudioCDSampleRate / 10);
+    }
+    host_->OnCreateStream(kStreamId, kRenderViewId, session_id, params);
     message_loop_->Run();
 
     // At some point in the future, a corresponding RemoveDiverter() call must
-    // be made.
-    EXPECT_CALL(mirroring_manager_,
-                RemoveDiverter(kRenderProcessId, kRenderViewId, NotNull()))
-        .RetiresOnSaturation();
-
-    // All created streams should ultimately be closed.
-    EXPECT_CALL(*observer_,
-                OnSetAudioStreamStatus(_, kStreamId, "closed"));
-
-    // Expect the audio stream will be deleted at some later point.
-    EXPECT_CALL(*observer_, OnDeleteAudioStream(_, kStreamId));
-  }
-
-  void CreateUnifiedStream() {
-    EXPECT_CALL(*observer_,
-                OnSetAudioStreamStatus(_, kStreamId, "created"));
-    EXPECT_CALL(*host_.get(), OnStreamCreated(kStreamId, _))
-        .WillOnce(QuitMessageLoop(message_loop_.get()));
-    EXPECT_CALL(mirroring_manager_,
-                AddDiverter(kRenderProcessId, kRenderViewId, NotNull()))
-        .RetiresOnSaturation();
-    // Send a create stream message to the audio output stream and wait until
-    // we receive the created message.
-    // Use AudioInputDeviceManager::kFakeOpenSessionId as the session id to
-    // pass the permission check.
-    host_->OnCreateStream(kStreamId,
-                          kRenderViewId,
-                          AudioInputDeviceManager::kFakeOpenSessionId,
-                          media::AudioParameters(
-                              media::AudioParameters::AUDIO_FAKE,
-                              media::CHANNEL_LAYOUT_STEREO,
-                              2,
-                              media::AudioParameters::kAudioCDSampleRate, 16,
-                              media::AudioParameters::kAudioCDSampleRate / 10));
-    message_loop_->Run();
-
-    // At some point in the future, a corresponding RemoveDiverter() call must
     // be made.
     EXPECT_CALL(mirroring_manager_,
                 RemoveDiverter(kRenderProcessId, kRenderViewId, NotNull()))
         .RetiresOnSaturation();
 
     // All created streams should ultimately be closed.
     EXPECT_CALL(*observer_,
                 OnSetAudioStreamStatus(_, kStreamId, "closed"));
 
     // Expect the audio stream will be deleted at some later point.
-    EXPECT_CALL(*observer_, OnDeleteAudioStream(_, kStreamId));
+    EXPECT_CALL(*observer_, OnDeleteAudioStream(_, kStreamId))
+        .WillOnce(DoAll(Assign(&is_stream_active_, false),
+                        QuitMessageLoop(message_loop_.get())));
   }
 
   void Close() {
     // Send a message to AudioRendererHost to tell it we want to close the
     // stream.
     host_->OnCloseStream(kStreamId);
-    message_loop_->RunUntilIdle();
+    message_loop_->Run();
   }
 
   void Play() {
     EXPECT_CALL(*observer_,
                 OnSetAudioStreamPlaying(_, kStreamId, true));
     EXPECT_CALL(*host_.get(), OnStreamPlaying(kStreamId))
         .WillOnce(QuitMessageLoop(message_loop_.get()));
 
     host_->OnPlayStream(kStreamId);
     message_loop_->Run();
@@ skipping 63 matching lines @@
  private:
   scoped_ptr<MockMediaInternals> observer_;
   MockAudioMirroringManager mirroring_manager_;
   scoped_refptr<MockAudioRendererHost> host_;
   scoped_ptr<base::MessageLoop> message_loop_;
   scoped_ptr<BrowserThreadImpl> io_thread_;
   scoped_ptr<BrowserThreadImpl> ui_thread_;
   scoped_ptr<media::AudioManager> audio_manager_;
   scoped_ptr<MediaStreamManager> media_stream_manager_;
 
+  bool is_stream_active_;
+
   DISALLOW_COPY_AND_ASSIGN(AudioRendererHostTest);
 };
 
 TEST_F(AudioRendererHostTest, CreateAndClose) {
-  Create();
+  Create(false);
   Close();
 }
 
 // Simulate the case where a stream is not properly closed.
 TEST_F(AudioRendererHostTest, CreateAndShutdown) {
-  Create();
+  Create(false);
 }
 
 TEST_F(AudioRendererHostTest, CreatePlayAndClose) {
-  Create();
+  Create(false);
   Play();
   Close();
 }
 
 TEST_F(AudioRendererHostTest, CreatePlayPauseAndClose) {
-  Create();
+  Create(false);
   Play();
   Pause();
   Close();
 }
 
 TEST_F(AudioRendererHostTest, SetVolume) {
-  Create();
+  Create(false);
   SetVolume(0.5);
   Play();
   Pause();
   Close();
 }
 
 // Simulate the case where a stream is not properly closed.
 TEST_F(AudioRendererHostTest, CreatePlayAndShutdown) {
-  Create();
+  Create(false);
   Play();
 }
 
 // Simulate the case where a stream is not properly closed.
 TEST_F(AudioRendererHostTest, CreatePlayPauseAndShutdown) {
-  Create();
+  Create(false);
   Play();
   Pause();
 }
 
 TEST_F(AudioRendererHostTest, SimulateError) {
-  Create();
+  Create(false);
   Play();
   SimulateError();
 }
 
 // Simulate the case when an error is generated on the browser process,
 // the audio device is closed but the render process try to close the
 // audio stream again.
 TEST_F(AudioRendererHostTest, SimulateErrorAndClose) {
-  Create();
+  Create(false);
   Play();
   SimulateError();
   Close();
 }
 
 TEST_F(AudioRendererHostTest, CreateUnifiedStreamAndClose) {
-  CreateUnifiedStream();
+  Create(true);
   Close();
 }
 
 // TODO(hclam): Add tests for data conversation in low latency mode.
 
 }  // namespace content