diff options
| author | jacqueline <me@jacqueline.id.au> | 2024-08-14 15:18:57 +1000 |
|---|---|---|
| committer | jacqueline <me@jacqueline.id.au> | 2024-08-14 15:18:57 +1000 |
| commit | 40c754a72a23a849321b60dbd77fa1303c77953b (patch) | |
| tree | dd10652e3b3e1c0c23a69a6f8e88301149df945a /src/drivers | |
| parent | 022aa38396cecb11b9de4b61665a6416378b4a95 (diff) | |
| download | tangara-fw-40c754a72a23a849321b60dbd77fa1303c77953b.tar.gz | |
Always initialise bytes_cleared when clearing PcmBuffers
Diffstat (limited to 'src/drivers')
| -rw-r--r-- | src/drivers/pcm_buffer.cpp | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/src/drivers/pcm_buffer.cpp b/src/drivers/pcm_buffer.cpp index 3f4a0443..142a6376 100644 --- a/src/drivers/pcm_buffer.cpp +++ b/src/drivers/pcm_buffer.cpp @@ -66,10 +66,17 @@ IRAM_ATTR auto PcmBuffer::receive(std::span<int16_t> dest, bool isr) auto PcmBuffer::clear() -> void { while (!isEmpty()) { - size_t bytes_cleared; + size_t bytes_cleared = 0; void* data = xRingbufferReceive(ringbuf_, &bytes_cleared, 0); - vRingbufferReturnItem(ringbuf_, data); - received_ += bytes_cleared / sizeof(int16_t); + if (data) { + vRingbufferReturnItem(ringbuf_, data); + received_ += bytes_cleared / sizeof(int16_t); + } else { + // Defensively guard against looping forever if for some reason the + // buffer isn't draining. + ESP_LOGW(kTag, "PcmBuffer not draining"); + break; + } } } |
