third_party/WebKit/Source/modules/webaudio/AudioWorkletGlobalScopeTest.cpp - chromium/src.git - Git at Google

 // Copyright 2017 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 "modules/webaudio/AudioWorkletGlobalScope.h"

 #include "bindings/core/v8/ScriptSourceCode.h"
 #include "bindings/core/v8/ScriptValue.h"
 #include "bindings/core/v8/SourceLocation.h"
 #include "bindings/core/v8/ToV8ForCore.h"
 #include "bindings/core/v8/V8BindingForCore.h"
 #include "bindings/core/v8/V8BindingForTesting.h"
 #include "bindings/core/v8/V8GCController.h"
 #include "bindings/core/v8/WorkerOrWorkletScriptController.h"
 #include "core/dom/TaskRunnerHelper.h"
 #include "core/workers/WorkerBackingThread.h"
 #include "core/workers/WorkerReportingProxy.h"
 #include "core/workers/WorkerThreadStartupData.h"
 #include "modules/webaudio/AudioBuffer.h"
 #include "modules/webaudio/AudioWorkletProcessor.h"
 #include "modules/webaudio/AudioWorkletProcessorDefinition.h"
 #include "modules/webaudio/AudioWorkletThread.h"
 #include "platform/bindings/ScriptState.h"
 #include "platform/bindings/V8BindingMacros.h"
 #include "platform/bindings/V8ObjectConstructor.h"
 #include "platform/weborigin/SecurityOrigin.h"
 #include "testing/gtest/include/gtest/gtest.h"

 namespace blink {

 namespace {

 static const size_t kRenderQuantumFrames = 128;

 // This is a typical sample rate.
 static const float kTestingSampleRate = 44100;

 }  // namespace

 class AudioWorkletGlobalScopeTest : public ::testing::Test {
  public:
   void SetUp() override {
     AudioWorkletThread::CreateSharedBackingThreadForTest();
     reporting_proxy_ = WTF::MakeUnique<WorkerReportingProxy>();
     security_origin_ =
         SecurityOrigin::Create(KURL(kParsedURLString, "http://fake.url/"));
   }

   void TearDown() override { AudioWorkletThread::ClearSharedBackingThread(); }

   std::unique_ptr<AudioWorkletThread> CreateAudioWorkletThread() {
     std::unique_ptr<AudioWorkletThread> thread =
         AudioWorkletThread::Create(nullptr, *reporting_proxy_);
     thread->Start(
         WorkerThreadStartupData::Create(
             KURL(kParsedURLString, "http://fake.url/"), "fake user agent", "",
             nullptr, kDontPauseWorkerGlobalScopeOnStart, nullptr, "",
             security_origin_.Get(), nullptr, kWebAddressSpaceLocal, nullptr,
             nullptr, WorkerV8Settings::Default()),
         ParentFrameTaskRunners::Create(nullptr));
     return thread;
   }

   void RunBasicTest(WorkerThread* thread) {
     WaitableEvent waitable_event;
     TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
         ->PostTask(
             BLINK_FROM_HERE,
             CrossThreadBind(
                 &AudioWorkletGlobalScopeTest::RunBasicTestOnWorkletThread,
                 CrossThreadUnretained(this), CrossThreadUnretained(thread),
                 CrossThreadUnretained(&waitable_event)));
     waitable_event.Wait();
   }

   void RunSimpleProcessTest(WorkerThread* thread) {
     WaitableEvent waitable_event;
     TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
         ->PostTask(BLINK_FROM_HERE,
                    CrossThreadBind(&AudioWorkletGlobalScopeTest::
                                        RunSimpleProcessTestOnWorkletThread,
                                    CrossThreadUnretained(this),
                                    CrossThreadUnretained(thread),
                                    CrossThreadUnretained(&waitable_event)));
     waitable_event.Wait();
   }

   void RunParsingTest(WorkerThread* thread) {
     WaitableEvent waitable_event;
     TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
         ->PostTask(
             BLINK_FROM_HERE,
             CrossThreadBind(
                 &AudioWorkletGlobalScopeTest::RunParsingTestOnWorkletThread,
                 CrossThreadUnretained(this), CrossThreadUnretained(thread),
                 CrossThreadUnretained(&waitable_event)));
     waitable_event.Wait();
   }

   void RunParsingParameterDescriptorTest(WorkerThread* thread) {
     WaitableEvent waitable_event;
     TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
         ->PostTask(
             BLINK_FROM_HERE,
             CrossThreadBind(
                 &AudioWorkletGlobalScopeTest::
                     RunParsingParameterDescriptorTestOnWorkletThread,
                 CrossThreadUnretained(this), CrossThreadUnretained(thread),
                 CrossThreadUnretained(&waitable_event)));
     waitable_event.Wait();
   }

  private:
   // Test if AudioWorkletGlobalScope and V8 components (ScriptState, Isolate)
   // are properly instantiated. Runs a simple processor registration and check
   // if the class definition is correctly registered, then instantiate an
   // AudioWorkletProcessor instance from the definition.
   void RunBasicTestOnWorkletThread(WorkerThread* thread,
                                    WaitableEvent* wait_event) {
     EXPECT_TRUE(thread->IsCurrentThread());

     AudioWorkletGlobalScope* global_scope =
         static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
     EXPECT_TRUE(global_scope);
     EXPECT_TRUE(global_scope->IsAudioWorkletGlobalScope());

     ScriptState* script_state =
         global_scope->ScriptController()->GetScriptState();
     EXPECT_TRUE(script_state);

     v8::Isolate* isolate = script_state->GetIsolate();
     EXPECT_TRUE(isolate);

     ScriptState::Scope scope(script_state);

     global_scope->ScriptController()->Evaluate(ScriptSourceCode(
         R"JS(
           registerProcessor('testProcessor', class {
               constructor () {}
               process () {}
             });
           )JS"));

     AudioWorkletProcessorDefinition* definition =
         global_scope->FindDefinition("testProcessor");
     EXPECT_TRUE(definition);
     EXPECT_EQ(definition->GetName(), "testProcessor");
     EXPECT_TRUE(definition->ConstructorLocal(isolate)->IsFunction());
     EXPECT_TRUE(definition->ProcessLocal(isolate)->IsFunction());

     AudioWorkletProcessor* processor =
         global_scope->CreateInstance("testProcessor");
     EXPECT_TRUE(processor);
     EXPECT_EQ(processor->GetName(), "testProcessor");
     EXPECT_TRUE(processor->InstanceLocal(isolate)->IsObject());

     wait_event->Signal();
   }

   // Test if various class definition patterns are parsed correctly.
   void RunParsingTestOnWorkletThread(WorkerThread* thread,
                                      WaitableEvent* wait_event) {
     EXPECT_TRUE(thread->IsCurrentThread());

     AudioWorkletGlobalScope* global_scope =
         static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
     ScriptState* script_state =
         global_scope->ScriptController()->GetScriptState();

     ScriptState::Scope scope(script_state);

     global_scope->ScriptController()->Evaluate(ScriptSourceCode(
         R"JS(
           var class1 = function () {};
           class1.prototype.process = function () {};
           registerProcessor('class1', class1);

           var class2 = function () {};
           class2.prototype = { process: function () {} };
           registerProcessor('class2', class2);

           var class3 = function () {};
           Object.defineProperty(class3, 'prototype', {
               get: function () {
                 return {
                   process: function () {}
                 };
               }
             });
           registerProcessor('class3', class3);
         )JS"));

     EXPECT_TRUE(global_scope->FindDefinition("class1"));
     EXPECT_TRUE(global_scope->FindDefinition("class2"));
     EXPECT_FALSE(global_scope->FindDefinition("class3"));

     wait_event->Signal();
   }

   // Test if the invocation of process() method in AudioWorkletProcessor and
   // AudioWorkletGlobalScope is performed correctly.
   void RunSimpleProcessTestOnWorkletThread(WorkerThread* thread,
                                            WaitableEvent* wait_event) {
     EXPECT_TRUE(thread->IsCurrentThread());

     AudioWorkletGlobalScope* global_scope =
         static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
     ScriptState* script_state =
         global_scope->ScriptController()->GetScriptState();

     ScriptState::Scope scope(script_state);

     global_scope->ScriptController()->Evaluate(ScriptSourceCode(
         R"JS(
           registerProcessor('testProcessor', class {
               constructor () {
                 this.constant = 1;
               }
               process (input, output) {
                 let inputChannelData = input.getChannelData(0);
                 let outputChannelData = output.getChannelData(0);
                 for (let i = 0; i < input.length; ++i) {
                   outputChannelData[i] = inputChannelData[i] + this.constant;
                 }
               }
             }
           )
         )JS"));

     AudioWorkletProcessor* processor =
         global_scope->CreateInstance("testProcessor");
     EXPECT_TRUE(processor);

     AudioBuffer* input_buffer =
         AudioBuffer::Create(1, kRenderQuantumFrames, kTestingSampleRate);
     AudioBuffer* output_buffer =
         AudioBuffer::Create(1, kRenderQuantumFrames, kTestingSampleRate);
     DOMFloat32Array* input_channel_data =
         input_buffer->getChannelData(0).View();
     float* input_array_data = input_channel_data->Data();
     EXPECT_TRUE(input_array_data);
     DOMFloat32Array* output_channel_data =
         output_buffer->getChannelData(0).View();
     float* output_array_data = output_channel_data->Data();
     EXPECT_TRUE(output_array_data);

     // Fill |inputBuffer| with 1 and zero out |outputBuffer|.
     std::fill(input_array_data, input_array_data + input_buffer->length(), 1);
     output_buffer->Zero();

     // Then invoke the process() method to perform JS buffer manipulation. The
     // output buffer should contain a constant value of 2.
     processor->Process(input_buffer, output_buffer);
     for (unsigned i = 0; i < output_buffer->length(); ++i) {
       EXPECT_EQ(output_array_data[i], 2);
     }

     wait_event->Signal();
   }

   void RunParsingParameterDescriptorTestOnWorkletThread(
       WorkerThread* thread,
       WaitableEvent* wait_event) {
     EXPECT_TRUE(thread->IsCurrentThread());

     AudioWorkletGlobalScope* global_scope =
         static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
     ScriptState* script_state =
         global_scope->ScriptController()->GetScriptState();

     ScriptState::Scope scope(script_state);

     global_scope->ScriptController()->Evaluate(ScriptSourceCode(
         R"JS(
           registerProcessor('testProcessor', class {
               static get parameterDescriptors () {
                 return [{
                   name: 'gain',
                   defaultValue: 0.707,
                   minValue: 0.0,
                   maxValue: 1.0
                 }];
               }
               constructor () {}
               process () {}
             }
           )
         )JS"));

     AudioWorkletProcessorDefinition* definition =
         global_scope->FindDefinition("testProcessor");
     EXPECT_TRUE(definition);
     EXPECT_EQ(definition->GetName(), "testProcessor");

     const Vector<String> param_names =
         definition->GetAudioParamDescriptorNames();
     EXPECT_EQ(param_names[0], "gain");

     const AudioParamDescriptor* descriptor =
         definition->GetAudioParamDescriptor(param_names[0]);
     EXPECT_EQ(descriptor->defaultValue(), 0.707f);
     EXPECT_EQ(descriptor->minValue(), 0.0f);
     EXPECT_EQ(descriptor->maxValue(), 1.0f);

     wait_event->Signal();
   }

   RefPtr<SecurityOrigin> security_origin_;
   std::unique_ptr<WorkerReportingProxy> reporting_proxy_;
 };

 TEST_F(AudioWorkletGlobalScopeTest, Basic) {
   std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
   RunBasicTest(thread.get());
   thread->TerminateAndWait();
 }

 TEST_F(AudioWorkletGlobalScopeTest, Parsing) {
   std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
   RunParsingTest(thread.get());
   thread->TerminateAndWait();
 }

 TEST_F(AudioWorkletGlobalScopeTest, BufferProcessing) {
   std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
   RunSimpleProcessTest(thread.get());
   thread->TerminateAndWait();
 }

 TEST_F(AudioWorkletGlobalScopeTest, ParsingParameterDescriptor) {
   std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
   RunParsingParameterDescriptorTest(thread.get());
   thread->TerminateAndWait();
 }

 }  // namespace blink
	// Copyright 2017 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 "modules/webaudio/AudioWorkletGlobalScope.h"

	#include "bindings/core/v8/ScriptSourceCode.h"
	#include "bindings/core/v8/ScriptValue.h"
	#include "bindings/core/v8/SourceLocation.h"
	#include "bindings/core/v8/ToV8ForCore.h"
	#include "bindings/core/v8/V8BindingForCore.h"
	#include "bindings/core/v8/V8BindingForTesting.h"
	#include "bindings/core/v8/V8GCController.h"
	#include "bindings/core/v8/WorkerOrWorkletScriptController.h"
	#include "core/dom/TaskRunnerHelper.h"
	#include "core/workers/WorkerBackingThread.h"
	#include "core/workers/WorkerReportingProxy.h"
	#include "core/workers/WorkerThreadStartupData.h"
	#include "modules/webaudio/AudioBuffer.h"
	#include "modules/webaudio/AudioWorkletProcessor.h"
	#include "modules/webaudio/AudioWorkletProcessorDefinition.h"
	#include "modules/webaudio/AudioWorkletThread.h"
	#include "platform/bindings/ScriptState.h"
	#include "platform/bindings/V8BindingMacros.h"
	#include "platform/bindings/V8ObjectConstructor.h"
	#include "platform/weborigin/SecurityOrigin.h"
	#include "testing/gtest/include/gtest/gtest.h"

	namespace blink {

	namespace {

	static const size_t kRenderQuantumFrames = 128;

	// This is a typical sample rate.
	static const float kTestingSampleRate = 44100;

	} // namespace

	class AudioWorkletGlobalScopeTest : public ::testing::Test {
	public:
	void SetUp() override {
	AudioWorkletThread::CreateSharedBackingThreadForTest();
	reporting_proxy_ = WTF::MakeUnique<WorkerReportingProxy>();
	security_origin_ =
	SecurityOrigin::Create(KURL(kParsedURLString, "http://fake.url/"));
	}

	void TearDown() override { AudioWorkletThread::ClearSharedBackingThread(); }

	std::unique_ptr<AudioWorkletThread> CreateAudioWorkletThread() {
	std::unique_ptr<AudioWorkletThread> thread =
	AudioWorkletThread::Create(nullptr, *reporting_proxy_);
	thread->Start(
	WorkerThreadStartupData::Create(
	KURL(kParsedURLString, "http://fake.url/"), "fake user agent", "",
	nullptr, kDontPauseWorkerGlobalScopeOnStart, nullptr, "",
	security_origin_.Get(), nullptr, kWebAddressSpaceLocal, nullptr,
	nullptr, WorkerV8Settings::Default()),
	ParentFrameTaskRunners::Create(nullptr));
	return thread;
	}

	void RunBasicTest(WorkerThread* thread) {
	WaitableEvent waitable_event;
	TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
	->PostTask(
	BLINK_FROM_HERE,
	CrossThreadBind(
	&AudioWorkletGlobalScopeTest::RunBasicTestOnWorkletThread,
	CrossThreadUnretained(this), CrossThreadUnretained(thread),
	CrossThreadUnretained(&waitable_event)));
	waitable_event.Wait();
	}

	void RunSimpleProcessTest(WorkerThread* thread) {
	WaitableEvent waitable_event;
	TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
	->PostTask(BLINK_FROM_HERE,
	CrossThreadBind(&AudioWorkletGlobalScopeTest::
	RunSimpleProcessTestOnWorkletThread,
	CrossThreadUnretained(this),
	CrossThreadUnretained(thread),
	CrossThreadUnretained(&waitable_event)));
	waitable_event.Wait();
	}

	void RunParsingTest(WorkerThread* thread) {
	WaitableEvent waitable_event;
	TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
	->PostTask(
	BLINK_FROM_HERE,
	CrossThreadBind(
	&AudioWorkletGlobalScopeTest::RunParsingTestOnWorkletThread,
	CrossThreadUnretained(this), CrossThreadUnretained(thread),
	CrossThreadUnretained(&waitable_event)));
	waitable_event.Wait();
	}

	void RunParsingParameterDescriptorTest(WorkerThread* thread) {
	WaitableEvent waitable_event;
	TaskRunnerHelper::Get(TaskType::kUnthrottled, thread)
	->PostTask(
	BLINK_FROM_HERE,
	CrossThreadBind(
	&AudioWorkletGlobalScopeTest::
	RunParsingParameterDescriptorTestOnWorkletThread,
	CrossThreadUnretained(this), CrossThreadUnretained(thread),
	CrossThreadUnretained(&waitable_event)));
	waitable_event.Wait();
	}

	private:
	// Test if AudioWorkletGlobalScope and V8 components (ScriptState, Isolate)
	// are properly instantiated. Runs a simple processor registration and check
	// if the class definition is correctly registered, then instantiate an
	// AudioWorkletProcessor instance from the definition.
	void RunBasicTestOnWorkletThread(WorkerThread* thread,
	WaitableEvent* wait_event) {
	EXPECT_TRUE(thread->IsCurrentThread());

	AudioWorkletGlobalScope* global_scope =
	static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
	EXPECT_TRUE(global_scope);
	EXPECT_TRUE(global_scope->IsAudioWorkletGlobalScope());

	ScriptState* script_state =
	global_scope->ScriptController()->GetScriptState();
	EXPECT_TRUE(script_state);

	v8::Isolate* isolate = script_state->GetIsolate();
	EXPECT_TRUE(isolate);

	ScriptState::Scope scope(script_state);

	global_scope->ScriptController()->Evaluate(ScriptSourceCode(
	R"JS(
	registerProcessor('testProcessor', class {
	constructor () {}
	process () {}
	});
	)JS"));

	AudioWorkletProcessorDefinition* definition =
	global_scope->FindDefinition("testProcessor");
	EXPECT_TRUE(definition);
	EXPECT_EQ(definition->GetName(), "testProcessor");
	EXPECT_TRUE(definition->ConstructorLocal(isolate)->IsFunction());
	EXPECT_TRUE(definition->ProcessLocal(isolate)->IsFunction());

	AudioWorkletProcessor* processor =
	global_scope->CreateInstance("testProcessor");
	EXPECT_TRUE(processor);
	EXPECT_EQ(processor->GetName(), "testProcessor");
	EXPECT_TRUE(processor->InstanceLocal(isolate)->IsObject());

	wait_event->Signal();
	}

	// Test if various class definition patterns are parsed correctly.
	void RunParsingTestOnWorkletThread(WorkerThread* thread,
	WaitableEvent* wait_event) {
	EXPECT_TRUE(thread->IsCurrentThread());

	AudioWorkletGlobalScope* global_scope =
	static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
	ScriptState* script_state =
	global_scope->ScriptController()->GetScriptState();

	ScriptState::Scope scope(script_state);

	global_scope->ScriptController()->Evaluate(ScriptSourceCode(
	R"JS(
	var class1 = function () {};
	class1.prototype.process = function () {};
	registerProcessor('class1', class1);

	var class2 = function () {};
	class2.prototype = { process: function () {} };
	registerProcessor('class2', class2);

	var class3 = function () {};
	Object.defineProperty(class3, 'prototype', {
	get: function () {
	return {
	process: function () {}
	};
	}
	});
	registerProcessor('class3', class3);
	)JS"));

	EXPECT_TRUE(global_scope->FindDefinition("class1"));
	EXPECT_TRUE(global_scope->FindDefinition("class2"));
	EXPECT_FALSE(global_scope->FindDefinition("class3"));

	wait_event->Signal();
	}

	// Test if the invocation of process() method in AudioWorkletProcessor and
	// AudioWorkletGlobalScope is performed correctly.
	void RunSimpleProcessTestOnWorkletThread(WorkerThread* thread,
	WaitableEvent* wait_event) {
	EXPECT_TRUE(thread->IsCurrentThread());

	AudioWorkletGlobalScope* global_scope =
	static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
	ScriptState* script_state =
	global_scope->ScriptController()->GetScriptState();

	ScriptState::Scope scope(script_state);

	global_scope->ScriptController()->Evaluate(ScriptSourceCode(
	R"JS(
	registerProcessor('testProcessor', class {
	constructor () {
	this.constant = 1;
	}
	process (input, output) {
	let inputChannelData = input.getChannelData(0);
	let outputChannelData = output.getChannelData(0);
	for (let i = 0; i < input.length; ++i) {
	outputChannelData[i] = inputChannelData[i] + this.constant;
	}
	}
	}
	)
	)JS"));

	AudioWorkletProcessor* processor =
	global_scope->CreateInstance("testProcessor");
	EXPECT_TRUE(processor);

	AudioBuffer* input_buffer =
	AudioBuffer::Create(1, kRenderQuantumFrames, kTestingSampleRate);
	AudioBuffer* output_buffer =
	AudioBuffer::Create(1, kRenderQuantumFrames, kTestingSampleRate);
	DOMFloat32Array* input_channel_data =
	input_buffer->getChannelData(0).View();
	float* input_array_data = input_channel_data->Data();
	EXPECT_TRUE(input_array_data);
	DOMFloat32Array* output_channel_data =
	output_buffer->getChannelData(0).View();
	float* output_array_data = output_channel_data->Data();
	EXPECT_TRUE(output_array_data);

	// Fill \|inputBuffer\| with 1 and zero out \|outputBuffer\|.
	std::fill(input_array_data, input_array_data + input_buffer->length(), 1);
	output_buffer->Zero();

	// Then invoke the process() method to perform JS buffer manipulation. The
	// output buffer should contain a constant value of 2.
	processor->Process(input_buffer, output_buffer);
	for (unsigned i = 0; i < output_buffer->length(); ++i) {
	EXPECT_EQ(output_array_data[i], 2);
	}

	wait_event->Signal();
	}

	void RunParsingParameterDescriptorTestOnWorkletThread(
	WorkerThread* thread,
	WaitableEvent* wait_event) {
	EXPECT_TRUE(thread->IsCurrentThread());

	AudioWorkletGlobalScope* global_scope =
	static_cast<AudioWorkletGlobalScope*>(thread->GlobalScope());
	ScriptState* script_state =
	global_scope->ScriptController()->GetScriptState();

	ScriptState::Scope scope(script_state);

	global_scope->ScriptController()->Evaluate(ScriptSourceCode(
	R"JS(
	registerProcessor('testProcessor', class {
	static get parameterDescriptors () {
	return [{
	name: 'gain',
	defaultValue: 0.707,
	minValue: 0.0,
	maxValue: 1.0
	}];
	}
	constructor () {}
	process () {}
	}
	)
	)JS"));

	AudioWorkletProcessorDefinition* definition =
	global_scope->FindDefinition("testProcessor");
	EXPECT_TRUE(definition);
	EXPECT_EQ(definition->GetName(), "testProcessor");

	const Vector<String> param_names =
	definition->GetAudioParamDescriptorNames();
	EXPECT_EQ(param_names[0], "gain");

	const AudioParamDescriptor* descriptor =
	definition->GetAudioParamDescriptor(param_names[0]);
	EXPECT_EQ(descriptor->defaultValue(), 0.707f);
	EXPECT_EQ(descriptor->minValue(), 0.0f);
	EXPECT_EQ(descriptor->maxValue(), 1.0f);

	wait_event->Signal();
	}

	RefPtr<SecurityOrigin> security_origin_;
	std::unique_ptr<WorkerReportingProxy> reporting_proxy_;
	};

	TEST_F(AudioWorkletGlobalScopeTest, Basic) {
	std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
	RunBasicTest(thread.get());
	thread->TerminateAndWait();
	}

	TEST_F(AudioWorkletGlobalScopeTest, Parsing) {
	std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
	RunParsingTest(thread.get());
	thread->TerminateAndWait();
	}

	TEST_F(AudioWorkletGlobalScopeTest, BufferProcessing) {
	std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
	RunSimpleProcessTest(thread.get());
	thread->TerminateAndWait();
	}

	TEST_F(AudioWorkletGlobalScopeTest, ParsingParameterDescriptor) {
	std::unique_ptr<AudioWorkletThread> thread = CreateAudioWorkletThread();
	RunParsingParameterDescriptorTest(thread.get());
	thread->TerminateAndWait();
	}

	} // namespace blink