Add UMA stats for AEC filter divergence metric.

content/renderer/media/media_stream_audio_processor.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 "content/renderer/media/media_stream_audio_processor.h"
 
 #include <stddef.h>
 #include <stdint.h>
 #include <utility>
 
@@ skipping 269 matching lines @@
   // to Consume().  Only used when the FIFO is disabled.
   bool data_available_;
 };
 
 MediaStreamAudioProcessor::MediaStreamAudioProcessor(
     const blink::WebMediaConstraints& constraints,
     const MediaStreamDevice::AudioDeviceParameters& input_params,
     WebRtcPlayoutDataSource* playout_data_source)
     : render_delay_ms_(0),
       playout_data_source_(playout_data_source),
+      main_thread_message_loop_(base::MessageLoop::current()),
       audio_mirroring_(false),
       typing_detected_(false),
       stopped_(false) {
   capture_thread_checker_.DetachFromThread();
   render_thread_checker_.DetachFromThread();
   InitializeAudioProcessingModule(constraints, input_params);
 
   aec_dump_message_filter_ = AecDumpMessageFilter::Get();
   // In unit tests not creating a message filter, |aec_dump_message_filter_|
   // will be NULL. We can just ignore that. Other unit tests and browser tests
@@ skipping 82 matching lines @@
     output_bus->bus()->SwapChannels(0, 1);
   }
 
   *processed_data = output_bus->bus();
 
   return true;
 }
 
 void MediaStreamAudioProcessor::Stop() {
   DCHECK(main_thread_checker_.CalledOnValidThread());
+
   if (stopped_)
     return;
 
   stopped_ = true;
 
   if (aec_dump_message_filter_.get()) {
     aec_dump_message_filter_->RemoveDelegate(this);
     aec_dump_message_filter_ = NULL;
   }
 
   if (!audio_processing_.get())
     return;
 
   audio_processing_.get()->UpdateHistogramsOnCallEnd();
   StopEchoCancellationDump(audio_processing_.get());
 
   if (playout_data_source_) {
     playout_data_source_->RemovePlayoutSink(this);
     playout_data_source_ = NULL;
   }
+
+  if (echo_information_)
+    echo_information_->ReportAndResetAecDivergentFilterStats();
 }
 
 const media::AudioParameters& MediaStreamAudioProcessor::InputFormat() const {
   return input_format_;
 }
 
 const media::AudioParameters& MediaStreamAudioProcessor::OutputFormat() const {
   return output_format_;
 }
 
@@ skipping 327 matching lines @@
   DCHECK_EQ(err, 0) << "ProcessStream() error: " << err;
 
   if (typing_detector_) {
     webrtc::VoiceDetection* vad = ap->voice_detection();
     DCHECK(vad->is_enabled());
     bool detected = typing_detector_->Process(key_pressed,
                                               vad->stream_has_voice());
     base::subtle::Release_Store(&typing_detected_, detected);
   }
 
-  if (echo_information_) {
-    echo_information_.get()->UpdateAecDelayStats(ap->echo_cancellation());
-  }
+  main_thread_message_loop_->PostTask(
+      FROM_HERE, base::Bind(&MediaStreamAudioProcessor::UpdateAecStats, this));
 
   // Return 0 if the volume hasn't been changed, and otherwise the new volume.
   return (agc->stream_analog_level() == volume) ?
       0 : agc->stream_analog_level();
 }
 
+void MediaStreamAudioProcessor::UpdateAecStats() {
+  DCHECK(main_thread_checker_.CalledOnValidThread());
+  if (echo_information_)
+    echo_information_->UpdateAecStats(audio_processing_->echo_cancellation());
+}
+
 }  // namespace content