sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-02-01 10:40:56 +00:00
Code Issues Releases Wiki Activity

Send actual buffered byte count

Browse Source
This commit is contained in:
Jesse Hills 2024-01-11 09:50:34 +09:00
parent 709a92649c
commit 6e09f4b4d7
No known key found for this signature in database
GPG Key ID: BEAAE804EFD8E83A
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
esphome/components/esp_adf/microphone/esp_adf_microphone.cpp
View File

@ -177,15 +177,15 @@ void ESPADFMicrophone::read_task(void *params) {
continue; continue;
} }
event.type = TaskEventType::RUNNING;
event.err = bytes_read;
xQueueSend(this_mic->read_event_queue_, &event, 0);
int available = rb_bytes_available(this_mic->ring_buffer_); int available = rb_bytes_available(this_mic->ring_buffer_);
if (available < bytes_read) { if (available < bytes_read) {
rb_read(this_mic->ring_buffer_, nullptr, bytes_read - available, 0); rb_read(this_mic->ring_buffer_, nullptr, bytes_read - available, 0);
} }
rb_write(this_mic->ring_buffer_, (char *) buffer, bytes_read, 0); int written = rb_write(this_mic->ring_buffer_, (char *) buffer, bytes_read, 0);
event.type = TaskEventType::RUNNING;
event.err = written;
xQueueSend(this_mic->read_event_queue_, &event, 0);
} }
allocator.deallocate(buffer, BUFFER_SIZE / sizeof(int16_t)); allocator.deallocate(buffer, BUFFER_SIZE / sizeof(int16_t));