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 {
Ref<MediaStreamAudioSourceNode> MediaStreamAudioSourceNode::create(AudioContext* context, MediaStream* mediaStream, MediaStreamTrack* audioTrack, AudioSourceProvider* audioSourceProvider)
{
return adoptRef(*new MediaStreamAudioSourceNode(context, mediaStream, audioTrack, audioSourceProvider));
}
MediaStreamAudioSourceNode::MediaStreamAudioSourceNode(AudioContext* context, MediaStream* mediaStream, MediaStreamTrack* audioTrack, AudioSourceProvider* audioSourceProvider)
: AudioNode(context, context->sampleRate())
, m_mediaStream(mediaStream)
, m_audioTrack(audioTrack)
, m_audioSourceProvider(audioSourceProvider)
, m_sourceNumberOfChannels(0)
{
addOutput(std::make_unique<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;
}
std::lock_guard<std::mutex> lock(m_processMutex);
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;
}
std::unique_lock<std::mutex> lock(m_processMutex, std::try_to_lock);
if (!lock.owns_lock()) {
outputBus->zero();
return;
}
audioSourceProvider()->provideInput(outputBus, numberOfFrames);
}
void MediaStreamAudioSourceNode::reset()
{
}
}
#endif // ENABLE(WEB_AUDIO) && ENABLE(MEDIA_STREAM)