Stop media stream source when audio capture error occurs.

content/renderer/media/media_stream_audio_source.cc

 // Copyright 2014 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_source.h"
 
 #include "base/bind.h"
+#include "base/single_thread_task_runner.h"
+#include "base/threading/thread_task_runner_handle.h"
 #include "content/renderer/media/media_stream_audio_track.h"
 #include "third_party/WebKit/public/platform/WebMediaStreamSource.h"
 #include "third_party/WebKit/public/platform/WebString.h"
 
 namespace content {
 
 MediaStreamAudioSource::MediaStreamAudioSource(bool is_local_source)
     : is_local_source_(is_local_source),
       is_stopped_(false),
+      task_runner_(base::ThreadTaskRunnerHandle::Get()),
       weak_factory_(this) {
   DVLOG(1) << "MediaStreamAudioSource@" << this << "::MediaStreamAudioSource("
            << (is_local_source_ ? "local" : "remote") << " source)";
 }
 
 MediaStreamAudioSource::~MediaStreamAudioSource() {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
   DVLOG(1) << "MediaStreamAudioSource@" << this << " is being destroyed.";
 }
 
 // static
 MediaStreamAudioSource* MediaStreamAudioSource::From(
     const blink::WebMediaStreamSource& source) {
   if (source.isNull() ||
       source.getType() != blink::WebMediaStreamSource::TypeAudio) {
     return nullptr;
   }
   return static_cast<MediaStreamAudioSource*>(source.getExtraData());
 }
 
 bool MediaStreamAudioSource::ConnectToTrack(
     const blink::WebMediaStreamTrack& blink_track) {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
   DCHECK(!blink_track.isNull());
 
   // Sanity-check that there is not already a MediaStreamAudioTrack instance
   // associated with |blink_track|.
   if (MediaStreamAudioTrack::From(blink_track)) {
     LOG(DFATAL)
         << "Attempting to connect another source to a WebMediaStreamTrack.";
     return false;
   }
 
@@ skipping 31 matching lines @@
 media::AudioParameters MediaStreamAudioSource::GetAudioParameters() const {
   return deliverer_.GetAudioParameters();
 }
 
 void* MediaStreamAudioSource::GetClassIdentifier() const {
   return nullptr;
 }
 
 std::unique_ptr<MediaStreamAudioTrack>
 MediaStreamAudioSource::CreateMediaStreamAudioTrack(const std::string& id) {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
   return std::unique_ptr<MediaStreamAudioTrack>(
       new MediaStreamAudioTrack(is_local_source()));
 }
 
 bool MediaStreamAudioSource::EnsureSourceIsStarted() {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
   DVLOG(1) << "MediaStreamAudioSource@" << this << "::EnsureSourceIsStarted()";
   return true;
 }
 
 void MediaStreamAudioSource::EnsureSourceIsStopped() {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
   DVLOG(1) << "MediaStreamAudioSource@" << this << "::EnsureSourceIsStopped()";
 }
 
 void MediaStreamAudioSource::SetFormat(const media::AudioParameters& params) {
   DVLOG(1) << "MediaStreamAudioSource@" << this << "::SetFormat("
            << params.AsHumanReadableString() << "), was previously set to {"
            << deliverer_.GetAudioParameters().AsHumanReadableString() << "}.";
   deliverer_.OnSetFormat(params);
 }
 
 void MediaStreamAudioSource::DeliverDataToTracks(
     const media::AudioBus& audio_bus,
     base::TimeTicks reference_time) {
   deliverer_.OnData(audio_bus, reference_time);
 }
 
 void MediaStreamAudioSource::DoStopSource() {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
   EnsureSourceIsStopped();
   is_stopped_ = true;
 }
 
 void MediaStreamAudioSource::StopAudioDeliveryTo(MediaStreamAudioTrack* track) {
-  DCHECK(thread_checker_.CalledOnValidThread());
+  DCHECK(task_runner_->RunsTasksOnCurrentThread());
 
   const bool did_remove_last_track = deliverer_.RemoveConsumer(track);
   DVLOG(1) << "Removed MediaStreamAudioTrack@" << track
            << " as a consumer of MediaStreamAudioSource@" << this << '.';
 
   // The W3C spec requires a source automatically stop when the last track is
   // stopped.
   if (!is_stopped_ && did_remove_last_track)
     MediaStreamSource::StopSource();
 }
 
+void MediaStreamAudioSource::StopSourceOnError(const std::string& why) {
+  VLOG(1) << why;
+
+  // Stop source when error occurs.
+  task_runner_->PostTask(
+      FROM_HERE, base::Bind(&MediaStreamSource::StopSource, GetWeakPtr()));
+}
+
 }  // namespace content