Improve logging related to start/stop and failure of audio input streams in Chrome

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 "base/strings/stringprintf.h"
 #include "build/build_config.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 {
 
@@ skipping 52 matching lines @@
 
 AudioManagerBase::AudioManagerBase(AudioLogFactory* audio_log_factory)
     : max_num_output_streams_(kDefaultMaxOutputStreams),
       max_num_input_streams_(kDefaultMaxInputStreams),
       num_output_streams_(0),
       num_input_streams_(0),
       // TODO(dalecurtis): Switch this to an ObserverListThreadSafe, so we don't
       // block the UI thread when swapping devices.
       output_listeners_(
           ObserverList<AudioDeviceListener>::NOTIFY_EXISTING_ONLY),
+      state_listeners_(ObserverList<StateChangeListener>::NOTIFY_EXISTING_ONLY),
       audio_thread_("AudioThread"),
       audio_log_factory_(audio_log_factory) {
 #if defined(OS_WIN)
   audio_thread_.init_com_with_mta(true);
 #elif defined(OS_MACOSX)
   // CoreAudio calls must occur on the main thread of the process, which in our
   // case is sadly the browser UI thread.  Failure to execute calls on the right
   // thread leads to crashes and odd behavior.  See http://crbug.com/158170.
   // TODO(dalecurtis): We should require the message loop to be passed in.
   if (base::MessageLoopForUI::IsCurrent()) {
@@ skipping 85 matching lines @@
   return stream;
 }
 
 AudioInputStream* AudioManagerBase::MakeAudioInputStream(
     const AudioParameters& params,
     const std::string& device_id) {
   // TODO(miu): Fix ~20 call points across several unit test modules to call
   // this method on the audio thread, then uncomment the following:
   // DCHECK(task_runner_->BelongsToCurrentThread());
 
+  std::string log_string = base::StringPrintf(
+      "MakeAudioInputStream(device_id=%s)", device_id.c_str());

[Henrik Grunell, 2014/08/22 16:14:43]

Is this id something that can identify someone?

[no longer working on chromium, 2014/08/25 08:20:05]

as I pointed out, we can't log the device_id due to privacy concern.

[henrika (OOO until Aug 14), 2014/08/25 12:47:45]

Removed.

But Shijing, we do log it at other places? Why is it not always a privacy
concern?

+  NotifyAllStateChangeListeners(log_string);
+
   if (!params.IsValid() || (params.channels() > kMaxInputChannels) ||
       device_id.empty()) {
     DLOG(ERROR) << "Audio parameters are invalid for device " << device_id;
     return NULL;
   }
 
   if (num_input_streams_ >= max_num_input_streams_) {
     DLOG(ERROR) << "Number of opened input audio streams "
                 << num_input_streams_
                 << " exceed the max allowed number " << max_num_input_streams_;
@@ skipping 11 matching lines @@
     case AudioParameters::AUDIO_FAKE:
       stream = FakeAudioInputStream::MakeFakeStream(this, params);
       break;
     default:
       stream = NULL;
       break;
   }
 
   if (stream) {
     ++num_input_streams_;
+    log_string = base::StringPrintf(
+        "MakeAudioInputStream => num_input_streams = %d", num_input_streams_);

[Henrik Grunell, 2014/08/22 16:14:43]

Do we need the above if we have this? What about the fail cases?

[henrika (OOO until Aug 14), 2014/08/25 12:47:45]

Thanks. Improved.

+    NotifyAllStateChangeListeners(log_string);
   }
 
   return stream;
 }
 
 AudioOutputStream* AudioManagerBase::MakeAudioOutputStreamProxy(
     const AudioParameters& params,
     const std::string& device_id) {
   DCHECK(task_runner_->BelongsToCurrentThread());
 
@@ skipping 79 matching lines @@
   // For example, pass the ownership to AudioManager so it can delete the
   // streams.
   --num_output_streams_;
   delete stream;
 }
 
 void AudioManagerBase::ReleaseInputStream(AudioInputStream* stream) {
   DCHECK(stream);
   // TODO(xians) : Have a clearer destruction path for the AudioInputStream.
   --num_input_streams_;
+  std::string log_string = base::StringPrintf(
+      "ReleaseInputStream => num_input_streams = %d",
+      num_input_streams_);
+  NotifyAllStateChangeListeners(log_string);
   delete stream;
 }
 
 void AudioManagerBase::Shutdown() {
   // Only true when we're sharing the UI message loop with the browser.  The UI
   // loop is no longer running at this time and browser destruction is imminent.
   if (task_runner_->BelongsToCurrentThread()) {
     ShutdownOnAudioThread();
   } else {
     task_runner_->PostTask(FROM_HERE, base::Bind(
@@ skipping 23 matching lines @@
   DCHECK(task_runner_->BelongsToCurrentThread());
   output_listeners_.RemoveObserver(listener);
 }
 
 void AudioManagerBase::NotifyAllOutputDeviceChangeListeners() {
   DCHECK(task_runner_->BelongsToCurrentThread());
   DVLOG(1) << "Firing OnDeviceChange() notifications.";
   FOR_EACH_OBSERVER(AudioDeviceListener, output_listeners_, OnDeviceChange());
 }
 
+void AudioManagerBase::AddStateChangeListener(StateChangeListener* listener) {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+  state_listeners_.AddObserver(listener);
+}
+
+void AudioManagerBase::RemoveStateChangeListener(
+    StateChangeListener* listener) {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+  state_listeners_.RemoveObserver(listener);
+}
+
+void AudioManagerBase::NotifyAllStateChangeListeners(const std::string& msg) {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+  std::string log_string("AMB::");
+  log_string += msg;
+  FOR_EACH_OBSERVER(
+      StateChangeListener, state_listeners_, OnStateChange(log_string));
+}
+
 AudioParameters AudioManagerBase::GetDefaultOutputStreamParameters() {
   return GetPreferredOutputStreamParameters(GetDefaultOutputDeviceID(),
       AudioParameters());
 }
 
 AudioParameters AudioManagerBase::GetOutputStreamParameters(
     const std::string& device_id) {
   return GetPreferredOutputStreamParameters(device_id,
       AudioParameters());
 }
@@ skipping 23 matching lines @@
 
   return 0;
 }
 
 scoped_ptr<AudioLog> AudioManagerBase::CreateAudioLog(
     AudioLogFactory::AudioComponent component) {
   return audio_log_factory_->CreateAudioLog(component);
 }
 
 }  // namespace media