add audio-buffer-size command line flag support to the input audio for all the platforms

media/audio/audio_manager_base.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/audio_manager_base.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/command_line.h"
 #include "base/strings/string_number_conversions.h"
 #include "build/build_config.h"
+#include "media/audio/audio_input_proxy.h"
 #include "media/audio/audio_output_dispatcher_impl.h"
 #include "media/audio/audio_output_proxy.h"
 #include "media/audio/audio_output_resampler.h"
 #include "media/audio/fake_audio_input_stream.h"
 #include "media/audio/fake_audio_output_stream.h"
 #include "media/base/media_switches.h"
 
 namespace media {
 
 static const int kStreamCloseDelaySeconds = 5;
@@ skipping 174 matching lines @@
                 << num_input_streams_
                 << " exceed the max allowed number " << max_num_input_streams_;
     return NULL;
   }
 
   AudioInputStream* stream;
   switch (params.format()) {
     case AudioParameters::AUDIO_PCM_LINEAR:
       stream = MakeLinearInputStream(params, device_id);
       break;
-    case AudioParameters::AUDIO_PCM_LOW_LATENCY:
-      stream = MakeLowLatencyInputStream(params, device_id);
+    case AudioParameters::AUDIO_PCM_LOW_LATENCY: {
+      const AudioParameters hardware_params =
+          GetSupportedInputHardwareParameters(device_id, params);
+      input_proxies_.push_back(
+          new AudioInputProxy(this, params, hardware_params, device_id));
+      stream = static_cast<AudioInputStream*>(input_proxies_.back());
       break;
+    }
     case AudioParameters::AUDIO_FAKE:
       stream = FakeAudioInputStream::MakeFakeStream(this, params);
       break;
     default:
       stream = NULL;
       break;
   }
 
   if (stream) {
     ++num_input_streams_;
@@ skipping 108 matching lines @@
     task_runner_->PostTask(FROM_HERE, base::Bind(
         &AudioManagerBase::ShutdownOnAudioThread, base::Unretained(this)));
   }
 
   // Stop() will wait for any posted messages to be processed first.
   audio_thread_.Stop();
 }
 
 void AudioManagerBase::ShutdownOnAudioThread() {
   DCHECK(task_runner_->BelongsToCurrentThread());
+  DCHECK(input_proxies_.empty());
   while (!output_dispatchers_.empty()) {
     output_dispatchers_.back()->dispatcher->Shutdown();
     output_dispatchers_.pop_back();
   }
+
+  while (!input_proxies_.empty())
+    input_proxies_.pop_back();
 }
 
 void AudioManagerBase::AddOutputDeviceChangeListener(
     AudioDeviceListener* listener) {
   DCHECK(task_runner_->BelongsToCurrentThread());
   output_listeners_.AddObserver(listener);
 }
 
 void AudioManagerBase::RemoveOutputDeviceChangeListener(
     AudioDeviceListener* listener) {
@@ skipping 13 matching lines @@
 }
 
 AudioParameters AudioManagerBase::GetOutputStreamParameters(
     const std::string& device_id) {
   return GetPreferredOutputStreamParameters(device_id,
       AudioParameters());
 }
 
 AudioParameters AudioManagerBase::GetInputStreamParameters(
     const std::string& device_id) {
-  NOTREACHED();
-  return AudioParameters();
+  return GetPreferredInputStreamParameters(device_id,
+                                           AudioParameters());
 }
 
 std::string AudioManagerBase::GetAssociatedOutputDeviceID(
     const std::string& input_device_id) {
   return "";
 }
 
 std::string AudioManagerBase::GetDefaultOutputDeviceID() {
   return "";
 }
 
 int AudioManagerBase::GetUserBufferSize() {
   const CommandLine* cmd_line = CommandLine::ForCurrentProcess();
   int buffer_size = 0;
   std::string buffer_size_str(cmd_line->GetSwitchValueASCII(
       switches::kAudioBufferSize));
   if (base::StringToInt(buffer_size_str, &buffer_size) && buffer_size > 0)
     return buffer_size;
 
   return 0;
 }
 
 scoped_ptr<AudioLog> AudioManagerBase::CreateAudioLog(
     AudioLogFactory::AudioComponent component) {
   return audio_log_factory_->CreateAudioLog(component);
 }
 
+AudioParameters AudioManagerBase::GetSupportedInputHardwareParameters(
+    const std::string& device_id, const AudioParameters& preferred_params) {
+  // Delete all the idle input proxy streams.
+  for (AudioInputProxies::iterator iter = input_proxies_.begin();
+       iter != input_proxies_.end();) {
+    if ((*iter)->is_idle())
+      input_proxies_.erase(iter++);
+    else
+      ++iter;
+  }
+
+//#if defined(OS_MACOSX)
+  // Find out if the existing streams using different format to open
+  // the device, if there is any, we should force all the existing streams and
+  // the new stream to use the native hardware parameters.
+  AudioParameters use_native_params;
+  for (AudioInputProxies::iterator iter = input_proxies_.begin();
+       iter != input_proxies_.end(); ++iter) {
+    if ((*iter)->device_id() == device_id &&
+        (*iter)->input_parameters() != preferred_params) {
+      if (!use_native_params.IsValid()) {
+        use_native_params = GetInputStreamParameters(device_id);
+        DCHECK(use_native_params.IsValid());
+      }
+
+      (*iter)->MaybeRestartStream(use_native_params);
+    }
+  }
+
+  if (use_native_params.IsValid())
+    return use_native_params;
+//#endif
+
+  return preferred_params;
+}
+
 }  // namespace media