Implement AudioWorkletProcessor interface

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

+// 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/AudioWorkletProcessorDefinition.h"
+
+#include "bindings/core/v8/ScriptState.h"
+#include "bindings/core/v8/ToV8.h"
+#include "bindings/core/v8/V8Binding.h"
+#include "bindings/core/v8/V8BindingMacros.h"
+#include "bindings/core/v8/V8ObjectConstructor.h"
+#include "core/dom/ExecutionContext.h"
+#include "modules/webaudio/AudioBuffer.h"
+#include "wtf/PtrUtil.h"
+
+namespace blink {
+
+AudioWorkletProcessorDefinition* AudioWorkletProcessorDefinition::create(
+    ScriptState* scriptState,
+    v8::Local<v8::Function> constructor,
+    v8::Local<v8::Function> process) {
+  return new AudioWorkletProcessorDefinition(scriptState, constructor, process);
+}
+
+AudioWorkletProcessorDefinition::AudioWorkletProcessorDefinition(
+    ScriptState* scriptState,
+    v8::Local<v8::Function> constructor,
+    v8::Local<v8::Function> process)
+    : m_scriptState(scriptState),
+      m_constructor(scriptState->isolate(), constructor),
+      m_process(scriptState->isolate(), process) {}
+
+AudioWorkletProcessorDefinition::~AudioWorkletProcessorDefinition() {}
+
+v8::Local<v8::Object> AudioWorkletProcessorDefinition::createInstance() {

[nhiroki, 2017/03/06 10:08:44]

Ditto: Can you add thread checks if possible?

[hongchan, 2017/03/06 20:06:12]

Hmm. AudioWorkletGlobalScope and this definition only can be accessed by the
worklet thread. The check requires us to pass in GlobalScope object to the
definition (for isContextThread() method). Is that what we want?

+  v8::Isolate* isolate = m_scriptState->isolate();
+  v8::Local<v8::Object> instance;
+  if (!V8ObjectConstructor::newInstance(isolate,
+                                        m_constructor.newLocal(isolate))
+           .ToLocal(&instance)) {
+    return v8::Local<v8::Object>();
+  }
+
+  return instance->Clone();
+}
+
+bool AudioWorkletProcessorDefinition::process(v8::Local<v8::Object> instance,
+                                              AudioBuffer* inputBuffer,
+                                              AudioBuffer* outputBuffer) {
+  ScriptState::Scope scope(m_scriptState.get());
+
+  v8::Isolate* isolate = m_scriptState->isolate();
+  v8::Local<v8::Value> argv[] = {
+      ToV8(inputBuffer, m_scriptState->context()->Global(), isolate),
+      ToV8(outputBuffer, m_scriptState->context()->Global(), isolate)};
+
+  v8::TryCatch block(isolate);
+  block.SetVerbose(true);
+
+  V8ScriptRunner::callFunction(m_process.newLocal(isolate),
+                               m_scriptState->getExecutionContext(), instance,
+                               WTF_ARRAY_LENGTH(argv), argv, isolate);
+
+  if (block.HasCaught()) {
+    return false;
+  }
+
+  return true;
+}
+
+}  // namespace blink