12 static const char *
const TAG =
"ring_buffer";
15 std::unique_ptr<RingBuffer> rb = make_unique<RingBuffer>();
18 rb->storage_ = allocator.allocate(len + 1);
19 if (rb->storage_ ==
nullptr) {
23 rb->handle_ = xStreamBufferCreateStatic(len + 1, 1, rb->storage_, &rb->structure_);
24 ESP_LOGD(TAG,
"Created ring buffer with size %u", len);
29 if (ticks_to_wait > 0)
30 xStreamBufferSetTriggerLevel(this->
handle_, len);
32 size_t bytes_read = xStreamBufferReceive(this->
handle_, data, len, ticks_to_wait);
34 xStreamBufferSetTriggerLevel(this->
handle_, 1);
42 size_t needed = len -
free;
43 uint8_t discard[needed];
44 xStreamBufferReceive(this->
handle_, discard, needed, 0);
46 return xStreamBufferSend(this->
handle_, data, len, 0);
50 return xStreamBufferSend(this->
handle_, data, len, ticks_to_wait);
size_t write_without_replacement(void *data, size_t len, TickType_t ticks_to_wait=0)
Writes to the ring buffer without overwriting oldest data.
size_t free() const
Returns the number of free bytes in the ring buffer.
BaseType_t reset()
Resets the ring buffer, discarding all stored data.
size_t read(void *data, size_t len, TickType_t ticks_to_wait=0)
Reads from the ring buffer, waiting up to a specified number of ticks if necessary.
size_t available() const
Returns the number of available bytes in the ring buffer.
Implementation of SPI Controller mode.
size_t write(void *data, size_t len)
Writes to the ring buffer, overwriting oldest data if necessary.
static std::unique_ptr< RingBuffer > create(size_t len)
StreamBufferHandle_t handle_