Adding APM configuration in AEC dump.

webrtc/modules/audio_processing/audio_processing_impl.cc

 /*
  *  Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 24 matching lines @@
 #include "webrtc/modules/audio_processing/noise_suppression_impl.h"
 #include "webrtc/modules/audio_processing/processing_component.h"
 #include "webrtc/modules/audio_processing/transient/transient_suppressor.h"
 #include "webrtc/modules/audio_processing/voice_detection_impl.h"
 #include "webrtc/modules/interface/module_common_types.h"
 #include "webrtc/system_wrappers/interface/critical_section_wrapper.h"
 #include "webrtc/system_wrappers/interface/file_wrapper.h"
 #include "webrtc/system_wrappers/interface/logging.h"
 #include "webrtc/system_wrappers/interface/metrics.h"
 
-#ifdef WEBRTC_AUDIOPROC_DEBUG_DUMP
-// Files generated at build-time by the protobuf compiler.
-#ifdef WEBRTC_ANDROID_PLATFORM_BUILD
-#include "external/webrtc/webrtc/modules/audio_processing/debug.pb.h"
-#else
-#include "webrtc/audio_processing/debug.pb.h"
-#endif
-#endif  // WEBRTC_AUDIOPROC_DEBUG_DUMP
-
 #define RETURN_ON_ERR(expr) \
   do {                      \
     int err = (expr);       \
     if (err != kNoError) {  \
       return err;           \
     }                       \
   } while (0)
 
+#define UPDATE_CONFIG(field_name, new_value) \
+  { \
+    const auto value = new_value; \
+    if (!config_->has_##field_name() || config_->field_name() != value) { \
+      config_->set_##field_name(value); \
+      changed = true; \
+    } \
+  }
+
 namespace webrtc {
 namespace {
 
 static bool LayoutHasKeyboard(AudioProcessing::ChannelLayout layout) {
   switch (layout) {
     case AudioProcessing::kMono:
     case AudioProcessing::kStereo:
       return false;
     case AudioProcessing::kMonoAndKeyboard:
     case AudioProcessing::kStereoAndKeyboard:
@@ skipping 115 matching lines @@
       echo_control_mobile_(NULL),
       gain_control_(NULL),
       high_pass_filter_(NULL),
       level_estimator_(NULL),
       noise_suppression_(NULL),
       voice_detection_(NULL),
       crit_(CriticalSectionWrapper::CreateCriticalSection()),
 #ifdef WEBRTC_AUDIOPROC_DEBUG_DUMP
       debug_file_(FileWrapper::Create()),
       event_msg_(new audioproc::Event()),
+      config_(new audioproc::Config()),
 #endif
       api_format_({{{kSampleRate16kHz, 1, false},
                     {kSampleRate16kHz, 1, false},
                     {kSampleRate16kHz, 1, false},
                     {kSampleRate16kHz, 1, false}}}),
       fwd_proc_format_(kSampleRate16kHz),
       rev_proc_format_(kSampleRate16kHz, 1),
       split_rate_(kSampleRate16kHz),
       stream_delay_ms_(0),
       delay_offset_ms_(0),
@@ skipping 36 matching lines @@
 
   noise_suppression_ = new NoiseSuppressionImpl(this, crit_);
   component_list_.push_back(noise_suppression_);
 
   voice_detection_ = new VoiceDetectionImpl(this, crit_);
   component_list_.push_back(voice_detection_);
 
   gain_control_for_new_agc_.reset(new GainControlForNewAgc(gain_control_));
 
   SetExtraOptions(config);
+
+#ifdef WEBRTC_AUDIOPROC_DEBUG_DUMP
+  UpdateCurrentConfig();
+#endif
 }
 
 AudioProcessingImpl::~AudioProcessingImpl() {
   {
     CriticalSectionScoped crit_scoped(crit_);
     // Depends on gain_control_ and gain_control_for_new_agc_.
     agc_manager_.reset();
     // Depends on gain_control_.
     gain_control_for_new_agc_.reset();
     while (!component_list_.empty()) {
@@ skipping 290 matching lines @@
 
   ProcessingConfig processing_config = api_format_;
   processing_config.input_stream() = input_config;
   processing_config.output_stream() = output_config;
 
   RETURN_ON_ERR(MaybeInitializeLocked(processing_config));
   assert(processing_config.input_stream().num_frames() ==
          api_format_.input_stream().num_frames());
 
 #ifdef WEBRTC_AUDIOPROC_DEBUG_DUMP
+  if (debug_file_->Open() && UpdateCurrentConfig()) {
+    RETURN_ON_ERR(WriteConfigMessage());
+  }
+#endif
+
+#ifdef WEBRTC_AUDIOPROC_DEBUG_DUMP
   if (debug_file_->Open()) {
     event_msg_->set_type(audioproc::Event::STREAM);
     audioproc::Stream* msg = event_msg_->mutable_stream();
     const size_t channel_size =
         sizeof(float) * api_format_.input_stream().num_frames();
     for (int i = 0; i < api_format_.input_stream().num_channels(); ++i)
       msg->add_input_channel(src[i], channel_size);
   }
 #endif
 
@@ skipping 366 matching lines @@
     if (debug_file_->CloseFile() == -1) {
       return kFileError;
     }
   }
 
   if (debug_file_->OpenFile(filename, false) == -1) {
     debug_file_->CloseFile();
     return kFileError;
   }
 
-  int err = WriteInitMessage();
+  UpdateCurrentConfig();
+  int err = WriteConfigMessage();
   if (err != kNoError) {
     return err;
   }
+
+  err = WriteInitMessage();
+  if (err != kNoError) {
+    return err;
+  }
   return kNoError;
 #else
   return kUnsupportedFunctionError;
 #endif  // WEBRTC_AUDIOPROC_DEBUG_DUMP
 }
 
 int AudioProcessingImpl::StartDebugRecording(FILE* handle) {
   CriticalSectionScoped crit_scoped(crit_);
 
   if (handle == NULL) {
     return kNullPointerError;
   }
 
 #ifdef WEBRTC_AUDIOPROC_DEBUG_DUMP
   // Stop any ongoing recording.
   if (debug_file_->Open()) {
     if (debug_file_->CloseFile() == -1) {
       return kFileError;
     }
   }
 
   if (debug_file_->OpenFromFileHandle(handle, true, false) == -1) {
     return kFileError;
   }
 
-  int err = WriteInitMessage();
+  UpdateCurrentConfig();
+  int err = WriteConfigMessage();
   if (err != kNoError) {
     return err;
   }
+
+  err = WriteInitMessage();
+  if (err != kNoError) {
+    return err;
+  }
   return kNoError;
 #else
   return kUnsupportedFunctionError;
 #endif  // WEBRTC_AUDIOPROC_DEBUG_DUMP
 }
 
 int AudioProcessingImpl::StartDebugRecordingForPlatformFile(
     rtc::PlatformFile handle) {
   FILE* stream = rtc::FdopenPlatformFileForWriting(handle);
   return StartDebugRecording(stream);
@@ skipping 256 matching lines @@
   msg->set_output_sample_rate(api_format_.output_stream().sample_rate_hz());
   // TODO(ekmeyerson): Add reverse output fields to event_msg_.
 
   int err = WriteMessageToDebugFile();
   if (err != kNoError) {
     return err;
   }
 
   return kNoError;
 }
+
+bool AudioProcessingImpl::UpdateCurrentConfig() {
+  bool changed = false;
+
+  // Acoustic echo canceler.
+  UPDATE_CONFIG(aec_enabled, echo_cancellation_->is_enabled());
+  UPDATE_CONFIG(aec_delay_agnostic,
+                echo_cancellation_->is_delay_agnostic_enabled());
+  UPDATE_CONFIG(aec_drift_compensation,
+                echo_cancellation_->is_drift_compensation_enabled());
+  UPDATE_CONFIG(aec_extended_filter,
+                echo_cancellation_->is_extended_filter_enabled());
+  UPDATE_CONFIG(aec_suppression_level,
+                static_cast<int>(echo_cancellation_->suppression_level()));
+  // Mobile AEC.
+  UPDATE_CONFIG(aecm_enabled, echo_control_mobile_->is_enabled());
+  UPDATE_CONFIG(aecm_comfort_noise,
+                echo_control_mobile_->is_comfort_noise_enabled());
+  UPDATE_CONFIG(aecm_routing_mode,
+                static_cast<int>(echo_control_mobile_->routing_mode()));
+  // Automatic gain controller.
+  UPDATE_CONFIG(agc_enabled, gain_control_->is_enabled());
+  UPDATE_CONFIG(agc_experiment, use_new_agc_);
+  UPDATE_CONFIG(agc_mode, static_cast<int>(gain_control_->mode()));
+  UPDATE_CONFIG(agc_limiter, gain_control_->is_limiter_enabled());
+  // High pass filter.
+  UPDATE_CONFIG(hpf_enabled, high_pass_filter_->is_enabled());
+  // Noise suppression.
+  UPDATE_CONFIG(ns_enabled, noise_suppression_->is_enabled());
+  UPDATE_CONFIG(ns_experiment, transient_suppressor_enabled_);
+  UPDATE_CONFIG(ns_level, static_cast<int>(noise_suppression_->level()));
+
+  return changed;
+}
+
+int AudioProcessingImpl::WriteConfigMessage() {
+  event_msg_->set_type(audioproc::Event::CONFIG);
+  event_msg_->mutable_config()->CopyFrom(*config_);
+
+  int err = WriteMessageToDebugFile();
+  if (err != kNoError) {
+    return err;
+  }
+
+  return kNoError;
+}
 #endif  // WEBRTC_AUDIOPROC_DEBUG_DUMP
 
 }  // namespace webrtc