AudioWorklet prototype

third_party/WebKit/Source/modules/webaudio/BaseAudioContext.cpp

 /*
  * Copyright (C) 2010, Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1.  Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2.  Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 31 matching lines @@
 #include "core/inspector/ConsoleMessage.h"
 #include "core/inspector/ConsoleTypes.h"
 #include "modules/mediastream/MediaStream.h"
 #include "modules/webaudio/AnalyserNode.h"
 #include "modules/webaudio/AudioBuffer.h"
 #include "modules/webaudio/AudioBufferSourceNode.h"
 #include "modules/webaudio/AudioContext.h"
 #include "modules/webaudio/AudioListener.h"
 #include "modules/webaudio/AudioNodeInput.h"
 #include "modules/webaudio/AudioNodeOutput.h"
+#include "modules/webaudio/AudioWorkletMessagingProxy.h"
 #include "modules/webaudio/BiquadFilterNode.h"
 #include "modules/webaudio/ChannelMergerNode.h"
 #include "modules/webaudio/ChannelSplitterNode.h"
 #include "modules/webaudio/ConstantSourceNode.h"
 #include "modules/webaudio/ConvolverNode.h"
 #include "modules/webaudio/DelayNode.h"
 #include "modules/webaudio/DynamicsCompressorNode.h"
 #include "modules/webaudio/GainNode.h"
 #include "modules/webaudio/IIRFilterNode.h"
 #include "modules/webaudio/MediaElementAudioSourceNode.h"
@@ skipping 91 matching lines @@
   DCHECK(!active_source_nodes_.size());
   DCHECK(!is_resolving_resume_promises_);
   DCHECK(!resume_resolvers_.size());
   DCHECK(!autoplay_status_.has_value());
 }
 
 void BaseAudioContext::Initialize() {
   if (IsDestinationInitialized())
     return;
 
+  // At this point, AudioWorklet should be initialized. Cache the reference to
+  // it.
+  worklet_messaging_proxy_ = GetAudioWorklet()->GetWorkletMessagingProxy();
+
+  LOG(INFO) << "BaseAudioContext::Initialize AWMP_rendering_thread = "
+            << worklet_messaging_proxy_->GetRenderingThread();
+
+  // =========================================================================
+  // WebThread* rendering_thread =
+  //     destination()->GetAudioDestinationHandler().GetRenderingThread();
+
+  // LOG(INFO) << "rendering_thread = " << rendering_thread;
+
+  // // Reset the worklet thread. Not sure if this is okay.
+  // AudioWorkletThread::SetSharedBackingThread(rendering_thread);
+
+  // LOG(INFO) << "AudioWorkletThread = "
+  //           << WorkletThreadHolder<AudioWorkletThread>::GetInstance()->GetThread();
+
+  // worklet_messaging_proxy_ =
+  //     static_cast<AudioWorkletMessagingProxy*>(
+  //         audio_worklet_->GetWorkletGlobalScopeProxy());
+  // LOG(INFO) << "worklet_messaging_proxy_ = " << worklet_messaging_proxy_;
+
+  // worklet_messaging_proxy_->RequestProcessorDefinitionMap();
+  // =========================================================================
+
   FFTFrame::Initialize();
 
   if (destination_node_) {
     destination_node_->Handler().Initialize();
+
     // The AudioParams in the listener need access to the destination node, so
     // only create the listener if the destination node exists.
     listener_ = AudioListener::Create(*this);
   }
 }
 
 void BaseAudioContext::Clear() {
   destination_node_.Clear();
   // The audio rendering thread is dead.  Nobody will schedule AudioHandler
   // deletion.  Let's do it ourselves.
@@ skipping 812 matching lines @@
   visitor->Trace(active_source_nodes_);
   visitor->Trace(resume_resolvers_);
   visitor->Trace(success_callbacks_);
   visitor->Trace(error_callbacks_);
   visitor->Trace(decode_audio_resolvers_);
 
   visitor->Trace(periodic_wave_sine_);
   visitor->Trace(periodic_wave_square_);
   visitor->Trace(periodic_wave_sawtooth_);
   visitor->Trace(periodic_wave_triangle_);
+
+  visitor->Trace(worklet_messaging_proxy_);
+
   EventTargetWithInlineData::Trace(visitor);
   SuspendableObject::Trace(visitor);
 }
 
 DEFINE_TRACE_WRAPPERS(BaseAudioContext) {
   // Inform V8's GC that we have references to these objects so they
   // don't get collected until we're done with them.
   for (auto callback : success_callbacks_) {
     visitor->TraceWrappers(callback);
   }
   for (auto callback : error_callbacks_) {
     visitor->TraceWrappers(callback);
   }
 }
 
 SecurityOrigin* BaseAudioContext::GetSecurityOrigin() const {
   if (GetExecutionContext())
     return GetExecutionContext()->GetSecurityOrigin();
 
   return nullptr;
 }
 
+AudioWorklet* BaseAudioContext::GetAudioWorklet() {
+  return WindowAudioWorklet::audioWorklet(
+      *(SuspendableObject::GetExecutionContext()->ExecutingWindow()));
+}
+
+AudioWorkletMessagingProxy* BaseAudioContext::GetWorkletMessagingProxy() {
+  return worklet_messaging_proxy_;
+}
+
+WebThreadSupportingGC* BaseAudioContext::GetRenderingThread() {
+  return worklet_messaging_proxy_->GetRenderingThread();
+}
+
 }  // namespace blink