addressing comment

This commit is contained in:
amer cerkic 2019-11-26 15:27:40 -08:00
parent 0de812b7b5
commit 168e85b26a

View file

@ -2065,7 +2065,7 @@ bool AudioClient::switchOutputToAudioDevice(const HifiAudioDeviceInfo outputDevi
_localSamplesAvailable.exchange(0, std::memory_order_release);
//wait on local injectors prep to finish running
if (_localPrepInjectorFuture.isStarted() || _localPrepInjectorFuture.isRunning()) {
if ( !_localPrepInjectorFuture.isFinished()) {
_localPrepInjectorFuture.waitForFinished();
}
@ -2347,9 +2347,9 @@ qint64 AudioClient::AudioOutputIODevice::readData(char * data, qint64 maxSize) {
qCDebug(audiostream, "Read %d samples from injectors (%d available, %d requested)", injectorSamplesPopped, _localInjectorsStream.samplesAvailable(), samplesRequested);
}
}
// prepare injectors for the next callback
_audio->_localPrepInjectorFuture = QtConcurrent::run(QThreadPool::globalInstance(), [this] {
_audio->_localPrepInjectorFuture = QtConcurrent::run(QThreadPool::globalInstance(), [this] {
_audio->prepareLocalAudioInjectors();
});