itsmattkc
8353b8d745
If the bytes retrieved is less than the bytes we expected for the time period we're rendering, we fill the remainder with silence. Fixes segfault trying to copy bytes that aren't actually allocated.
88 lines
1.9 KiB
C++
88 lines
1.9 KiB
C++
#include "audiobackend.h"
|
|
|
|
#include "audioworker.h"
|
|
|
|
AudioBackend::AudioBackend(QObject *parent) :
|
|
AudioRenderBackend(parent)
|
|
{
|
|
}
|
|
|
|
AudioBackend::~AudioBackend()
|
|
{
|
|
Close();
|
|
}
|
|
|
|
QIODevice *AudioBackend::GetAudioPullDevice()
|
|
{
|
|
pull_device_.setFileName(CachePathName());
|
|
|
|
return &pull_device_;
|
|
}
|
|
|
|
bool AudioBackend::InitInternal()
|
|
{
|
|
// Initiate one thread per CPU core
|
|
for (int i=0;i<threads().size();i++) {
|
|
// Create one processor object for each thread
|
|
AudioWorker* processor = new AudioWorker(decoder_cache());
|
|
processor->SetParameters(params());
|
|
processors_.append(processor);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void AudioBackend::CloseInternal()
|
|
{
|
|
// This backend doesn't init anything yet
|
|
}
|
|
|
|
bool AudioBackend::CompileInternal()
|
|
{
|
|
// This backend doesn't compile anything yet
|
|
return true;
|
|
}
|
|
|
|
void AudioBackend::DecompileInternal()
|
|
{
|
|
// This backend doesn't compile anything yet
|
|
}
|
|
|
|
void AudioBackend::ConnectWorkerToThis(RenderWorker *worker)
|
|
{
|
|
connect(worker, SIGNAL(CompletedCache(NodeDependency)), this, SLOT(ThreadCompletedCache(NodeDependency)));
|
|
}
|
|
|
|
void AudioBackend::ThreadCompletedCache(NodeDependency dep)
|
|
{
|
|
caching_ = false;
|
|
|
|
QByteArray cached_samples = dep.node()->get_cached_value(dep.range()).toByteArray();
|
|
|
|
int offset = params().time_to_bytes(dep.in());
|
|
int length = params().time_to_bytes(dep.range().length());
|
|
int out_point = offset + length;
|
|
|
|
if (pcm_data_.size() < out_point) {
|
|
pcm_data_.resize(out_point);
|
|
}
|
|
|
|
// Replace data with this data
|
|
int copy_length = qMin(length, cached_samples.size());
|
|
|
|
memcpy(pcm_data_.data() + offset, cached_samples.data(), static_cast<size_t>(copy_length));
|
|
|
|
if (copy_length < length) {
|
|
// Fill in remainder with silence
|
|
memset(pcm_data_.data() + offset + copy_length, 0, static_cast<size_t>(length - copy_length));
|
|
}
|
|
|
|
QFile f(CachePathName());
|
|
if (f.open(QFile::WriteOnly)) {
|
|
f.write(pcm_data_);
|
|
f.close();
|
|
}
|
|
|
|
CacheNext();
|
|
}
|