WaveShaperProcessor.cpp [plain text]
#include "config.h"
#if ENABLE(WEB_AUDIO)
#include "WaveShaperProcessor.h"
#include "WaveShaperDSPKernel.h"
namespace WebCore {
WaveShaperProcessor::WaveShaperProcessor(float sampleRate, size_t numberOfChannels)
: AudioDSPKernelProcessor(sampleRate, numberOfChannels)
, m_oversample(OverSampleNone)
{
}
WaveShaperProcessor::~WaveShaperProcessor()
{
if (isInitialized())
uninitialize();
}
std::unique_ptr<AudioDSPKernel> WaveShaperProcessor::createKernel()
{
return std::make_unique<WaveShaperDSPKernel>(this);
}
void WaveShaperProcessor::setCurve(Float32Array* curve)
{
std::lock_guard<Lock> lock(m_processMutex);
m_curve = curve;
}
void WaveShaperProcessor::setOversample(OverSampleType oversample)
{
std::lock_guard<Lock> lock(m_processMutex);
m_oversample = oversample;
if (oversample != OverSampleNone) {
for (auto& audioDSPKernel : m_kernels) {
WaveShaperDSPKernel& kernel = static_cast<WaveShaperDSPKernel&>(*audioDSPKernel);
kernel.lazyInitializeOversampling();
}
}
}
void WaveShaperProcessor::process(const AudioBus* source, AudioBus* destination, size_t framesToProcess)
{
if (!isInitialized()) {
destination->zero();
return;
}
bool channelCountMatches = source->numberOfChannels() == destination->numberOfChannels() && source->numberOfChannels() == m_kernels.size();
ASSERT(channelCountMatches);
if (!channelCountMatches)
return;
std::unique_lock<Lock> lock(m_processMutex, std::try_to_lock);
if (!lock.owns_lock()) {
destination->zero();
return;
}
for (unsigned i = 0; i < m_kernels.size(); ++i)
m_kernels[i]->process(source->channel(i)->data(), destination->channel(i)->mutableData(), framesToProcess);
}
}
#endif // ENABLE(WEB_AUDIO)