SynchronizedNBufferRTOST< T > Class Template Reference

NBuffer which uses some RTOS queues to manage the available and filled buffers. More...

#include <SynchronizedNBufferRTOS.h>

Inheritance diagram for SynchronizedNBufferRTOST< T >:

Public Member Functions
	SynchronizedNBufferRTOST (int bufferSize, int bufferCount, int writeMaxWait=portMAX_DELAY, int readMaxWait=portMAX_DELAY)
T *	address ()
	returns the address of the start of the physical read buffer
int	available ()
	provides the number of entries that are available to read
int	availableForWrite ()
	provides the number of entries that are available to write
int	bufferCountEmpty ()
int	bufferCountFilled ()
void	clear ()
	same as reset
virtual int	clearArray (int len)
	Removes the next len entries.
bool	isEmpty ()
bool	isFull ()
	checks if the buffer is full
virtual float	levelPercent ()
	Returns the level of the buffer in %.
bool	peek (T &result) override
	peeks the actual entry from the buffer
bool	read (T &result) override
	reads a single value
virtual int	readArray (T data[], int len)
	reads multiple values
BaseBuffer< T > &	readEnd ()
void	reset ()
	clears the buffer
void	resize (int bufferSize, int bufferCount)
unsigned long	sampleRate ()
void	setReadMaxWait (TickType_t ticks)
void	setWriteMaxWait (TickType_t ticks)
size_t	size ()
bool	write (T data)
	write add an entry to the buffer
virtual int	writeArray (const T data[], int len)
	Fills the buffer data.
virtual int	writeArrayOverwrite (const T data[], int len)
	Fills the buffer data and overwrites the oldest data if the buffer is full.
BaseBuffer< T > &	writeEnd ()

Protected Member Functions
bool	addAvailableBuffer (BaseBuffer< T > *buffer)
bool	addFilledBuffer (BaseBuffer< T > *buffer)
void	cleanup ()
	Removes all allocated buffers.
void	freeMemory ()
BaseBuffer< T > *	getNextAvailableBuffer ()
BaseBuffer< T > *	getNextFilledBuffer ()
void	resetCurrent ()
void	setWritePos (int pos)

Protected Attributes
BaseBuffer< T > *	actual_read_buffer = nullptr
BaseBuffer< T > *	actual_write_buffer = nullptr
QueueRTOS< BaseBuffer< T > * >	available_buffers {0,portMAX_DELAY,0}
int	buffer_count = 0
int	buffer_size = 0
QueueRTOS< BaseBuffer< T > * >	filled_buffers {0,portMAX_DELAY,0}
size_t	max_size
friend	NBuffer< T >
size_t	read_max_wait
unsigned long	sample_count = 0
unsigned long	start_time = 0
size_t	write_max_wait

Detailed Description

template<typename T>
class audio_tools::SynchronizedNBufferRTOST< T >

NBuffer which uses some RTOS queues to manage the available and filled buffers.

Template Parameters

T
COUNT	number of buffers

Member Function Documentation

addAvailableBuffer()

template<typename T >

bool addAvailableBuffer ( BaseBuffer< T > *  buffer )

inlineprotectedvirtual

Reimplemented from NBuffer< T >.

addFilledBuffer()

template<typename T >

bool addFilledBuffer ( BaseBuffer< T > *  buffer )

inlineprotectedvirtual

Reimplemented from NBuffer< T >.

address()

template<typename T >

T * address ( )

inlinevirtualinherited

returns the address of the start of the physical read buffer

Implements BaseBuffer< T >.

available()

template<typename T >

int available ( )

inlinevirtualinherited

provides the number of entries that are available to read

Implements BaseBuffer< T >.

availableForWrite()

template<typename T >

int availableForWrite ( )

inlinevirtualinherited

provides the number of entries that are available to write

Implements BaseBuffer< T >.

bufferCountEmpty()

template<typename T >

int bufferCountEmpty ( )

inlinevirtual

Reimplemented from NBuffer< T >.

bufferCountFilled()

template<typename T >

int bufferCountFilled ( )

inlinevirtual

Reimplemented from NBuffer< T >.

clearArray()

template<typename T >

virtual int clearArray ( int  len )

inlinevirtualinherited

Removes the next len entries.

Reimplemented in SingleBuffer< T >, SingleBuffer< int16_t >, and SingleBuffer< uint8_t >.

getNextAvailableBuffer()

template<typename T >

BaseBuffer< T > * getNextAvailableBuffer ( )

inlineprotectedvirtual

Reimplemented from NBuffer< T >.

getNextFilledBuffer()

template<typename T >

BaseBuffer< T > * getNextFilledBuffer ( )

inlineprotectedvirtual

Reimplemented from NBuffer< T >.

isFull()

template<typename T >

bool isFull ( )

inlinevirtualinherited

checks if the buffer is full

Reimplemented from BaseBuffer< T >.

peek()

template<typename T >

bool peek ( T &  result )

inlineoverridevirtualinherited

peeks the actual entry from the buffer

Implements BaseBuffer< T >.

read()

template<typename T >

bool read ( T &  result )

inlineoverridevirtualinherited

reads a single value

Implements BaseBuffer< T >.

readArray()

template<typename T >

virtual int readArray ( T  data[], int  len  )

inlinevirtualinherited

reads multiple values

Reimplemented in RingBufferFile< File, T >, BufferRTOS< T >, SynchronizedBuffer< T >, BufferRP2040T< T >, and NBufferFile< File, T >.

reset()

template<typename T >

void reset ( )

inlinevirtualinherited

clears the buffer

Implements BaseBuffer< T >.

resize()

template<typename T >

void resize ( int  bufferSize, int  bufferCount  )

inlinevirtual

Reimplemented from NBuffer< T >.

size()

template<typename T >

size_t size ( )

inlinevirtual

Reimplemented from NBuffer< T >.

write()

template<typename T >

bool write ( T  data )

inlinevirtualinherited

write add an entry to the buffer

Implements BaseBuffer< T >.

writeArray()

template<typename T >

virtual int writeArray ( const T  data[], int  len  )

inlinevirtualinherited

Fills the buffer data.

Reimplemented in BufferRTOS< T >, SynchronizedBuffer< T >, BufferRP2040T< T >, RingBufferFile< File, T >, and NBufferFile< File, T >.

---

The documentation for this class was generated from the following file:

• src/AudioTools/Concurrency/RTOS/SynchronizedNBufferRTOS.h