diff options
Diffstat (limited to 'chromium/third_party')
7 files changed, 59 insertions, 10 deletions
diff --git a/chromium/third_party/blink/renderer/modules/webaudio/audio_destination_node.h b/chromium/third_party/blink/renderer/modules/webaudio/audio_destination_node.h index 2d1a60c5bb5..604b3657547 100644 --- a/chromium/third_party/blink/renderer/modules/webaudio/audio_destination_node.h +++ b/chromium/third_party/blink/renderer/modules/webaudio/audio_destination_node.h @@ -55,6 +55,11 @@ class AudioDestinationHandler : public AudioHandler { // restart of the context. virtual void RestartRendering() = 0; + // The worklet thread change can happen when a context/destination is + // suspended. In that case, we prepare the worklet operation but do not start + // running. + virtual void PrepareTaskRunnerForWorklet() = 0; + size_t CurrentSampleFrame() const { return current_sample_frame_.load(std::memory_order_acquire); } diff --git a/chromium/third_party/blink/renderer/modules/webaudio/base_audio_context.cc b/chromium/third_party/blink/renderer/modules/webaudio/base_audio_context.cc index 7d200498668..35cb8108518 100644 --- a/chromium/third_party/blink/renderer/modules/webaudio/base_audio_context.cc +++ b/chromium/third_party/blink/renderer/modules/webaudio/base_audio_context.cc @@ -847,12 +847,24 @@ void BaseAudioContext::NotifyWorkletIsReady() { audioWorklet()->GetMessagingProxy()->GetBackingWorkerThread(); } - // If the context is running, restart the destination to switch the render - // thread with the worklet thread. When the context is suspended, the next - // resume() call will start rendering with the worklet thread. - // Note that restarting can happen right after the context construction. - if (ContextState() == kRunning) { - destination()->GetAudioDestinationHandler().RestartRendering(); + switch (ContextState()) { + case kRunning: + // If the context is running, restart the destination to switch the render + // thread with the worklet thread right away. + destination()->GetAudioDestinationHandler().RestartRendering(); + break; + case kSuspended: + // For the suspended context, the destination will use the worklet task + // runner for rendering. This also prevents the regular audio thread from + // touching worklet-related objects by blocking an invalid transitory + // state where the context state is suspended and the destination state is + // running. See: crbug.com/1403515 + destination()->GetAudioDestinationHandler().PrepareTaskRunnerForWorklet(); + break; + case kClosed: + // When the context is closed, no preparation for the worklet operations + // is necessary. + return; } } diff --git a/chromium/third_party/blink/renderer/modules/webaudio/offline_audio_destination_node.h b/chromium/third_party/blink/renderer/modules/webaudio/offline_audio_destination_node.h index cc184245bb5..fa3c30bed57 100644 --- a/chromium/third_party/blink/renderer/modules/webaudio/offline_audio_destination_node.h +++ b/chromium/third_party/blink/renderer/modules/webaudio/offline_audio_destination_node.h @@ -66,6 +66,8 @@ class OfflineAudioDestinationHandler final : public AudioDestinationHandler { void Pause() override; void Resume() override; uint32_t MaxChannelCount() const override; + void PrepareTaskRunnerForWorklet() override {} + void RestartRendering() override; diff --git a/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.cc b/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.cc index 71507ed2cce..3854a6bc7e5 100644 --- a/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.cc +++ b/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.cc @@ -342,4 +342,16 @@ RealtimeAudioDestinationNode* RealtimeAudioDestinationNode::Create( *context, latency_hint, sample_rate); } -} // namespace blink +void RealtimeAudioDestinationHandler::PrepareTaskRunnerForWorklet() { + DCHECK(IsMainThread()); + DCHECK_EQ(Context()->ContextState(), BaseAudioContext::kSuspended); + DCHECK(Context()->audioWorklet()); + DCHECK(Context()->audioWorklet()->IsReady()); + + platform_destination_->SetWorkletTaskRunner( + Context()->audioWorklet()->GetMessagingProxy() + ->GetBackingWorkerThread() + ->GetTaskRunner(TaskType::kInternalMediaRealTime)); +} + +} // namespace blink diff --git a/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.h b/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.h index 638d364afa3..aa7c270c19d 100644 --- a/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.h +++ b/chromium/third_party/blink/renderer/modules/webaudio/realtime_audio_destination_node.h @@ -69,6 +69,8 @@ class RealtimeAudioDestinationHandler final void RestartRendering() override; uint32_t MaxChannelCount() const override; double SampleRate() const override; + void PrepareTaskRunnerForWorklet() override; + // For AudioIOCallback. This is invoked by the platform audio destination to // get the next render quantum into |destination_bus| and update diff --git a/chromium/third_party/blink/renderer/platform/audio/audio_destination.cc b/chromium/third_party/blink/renderer/platform/audio/audio_destination.cc index fc176335163..0f776809408 100644 --- a/chromium/third_party/blink/renderer/platform/audio/audio_destination.cc +++ b/chromium/third_party/blink/renderer/platform/audio/audio_destination.cc @@ -270,15 +270,27 @@ void AudioDestination::Start() { SetDeviceState(DeviceState::kRunning); } +void AudioDestination::SetWorkletTaskRunner( + scoped_refptr<base::SingleThreadTaskRunner> worklet_task_runner) { + DCHECK(IsMainThread()); + TRACE_EVENT0("webaudio", "AudioDestination::SetWorkletTaskRunner"); + + if (worklet_task_runner_) { + DCHECK_EQ(worklet_task_runner_, worklet_task_runner); + return; + } + + worklet_task_runner_ = std::move(worklet_task_runner); +} + void AudioDestination::StartWithWorkletTaskRunner( scoped_refptr<base::SingleThreadTaskRunner> worklet_task_runner) { DCHECK(IsMainThread()); - DCHECK_EQ(worklet_task_runner_, nullptr); TRACE_EVENT0("webaudio", "AudioDestination::StartWithWorkletTaskRunner"); if (device_state_ != DeviceState::kStopped) return; - worklet_task_runner_ = std::move(worklet_task_runner); + SetWorkletTaskRunner(worklet_task_runner); web_audio_device_->Start(); SetDeviceState(DeviceState::kRunning); } diff --git a/chromium/third_party/blink/renderer/platform/audio/audio_destination.h b/chromium/third_party/blink/renderer/platform/audio/audio_destination.h index 458da42b9b5..6f8942b93e8 100644 --- a/chromium/third_party/blink/renderer/platform/audio/audio_destination.h +++ b/chromium/third_party/blink/renderer/platform/audio/audio_destination.h @@ -98,7 +98,11 @@ class PLATFORM_EXPORT AudioDestination virtual void Pause(); virtual void Resume(); - // Starts the destination with the AudioWorklet support. + // Sets the destination for worklet operation, but does not start rendering. + void SetWorkletTaskRunner( + scoped_refptr<base::SingleThreadTaskRunner> worklet_task_runner); + + // Starts rendering in the AudioWorklet mode. void StartWithWorkletTaskRunner( scoped_refptr<base::SingleThreadTaskRunner> worklet_task_runner); |