Git-Mirrors/portapack-mayhem
1
0
Fork 0
mirror of https://github.com/eried/portapack-mayhem.git synced 2024-10-01 01:26:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

Marginal attempt to simplify stream write loop.

Browse Source
This commit is contained in:
Jared Boone 2016-04-06 11:35:00 -07:00
parent fc8bb635a6
commit 08f4542954
1 changed files with 25 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
firmware/application/audio_thread.hpp
View File

@ -106,7 +106,8 @@ private:
return;
}
while( !chThdShouldTerminate() ) {
bool success = true;
while( success && !chThdShouldTerminate() ) {
chEvtWaitAny(EVT_FIFO_HIGHWATER);
auto fifo = reinterpret_cast<FIFO<uint8_t>*>(shared_memory.FIFO_HACK);
@ -116,25 +117,34 @@ private:
StreamOutput stream { fifo };
while( stream.available() >= write_buffer->size() ) {
led_usb.on();
const auto bytes_to_write = stream.read(write_buffer->data(), write_buffer->size());
if( bytes_to_write == write_buffer->size() ) {
if( !file.write(write_buffer->data(), write_buffer->size()) ) {
led_tx.on();
break;
}
} else {
break;
}
led_usb.off();
while( success && (stream.available() >= write_buffer->size()) ) {
success = transfer(stream, write_buffer.get());
}
}
if( !success ) {
led_tx.on();
}
file.close();
}
bool transfer(StreamOutput& stream, std::array<uint8_t, write_size>* const write_buffer) {
bool success = false;
led_usb.on();
const auto bytes_to_write = stream.read(write_buffer->data(), write_buffer->size());
if( bytes_to_write == write_buffer->size() ) {
if( file.write(write_buffer->data(), write_buffer->size()) ) {
success = true;
}
}
led_usb.off();
return success;
}
};
#endif/*__AUDIO_THREAD_H__*/