| Index: media/blink/webaudiosourceprovider_impl.cc
|
| diff --git a/media/blink/webaudiosourceprovider_impl.cc b/media/blink/webaudiosourceprovider_impl.cc
|
| index c4ddcc10d774098e6d015a4aaaf661221bda9581..3f052dbeb6f5a8f9759964cb534635f5e19ebd79 100644
|
| --- a/media/blink/webaudiosourceprovider_impl.cc
|
| +++ b/media/blink/webaudiosourceprovider_impl.cc
|
| @@ -50,21 +50,17 @@
|
|
|
| // TeeFilter is a RenderCallback implementation that allows for a client to get
|
| // a copy of the data being rendered by the |renderer_| on Render(). This class
|
| -// also holds on to the necessary audio parameters.
|
| +// also holds to the necessary audio parameters.
|
| class WebAudioSourceProviderImpl::TeeFilter
|
| : public AudioRendererSink::RenderCallback {
|
| public:
|
| - TeeFilter() : renderer_(nullptr), channels_(0), sample_rate_(0) {}
|
| + TeeFilter(AudioRendererSink::RenderCallback* renderer,
|
| + int channels,
|
| + int sample_rate)
|
| + : renderer_(renderer), channels_(channels), sample_rate_(sample_rate) {
|
| + DCHECK(renderer_);
|
| + }
|
| ~TeeFilter() override {}
|
| -
|
| - void Initialize(AudioRendererSink::RenderCallback* renderer,
|
| - int channels,
|
| - int sample_rate) {
|
| - DCHECK(renderer);
|
| - renderer_ = renderer;
|
| - channels_ = channels;
|
| - sample_rate_ = sample_rate;
|
| - }
|
|
|
| // AudioRendererSink::RenderCallback implementation.
|
| // These are forwarders to |renderer_| and are here to allow for a client to
|
| @@ -74,19 +70,19 @@
|
| uint32_t frames_skipped) override;
|
| void OnRenderError() override;
|
|
|
| - bool IsInitialized() const { return !!renderer_; }
|
| int channels() const { return channels_; }
|
| int sample_rate() const { return sample_rate_; }
|
| - void set_copy_audio_bus_callback(const CopyAudioCB& callback) {
|
| + void set_copy_audio_bus_callback(
|
| + const WebAudioSourceProviderImpl::CopyAudioCB& callback) {
|
| copy_audio_bus_callback_ = callback;
|
| }
|
|
|
| private:
|
| - AudioRendererSink::RenderCallback* renderer_;
|
| - int channels_;
|
| - int sample_rate_;
|
| -
|
| - CopyAudioCB copy_audio_bus_callback_;
|
| + AudioRendererSink::RenderCallback* const renderer_;
|
| + const int channels_;
|
| + const int sample_rate_;
|
| +
|
| + WebAudioSourceProviderImpl::CopyAudioCB copy_audio_bus_callback_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(TeeFilter);
|
| };
|
| @@ -97,7 +93,6 @@
|
| state_(kStopped),
|
| client_(nullptr),
|
| sink_(sink),
|
| - tee_filter_(new TeeFilter()),
|
| weak_factory_(this) {}
|
|
|
| WebAudioSourceProviderImpl::~WebAudioSourceProviderImpl() {
|
| @@ -116,11 +111,12 @@
|
| set_format_cb_ = BindToCurrentLoop(base::Bind(
|
| &WebAudioSourceProviderImpl::OnSetFormat, weak_factory_.GetWeakPtr()));
|
|
|
| - // If |tee_filter_| is Initialize()d - then run |set_format_cb_| to send
|
| - // |client_| the current format info. Otherwise |set_format_cb_| will get
|
| - // called when Initialize() is called. Note: Always using |set_format_cb_|
|
| - // ensures we have the same locking order when calling into |client_|.
|
| - if (tee_filter_->IsInitialized())
|
| + // If |tee_filter_| is set, it means we have been Initialize()d - then run
|
| + // |set_format_cb_| to send |client_| the current format info. Otherwise
|
| + // |set_format_cb_| will get called when Initialize() is called.
|
| + // Note: Always using |set_format_cb_| ensures we have the same locking
|
| + // order when calling into |client_|.
|
| + if (tee_filter_)
|
| base::ResetAndReturn(&set_format_cb_).Run();
|
| } else if (!client && client_) {
|
| // Restore normal playback.
|
| @@ -155,6 +151,7 @@
|
| }
|
|
|
| DCHECK(client_);
|
| + DCHECK(tee_filter_);
|
| DCHECK_EQ(tee_filter_->channels(), bus_wrapper_->channels());
|
| const int frames = tee_filter_->Render(bus_wrapper_.get(), 0, 0);
|
| if (frames < incoming_number_of_frames)
|
| @@ -224,7 +221,8 @@
|
| base::AutoLock auto_lock(sink_lock_);
|
| DCHECK_EQ(state_, kStopped);
|
|
|
| - tee_filter_->Initialize(renderer, params.channels(), params.sample_rate());
|
| + tee_filter_ = base::WrapUnique(
|
| + new TeeFilter(renderer, params.channels(), params.sample_rate()));
|
|
|
| sink_->Initialize(params, tee_filter_.get());
|
|
|
| @@ -235,10 +233,6 @@
|
| void WebAudioSourceProviderImpl::SetCopyAudioCallback(
|
| const CopyAudioCB& callback) {
|
| DCHECK(!callback.is_null());
|
| -
|
| - // Use |sink_lock_| to protect |tee_filter_| too since they go in lockstep.
|
| - base::AutoLock auto_lock(sink_lock_);
|
| -
|
| DCHECK(tee_filter_);
|
| tee_filter_->set_copy_audio_bus_callback(callback);
|
| }
|
| @@ -246,26 +240,24 @@
|
| void WebAudioSourceProviderImpl::ClearCopyAudioCallback() {
|
| DCHECK(tee_filter_);
|
| tee_filter_->set_copy_audio_bus_callback(CopyAudioCB());
|
| +}
|
| +
|
| +void WebAudioSourceProviderImpl::OnSetFormat() {
|
| + base::AutoLock auto_lock(sink_lock_);
|
| + if (!client_)
|
| + return;
|
| +
|
| + // Inform Blink about the audio stream format.
|
| + client_->setFormat(tee_filter_->channels(), tee_filter_->sample_rate());
|
| }
|
|
|
| int WebAudioSourceProviderImpl::RenderForTesting(AudioBus* audio_bus) {
|
| return tee_filter_->Render(audio_bus, 0, 0);
|
| -}
|
| -
|
| -void WebAudioSourceProviderImpl::OnSetFormat() {
|
| - base::AutoLock auto_lock(sink_lock_);
|
| - if (!client_)
|
| - return;
|
| -
|
| - // Inform Blink about the audio stream format.
|
| - client_->setFormat(tee_filter_->channels(), tee_filter_->sample_rate());
|
| }
|
|
|
| int WebAudioSourceProviderImpl::TeeFilter::Render(AudioBus* audio_bus,
|
| uint32_t delay_milliseconds,
|
| uint32_t frames_skipped) {
|
| - DCHECK(IsInitialized());
|
| -
|
| const int num_rendered_frames =
|
| renderer_->Render(audio_bus, delay_milliseconds, frames_skipped);
|
|
|
| @@ -281,7 +273,6 @@
|
| }
|
|
|
| void WebAudioSourceProviderImpl::TeeFilter::OnRenderError() {
|
| - DCHECK(IsInitialized());
|
| renderer_->OnRenderError();
|
| }
|
|
|
|
|