Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(213)

Unified Diff: media/blink/webaudiosourceprovider_impl.cc

Issue 2014963002: Revert of Reland: MediaCaptureFromElement: add support for audio captureStream(). (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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();
}

Powered by Google App Engine
This is Rietveld 408576698