}
CAudioOutput::~CAudioOutput() {
-
}
void CAudioOutput::onStream(CPulseAudioClient* pClient, size_t length) {
/* When write() is called in PulseAudio callback, bypass a pcm data to PulseAudioClient (For Asynchronous) */
if (mpPulseAudioClient->isInThread() == true) {
int ret = mpPulseAudioClient->write(buffer, length);
- if (ret == 0) {
- return length;
+ if (ret < 0) {
+ THROW_ERROR_MSG_FORMAT(CAudioError::EError::ERROR_INTERNAL_OPERATION, "The written result is invalid ret:%d", ret);
}
+ return length;
}
try {
AUDIO_IO_LOGD("PulseAudioClient->write(buffer:%p, length:%d)", buffer, l);
#endif
- int r = mpPulseAudioClient->write(buffer, l);
- if (r < 0) {
- THROW_ERROR_MSG_FORMAT(CAudioError::EError::ERROR_INTERNAL_OPERATION, "The written result is invalid ret:%d", r);
+ int ret = mpPulseAudioClient->write(buffer, l);
+ if (ret < 0) {
+ THROW_ERROR_MSG_FORMAT(CAudioError::EError::ERROR_INTERNAL_OPERATION, "The written result is invalid ret:%d", ret);
}
buffer = static_cast<const uint8_t*>(buffer) + l;