Document the ring buffer macros

This commit is contained in:
Bill Currie 2021-01-22 15:22:04 +09:00
parent c016ad9f55
commit baf25f0891

View file

@ -28,6 +28,16 @@
#ifndef __QF_ringbuffer_h
#define __QF_ringbuffer_h
/** Type declaration for a type-safe ring buffer.
*
* While not in itself thread-safe, the buffer is designed (and tested) to be
* used in a threaded environment using sutable locking mechanisms.
*
* \param type The type of data element stored in the ring buffer.
* \param size The number of objects in the ring buffer. Note that the
* actual capacity of the buffer is `size - 1` due to the
* way ring buffers work.
*/
#define RING_BUFFER(type, size) \
struct { \
type buffer[size]; \
@ -40,16 +50,46 @@
sizeof (rb->buffer) / sizeof (rb->buffer[0]); \
})
/** Return the amount of space available for writing in the ring buffer.
*
* Use this to know how much data can be written (RB_WRITE_DATA()), or just
* to see if any space is available.
*
* \note Does NOT affect buffer state.
*
* \param ring_buffer The ring buffer to check for available space.
*/
#define RB_SPACE_AVAILABLE(ring_buffer) \
({ __auto_type rb = &(ring_buffer); \
(rb->tail + RB_buffer_size(rb) - rb->head - 1) % RB_buffer_size(rb);\
})
/** Return the number of objects available in the ring buffer.
*
* Use this to know how much data can be read (RB_READ_DATA()) or discarded
* (RB_DROP_DATA()), or just to see if any data is available.
*
* \note Does NOT affect buffer state.
*
* \param ring_buffer The ring buffer to check for available data.
*/
#define RB_DATA_AVAILABLE(ring_buffer) \
({ __auto_type rb = &(ring_buffer); \
(rb->head + RB_buffer_size (rb) - rb->tail) % RB_buffer_size (rb); \
})
/** Write \a count objects from \a data to the buffer, wrapping if necessary.
*
* \note Affects buffer state (advances the head).
*
* \note Does NOT check that the space is available. It is the caller's
* responsitiblity to do so using RB_SPACE_AVAILABLE().
*
* \param ring_buffer The ring buffer to which the data will be written.
* \param data Pointer to the data to be copied into the ring buffer.
* \param count unsigned int. The number of objects to copy from
* \a data
*/
#define RB_WRITE_DATA(ring_buffer, data, count) \
({ __auto_type rb = &(ring_buffer); \
const typeof (rb->buffer[0]) *d = (data); \
@ -66,6 +106,19 @@
memcpy (rb->buffer + h, d, c * sizeof (rb->buffer[0])); \
})
/** Read \a count objects from the buffer to \a data, wrapping if necessary.
*
* \note Affects buffer state (advances the tail).
*
* \note Does NOT check that the data is available. It is the caller's
* responsitiblity to do so using RB_DATA_AVAILABLE().
*
* \param ring_buffer The ring buffer from which the data will be read.
* \param data Pointer to the location into which data will be copied
* from the ring buffer.
* \param count unsigned int. The number of objects to copy from
* the buffer into \a data
*/
#define RB_READ_DATA(ring_buffer, data, count) \
({ __auto_type rb = &(ring_buffer); \
typeof (&rb->buffer[0]) d = (data); \
@ -83,6 +136,17 @@
rb->tail = (t + oc) % RB_buffer_size (rb); \
})
/** Discard \a count objects from the ring buffer.
*
* \note Affects buffer state (advances the tail).
*
* \note Does NOT check that the data is available. It is the caller's
* responsitiblity to do so using RB_DATA_AVAILABLE().
*
* \param ring_buffer The ring buffer from which the objects will be
* discarded.
* \param count The number of objects to discard.
*/
#define RB_DROP_DATA(ring_buffer, count) \
({ __auto_type rb = &(ring_buffer); \
unsigned c = (count); \
@ -90,11 +154,35 @@
rb->tail = (t + c) % RB_buffer_size (rb); \
})
/** Read a single item from the buffer without affecting buffer state.
*
* \note Does NOT affect buffer state.
*
* \note Does NOT check that the data is available. It is the caller's
* responsitiblity to do so using RB_DATA_AVAILABLE().
*
* \param ring_buffer The ring buffer from which to read the object.
* \param ahead The tail-relative index of the object to read from
* the buffer. Valid range is 0 to
* `RB_DATA_AVAILABLE() - 1`
*/
#define RB_PEEK_DATA(ring_buffer, ahead) \
({ __auto_type rb = &(ring_buffer); \
rb->buffer[(rb->tail + ahead) % RB_buffer_size (rb)]; \
})
/** WRite a single item to the buffer without affecting buffer state.
*
* \note Does NOT affect buffer state.
*
* \note Does NOT check that the data is available. It is the caller's
* responsitiblity to do so using RB_DATA_AVAILABLE().
*
* \param ring_buffer The ring buffer from which to read the object.
* \param ahead The tail-relative index of the buffer object to write.
* Valid range is 0 to `RB_DATA_AVAILABLE() - 1`
* \param data The data to write to the buffer.
*/
#define RB_POKE_DATA(ring_buffer, ahead, data) \
({ __auto_type rb = &(ring_buffer); \
rb->buffer[(rb->tail + ahead) % RB_buffer_size (rb)] = (data); \