Switch Speech Recognition to asynchronous callback-based AudioManager interactions.

content/browser/speech/speech_recognition_browsertest.cc

 // Copyright 2013 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 <stddef.h>
 #include <stdint.h>
 #include <string.h>
 
 #include <list>
 #include <memory>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "content/browser/speech/speech_recognition_engine.h"
 #include "content/browser/speech/speech_recognition_manager_impl.h"
 #include "content/browser/speech/speech_recognizer_impl.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/notification_types.h"
 #include "content/public/browser/web_contents.h"
 #include "content/public/test/browser_test_utils.h"
 #include "content/public/test/content_browser_test.h"
 #include "content/public/test/content_browser_test_utils.h"
 #include "content/public/test/test_utils.h"
 #include "content/shell/browser/shell.h"
 #include "content/test/mock_google_streaming_server.h"
+#include "media/audio/audio_system_impl.h"
 #include "media/audio/mock_audio_manager.h"
 #include "media/audio/test_audio_input_controller_factory.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using base::RunLoop;
 
 namespace content {
 
 class SpeechRecognitionBrowserTest :
     public ContentBrowserTest,
@@ skipping 75 matching lines @@
     media::AudioInputController::set_factory_for_testing(
         &test_audio_input_controller_factory_);
     mock_streaming_server_.reset(new MockGoogleStreamingServer(this));
     streaming_server_state_ = kIdle;
   }
 
   void SetUpOnMainThread() override {
     ASSERT_TRUE(SpeechRecognitionManagerImpl::GetInstance());
     media::AudioManager::StartHangMonitorIfNeeded(
         BrowserThread::GetTaskRunnerForThread(BrowserThread::IO));
-    SpeechRecognizerImpl::SetAudioManagerForTesting(new media::MockAudioManager(
+    audio_manager_.reset(new media::MockAudioManager(
         BrowserThread::GetTaskRunnerForThread(BrowserThread::IO)));
+    audio_manager_->SetInputStreamParameters(
+        media::AudioParameters::UnavailableDeviceParams());
+    audio_system_ = media::AudioSystemImpl::Create(audio_manager_.get());
+    SpeechRecognizerImpl::SetAudioSystemForTesting(audio_system_.get());
   }
 
   void TearDownOnMainThread() override {
-    SpeechRecognizerImpl::SetAudioManagerForTesting(NULL);
+    SpeechRecognizerImpl::SetAudioSystemForTesting(nullptr);
   }
 
   void TearDownInProcessBrowserTestFixture() override {
-    test_audio_input_controller_factory_.set_delegate(NULL);
+    test_audio_input_controller_factory_.set_delegate(nullptr);
     mock_streaming_server_.reset();
   }
 
  private:
   static void FeedSingleBufferToAudioController(
       scoped_refptr<media::TestAudioInputController> controller,
       size_t buffer_size,
       bool fill_with_noise) {
     DCHECK(controller.get());
     const media::AudioParameters& audio_params = controller->audio_parameters();
@@ skipping 37 matching lines @@
     }
   }
 
   SpeechRecognitionResult GetGoodSpeechResult() {
     SpeechRecognitionResult result;
     result.hypotheses.push_back(SpeechRecognitionHypothesis(
         base::UTF8ToUTF16("Pictures of the moon"), 1.0F));
     return result;
   }
 
+  media::MockAudioManager::UniquePtr audio_manager_;
+  std::unique_ptr<media::AudioSystem> audio_system_;
   StreamingServerState streaming_server_state_;
   std::unique_ptr<MockGoogleStreamingServer> mock_streaming_server_;
   media::TestAudioInputControllerFactory test_audio_input_controller_factory_;
 };
 
 // Simply loads the test page and checks if it was able to create a Speech
 // Recognition object in JavaScript, to make sure the Web Speech API is enabled.
 // Flaky on all platforms. http://crbug.com/396414.
 IN_PROC_BROWSER_TEST_F(SpeechRecognitionBrowserTest, DISABLED_Precheck) {
   NavigateToURLBlockUntilNavigationsComplete(
       shell(), GetTestUrlFromFragment("precheck"), 2);
 
   EXPECT_EQ(kIdle, streaming_server_state());
   EXPECT_EQ("success", GetPageFragment());
 }
 
 IN_PROC_BROWSER_TEST_F(SpeechRecognitionBrowserTest, OneShotRecognition) {
   NavigateToURLBlockUntilNavigationsComplete(
       shell(), GetTestUrlFromFragment("oneshot"), 2);
 
   EXPECT_EQ(kClientDisconnected, streaming_server_state());
   EXPECT_EQ("goodresult1", GetPageFragment());
 }
 
 }  // namespace content