itsmattkc
33a85aa059
than overwritten on some platforms Despite the fact we don't actually do any reading here, using QFile::WriteOnly on its own will truncate the file to 0 bytes which is undesirable. The documentation says QFile::ReadOnly, Append or NewOnly will prevent this. NewOnly won't work and reads are unnecessary, so Append was used initially. However on some platforms, Append will _only_ allow writing at the end of the file (ignoring the seek() function) meaning bytes won't be written where they're meant to be (this behavior happens on Linux and not on Windows, the platform discrepancy is likely a Qt bug). Using ReadWrite instead, despite not reading anything, prevents truncation and allows for writing not at the end of the file.
98 lines
2.2 KiB
C++
98 lines
2.2 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();
|
|
processor->SetParameters(params());
|
|
processors_.append(processor);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void AudioBackend::CloseInternal()
|
|
{
|
|
}
|
|
|
|
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, &RenderWorker::CompletedCache, this, &AudioBackend::ThreadCompletedCache);
|
|
}
|
|
|
|
void AudioBackend::ThreadCompletedCache(NodeDependency dep, NodeValueTable data, qint64 job_time)
|
|
{
|
|
SetWorkerBusyState(static_cast<RenderWorker*>(sender()), false);
|
|
|
|
if (job_time == render_job_info_.value(dep.range())) {
|
|
render_job_info_.remove(dep.range());
|
|
|
|
QByteArray cached_samples = data.Get(NodeParam::kSamples).toByteArray();
|
|
|
|
int offset = params().time_to_bytes(dep.in());
|
|
int length = params().time_to_bytes(dep.range().length());
|
|
int out_point = offset + length;
|
|
|
|
QFile f(CachePathName());
|
|
if (f.open(QFile::ReadWrite)) {
|
|
|
|
if (f.size() < out_point && !f.resize(out_point)) {
|
|
qCritical() << "Failed to resize file" << CachePathName();
|
|
}
|
|
|
|
if (!f.seek(offset)) {
|
|
qCritical() << "Failed to seek file" << CachePathName();
|
|
}
|
|
|
|
// Replace data with this data
|
|
int copy_length = qMin(length, cached_samples.size());
|
|
|
|
f.write(cached_samples.data(), copy_length);
|
|
|
|
if (copy_length < length) {
|
|
// Fill in remainder with silence
|
|
QByteArray empty_space(length - copy_length, 0);
|
|
f.write(empty_space);
|
|
}
|
|
|
|
f.close();
|
|
} else {
|
|
qWarning() << "Failed to write to cached PCM file";
|
|
}
|
|
}
|
|
|
|
CacheNext();
|
|
}
|