From 222c810b07ffc635fc7908d121e97e4d65ccc5c8 Mon Sep 17 00:00:00 2001 From: jacqueline Date: Fri, 2 Dec 2022 13:39:00 +1100 Subject: fix build errors --- src/audio/include/chunk.hpp | 37 +++++++++++++++++++++++-------------- 1 file changed, 23 insertions(+), 14 deletions(-) (limited to 'src/audio/include/chunk.hpp') diff --git a/src/audio/include/chunk.hpp b/src/audio/include/chunk.hpp index a3f943ea..365c83d0 100644 --- a/src/audio/include/chunk.hpp +++ b/src/audio/include/chunk.hpp @@ -4,8 +4,13 @@ #include #include #include -#include "esp-idf/components/cbor/tinycbor/src/cbor.h" + +#include "freertos/FreeRTOS.h" + +#include "cbor.h" +#include "freertos/message_buffer.h" #include "freertos/portmacro.h" +#include "freertos/queue.h" #include "result.hpp" namespace audio { @@ -35,7 +40,22 @@ auto WriteChunksToStream(MessageBufferHandle_t* stream, uint8_t* working_buffer, size_t working_buffer_length, std::function callback, - TickType_t max_wait) -> EncodeWriteResult; + TickType_t max_wait) -> ChunkWriteResult; + +enum ChunkReadResult { + CHUNK_READ_OKAY, + // Returned when the chunk was read successfully, but the consumer did not + // use all of the data. + CHUNK_LEFTOVER_DATA, + // Returned an error in parsing the cbor-encoded header. + CHUNK_DECODING_ERROR, + // Returned when max_wait expired before any data was read. + CHUNK_READ_TIMEOUT, + // Returned when a non-chunk message is received. + CHUNK_STREAM_ENDED, + // Returned when the processing callback does not return a value. + CHUNK_PROCESSING_ERROR, +}; class ChunkReader { public: @@ -46,17 +66,6 @@ class ChunkReader { auto GetLastMessage() -> std::pair; - enum ChunkReadResult { - // Returned an error in parsing the cbor-encoded header. - CHUNK_DECODING_ERROR, - // Returned when max_wait expired before any data was read. - CHUNK_READ_TIMEOUT, - // Returned when a non-chunk message is received. - CHUNK_STREAM_ENDED, - // Returned when the processing callback does not return a value. - CHUNK_PROCESSING_ERROR, - }; - /* * Reads chunks of data from the given input stream, and invokes the given * callback to process each of them in turn. @@ -71,7 +80,7 @@ class ChunkReader { */ auto ReadChunkFromStream( std::function(uint8_t*, size_t)> callback, - TickType_t max_wait) -> EncodeReadResult; + TickType_t max_wait) -> ChunkReadResult; private: MessageBufferHandle_t* stream_; -- cgit v1.2.3