From e5fb1759b16d2c99487acc4fb0a2711afa3aa1dc Mon Sep 17 00:00:00 2001 From: jacqueline Date: Tue, 24 Jan 2023 16:39:52 +1100 Subject: Add a bunch of logging from playback stream investigatons --- src/audio/chunk.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'src/audio/chunk.cpp') diff --git a/src/audio/chunk.cpp b/src/audio/chunk.cpp index 5f8f3148..b37fdfed 100644 --- a/src/audio/chunk.cpp +++ b/src/audio/chunk.cpp @@ -7,12 +7,15 @@ #include #include "cbor.h" +#include "esp_log.h" #include "stream_buffer.hpp" #include "stream_message.hpp" namespace audio { +static const char* kTag = "chunk"; + ChunkWriter::ChunkWriter(StreamBuffer* buffer) : stream_(buffer), leftover_bytes_(0) {} @@ -53,9 +56,11 @@ auto ChunkWriter::WriteChunkToStream( // Try to write to the buffer. Note the return type here will be either 0 or // header_size + chunk_size, as MessageBuffer doesn't allow partial writes. + size_t intended_write_size = header_size.value() + chunk_size; + ESP_LOGI(kTag, "writing chunk of size %d", intended_write_size); size_t actual_write_size = xMessageBufferSend(stream_->Handle(), write_buffer.data(), - header_size.value() + chunk_size, max_wait); + intended_write_size, max_wait); if (actual_write_size == 0) { leftover_bytes_ = chunk_size; @@ -86,6 +91,7 @@ auto ChunkReader::ReadChunkFromStream( // First, wait for a message to arrive over the buffer. cpp::span new_data_dest = stream_->ReadBuffer().last( stream_->ReadBuffer().size() - leftover_bytes_); + ESP_LOGI(kTag, "reading chunk of size %d", new_data_dest.size()); last_message_size_ = xMessageBufferReceive( stream_->Handle(), new_data_dest.data(), new_data_dest.size(), max_wait); -- cgit v1.2.3