Implement BaseAudioContext

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

 // Copyright 2015 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/AudioContext.h"
 
 #include "bindings/core/v8/ExceptionMessages.h"
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "core/dom/DOMException.h"
 #include "core/dom/ExceptionCode.h"
+#include "core/html/HTMLMediaElement.h"
+#include "modules/mediastream/MediaStream.h"
 #include "modules/webaudio/AudioBufferCallback.h"
+#include "modules/webaudio/MediaElementAudioSourceNode.h"
+#include "modules/webaudio/MediaStreamAudioDestinationNode.h"
+#include "modules/webaudio/MediaStreamAudioSourceNode.h"
 #include "platform/audio/AudioUtilities.h"
 
 #if DEBUG_AUDIONODE_REFERENCES
 #include <stdio.h>
 #endif
 
 namespace blink {
 
 // Don't allow more than this number of simultaneous AudioContexts
 // talking to hardware.
 const unsigned MaxHardwareContexts = 6;
 static unsigned s_hardwareContextCount = 0;
 static unsigned s_contextId = 0;
 
-AbstractAudioContext* AudioContext::create(Document& document, ExceptionState& exceptionState)
+AudioContext* AudioContext::create(Document& document, ExceptionState& exceptionState)
 {
     ASSERT(isMainThread());
     if (s_hardwareContextCount >= MaxHardwareContexts) {
         exceptionState.throwDOMException(
             NotSupportedError,
             ExceptionMessages::indexExceedsMaximumBound(
                 "number of hardware contexts",
                 s_hardwareContextCount,
                 MaxHardwareContexts));
         return nullptr;
@@ skipping 25 matching lines @@
     ++s_hardwareContextCount;
 #if DEBUG_AUDIONODE_REFERENCES
     fprintf(stderr, "%p: AudioContext::AudioContext(): %u #%u\n",
         audioContext, audioContext->m_contextId, s_hardwareContextCount);
 #endif
 
     return audioContext;
 }
 
 AudioContext::AudioContext(Document& document)
-    : AbstractAudioContext(&document)
+    : BaseAudioContext(&document)
     , m_contextId(s_contextId++)
 {
 }
 
 AudioContext::~AudioContext()
 {
 #if DEBUG_AUDIONODE_REFERENCES
     fprintf(stderr, "%p: AudioContext::~AudioContext(): %u\n", this, m_contextId);
 #endif
 }
 
 DEFINE_TRACE(AudioContext)
 {
     visitor->trace(m_closeResolver);
-    AbstractAudioContext::trace(visitor);
+    BaseAudioContext::trace(visitor);
+}
+
+MediaElementAudioSourceNode* AudioContext::createMediaElementSource(HTMLMediaElement* mediaElement, ExceptionState& exceptionState)
+{
+    ASSERT(isMainThread());
+
+    if (isContextClosed()) {
+        throwExceptionForClosedState(exceptionState);
+        return nullptr;
+    }
+
+    // First check if this media element already has a source node.
+    if (mediaElement->audioSourceNode()) {
+        exceptionState.throwDOMException(
+            InvalidStateError,
+            "HTMLMediaElement already connected previously to a different MediaElementSourceNode.");
+        return nullptr;
+    }
+
+    MediaElementAudioSourceNode* node = MediaElementAudioSourceNode::create(*this, *mediaElement);
+
+    mediaElement->setAudioSourceNode(node);
+
+    notifySourceNodeStartedProcessing(node); // context keeps reference until node is disconnected
+    return node;
+}
+
+MediaStreamAudioSourceNode* AudioContext::createMediaStreamSource(MediaStream* mediaStream, ExceptionState& exceptionState)
+{
+    ASSERT(isMainThread());
+
+    if (isContextClosed()) {
+        throwExceptionForClosedState(exceptionState);
+        return nullptr;
+    }
+
+    MediaStreamTrackVector audioTracks = mediaStream->getAudioTracks();
+    if (audioTracks.isEmpty()) {
+        exceptionState.throwDOMException(
+            InvalidStateError,
+            "MediaStream has no audio track");
+        return nullptr;
+    }
+
+    // Use the first audio track in the media stream.
+    MediaStreamTrack* audioTrack = audioTracks[0];
+    OwnPtr<AudioSourceProvider> provider = audioTrack->createWebAudioSource();
+    MediaStreamAudioSourceNode* node = MediaStreamAudioSourceNode::create(*this, *mediaStream, audioTrack, provider.release());
+
+    // FIXME: Only stereo streams are supported right now. We should be able to accept multi-channel streams.
+    node->setFormat(2, sampleRate());
+
+    notifySourceNodeStartedProcessing(node); // context keeps reference until node is disconnected
+    return node;
+}
+
+MediaStreamAudioDestinationNode* AudioContext::createMediaStreamDestination(ExceptionState& exceptionState)
+{
+    if (isContextClosed()) {
+        throwExceptionForClosedState(exceptionState);
+        return nullptr;
+    }
+
+    // Set number of output channels to stereo by default.
+    return MediaStreamAudioDestinationNode::create(*this, 2);
 }
 
 ScriptPromise AudioContext::suspendContext(ScriptState* scriptState)
 {
     ASSERT(isMainThread());
     AutoLocker locker(this);
 
     ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
     ScriptPromise promise = resolver->promise();
 
@@ skipping 76 matching lines @@
 
     ASSERT(s_hardwareContextCount);
     --s_hardwareContextCount;
 
     if (m_closeResolver)
         m_closeResolver->resolve();
 }
 
 bool AudioContext::isContextClosed() const
 {
-    return m_closeResolver || AbstractAudioContext::isContextClosed();
+    return m_closeResolver || BaseAudioContext::isContextClosed();
 }
 
 void AudioContext::stopRendering()
 {
     ASSERT(isMainThread());
     ASSERT(destination());
 
     if (contextState() == Running) {
         destination()->audioDestinationHandler().stopRendering();
         setContextState(Suspended);
         deferredTaskHandler().clearHandlersToBeDeleted();
     }
 }
 
 } // namespace blink