MediaStreamAudioSourceNode.cpp [plain text]
#include "config.h"
#if ENABLE(WEB_AUDIO) && ENABLE(MEDIA_STREAM)
#include "MediaStreamAudioSourceNode.h"
#include "AudioContext.h"
#include "AudioNodeOutput.h"
#include "Logging.h"
#include <wtf/Locker.h>
namespace WebCore {
PassRefPtr<MediaStreamAudioSourceNode> MediaStreamAudioSourceNode::create(AudioContext* context, MediaStream* mediaStream, AudioSourceProvider* audioSourceProvider)
{
return adoptRef(new MediaStreamAudioSourceNode(context, mediaStream, audioSourceProvider));
}
MediaStreamAudioSourceNode::MediaStreamAudioSourceNode(AudioContext* context, MediaStream* mediaStream, AudioSourceProvider* audioSourceProvider)
: AudioNode(context, context->sampleRate())
, m_mediaStream(mediaStream)
, m_audioSourceProvider(audioSourceProvider)
, m_sourceNumberOfChannels(0)
{
addOutput(adoptPtr(new AudioNodeOutput(this, 2)));
setNodeType(NodeTypeMediaStreamAudioSource);
initialize();
}
MediaStreamAudioSourceNode::~MediaStreamAudioSourceNode()
{
uninitialize();
}
void MediaStreamAudioSourceNode::setFormat(size_t numberOfChannels, float sourceSampleRate)
{
if (numberOfChannels != m_sourceNumberOfChannels || sourceSampleRate != sampleRate()) {
if (!numberOfChannels || numberOfChannels > AudioContext::maxNumberOfChannels() || sourceSampleRate != sampleRate()) {
LOG(Media, "MediaStreamAudioSourceNode::setFormat(%u, %f) - unhandled format change", static_cast<unsigned>(numberOfChannels), sourceSampleRate);
m_sourceNumberOfChannels = 0;
return;
}
MutexLocker locker(m_processLock);
m_sourceNumberOfChannels = numberOfChannels;
{
AudioContext::AutoLocker contextLocker(context());
output(0)->setNumberOfChannels(numberOfChannels);
}
}
}
void MediaStreamAudioSourceNode::process(size_t numberOfFrames)
{
AudioBus* outputBus = output(0)->bus();
if (!audioSourceProvider()) {
outputBus->zero();
return;
}
if (!mediaStream() || m_sourceNumberOfChannels != outputBus->numberOfChannels()) {
outputBus->zero();
return;
}
MutexTryLocker tryLocker(m_processLock);
if (tryLocker.locked())
audioSourceProvider()->provideInput(outputBus, numberOfFrames);
else {
outputBus->zero();
}
}
void MediaStreamAudioSourceNode::reset()
{
}
}
#endif // ENABLE(WEB_AUDIO) && ENABLE(MEDIA_STREAM)