Audio output debug recording.

media/audio/pulse/pulse_output.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/pulse/pulse_output.h"
 
 #include <pulse/pulseaudio.h>
 #include <stdint.h>
 
+#include "base/bind.h"
+#include "base/memory/ptr_util.h"
 #include "base/single_thread_task_runner.h"
 #include "base/time/time.h"
+#include "media/audio/audio_debug_recording_helper.h"
 #include "media/audio/audio_device_description.h"
+#include "media/audio/audio_file_writer.h"
 #include "media/audio/audio_manager_base.h"
 #include "media/audio/pulse/pulse_util.h"
 #include "media/base/audio_sample_types.h"
 
 namespace media {
 
 using pulse::AutoPulseLock;
 using pulse::WaitForOperationCompletion;
 
 // static, pa_stream_notify_cb
@@ skipping 28 matching lines @@
                               // want 32 because we're outputting
                               // floats.
                               32,
                               params.frames_per_buffer())),
       device_id_(device_id),
       manager_(manager),
       pa_context_(NULL),
       pa_mainloop_(NULL),
       pa_stream_(NULL),
       volume_(1.0f),
-      source_callback_(NULL) {
+      source_callback_(NULL),
+      debug_recording_helper_(base::MakeUnique<AudioDebugRecordingHelper>(
+          manager,
+          manager_->GetTaskRunner())) {
   CHECK(params_.IsValid());
   audio_bus_ = AudioBus::Create(params_);
 }
 
 PulseAudioOutputStream::~PulseAudioOutputStream() {
   // All internal structures should already have been freed in Close(), which
   // calls AudioManagerBase::ReleaseOutputStream() which deletes this object.
   DCHECK(!pa_stream_);
   DCHECK(!pa_context_);
   DCHECK(!pa_mainloop_);
@@ skipping 77 matching lines @@
       if (frames_filled < audio_bus_->frames()) {
         audio_bus_->ZeroFramesPartial(
             frames_filled, audio_bus_->frames() - frames_filled);
       }
 
       audio_bus_->Scale(volume_);
       audio_bus_->ToInterleaved<Float32SampleTypeTraits>(
           audio_bus_->frames(), reinterpret_cast<float*>(buffer));
     } else {
       memset(buffer, 0, bytes_to_fill);
+
+      // If we'll write the data to a debug file, also zero out the |audio_bus_|
+      // as it will be copied.
+      if (debug_recording_helper_->WillWrite())
+        audio_bus_->Zero();
     }
 
+    debug_recording_helper_->MaybeWrite(audio_bus_.get());

[Max Morin, 2017/01/20 07:49:09]

Move this below call to PA, to reduce risk of timeouts?

[Henrik Grunell, 2017/01/20 10:38:56]

Good point. Done.

+
     if (pa_stream_write(pa_stream_, buffer, bytes_to_fill, NULL, 0LL,
                         PA_SEEK_RELATIVE) < 0) {
       if (source_callback_) {
         source_callback_->OnError(this);
       }
     }
 
     // NOTE: As mentioned above, |bytes_remaining| may be negative after this.
     bytes_remaining -= bytes_to_fill;
 
@@ skipping 67 matching lines @@
   AutoPulseLock auto_lock(pa_mainloop_);
   volume_ = static_cast<float>(volume);
 }
 
 void PulseAudioOutputStream::GetVolume(double* volume) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   *volume = volume_;
 }
 
+void PulseAudioOutputStream::EnableDebugRecording(
+    const base::FilePath& file_name) {
+  debug_recording_helper_->EnableDebugRecording(params_, file_name);
+}
+
+void PulseAudioOutputStream::DisableDebugRecording() {
+  debug_recording_helper_->DisableDebugRecording();
+}
+
 }  // namespace media