tza/openauto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Revert last commit

Browse Source
This commit is contained in:
michal.szwaj 2018-03-25 11:51:17 +02:00
parent 18fa86b532
commit f9692b76a1
2 changed files with 5 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/f1x/openauto/autoapp/Projection/RtAudioOutput.hpp
View File

@ -55,7 +55,6 @@ private:
SequentialBuffer audioBuffer_;
std::unique_ptr<RtAudio> dac_;
std::mutex mutex_;
bool playbackRequested_;
};
}

17
src/autoapp/Projection/RtAudioOutput.cpp
View File

@ -32,7 +32,6 @@ RtAudioOutput::RtAudioOutput(uint32_t channelCount, uint32_t sampleSize, uint32_
: channelCount_(channelCount)
, sampleSize_(sampleSize)
, sampleRate_(sampleRate)
, playbackRequested_(false)
{
std::vector<RtAudio::Api> apis;
RtAudio::getCompiledApi(apis);
@ -55,7 +54,7 @@ bool RtAudioOutput::open()
RtAudio::StreamOptions streamOptions;
streamOptions.numberOfBuffers = 1;
streamOptions.flags = RTAUDIO_MINIMIZE_LATENCY | RTAUDIO_SCHEDULE_REALTIME;
uint32_t bufferFrames = 256;
uint32_t bufferFrames = 64;
dac_->openStream(&parameters, nullptr, RTAUDIO_SINT16, sampleRate_, &bufferFrames, &RtAudioOutput::audioBufferReadHandler, static_cast<void*>(this), &streamOptions);
return audioBuffer_.open(QIODevice::ReadWrite);
}
@ -75,10 +74,13 @@ bool RtAudioOutput::open()
void RtAudioOutput::write(const aasdk::common::DataConstBuffer& buffer)
{
audioBuffer_.write(reinterpret_cast<const char*>(buffer.cdata), buffer.size);
}
void RtAudioOutput::start()
{
std::lock_guard<decltype(mutex_)> lock(mutex_);
if(playbackRequested_ && dac_->isStreamOpen() && !dac_->isStreamRunning())
if(dac_->isStreamOpen() && !dac_->isStreamRunning())
{
try
{
@ -89,15 +91,6 @@ void RtAudioOutput::write(const aasdk::common::DataConstBuffer& buffer)
OPENAUTO_LOG(error) << "[RtAudioOutput] Failed to start audio output, what: " << e.what();
}
}
playbackRequested_ = false;
}
void RtAudioOutput::start()
{
std::lock_guard<decltype(mutex_)> lock(mutex_);
playbackRequested_ = true;
}
void RtAudioOutput::stop()