#include #include #include /** * @file * Prototypes and structures for the ring buffer module. */ #ifndef RINGBUFFER_H #define RINGBUFFER_H #ifdef __cplusplus extern "C" { #endif #define RING_BUFFER_ASSERT(x) assert(x) /** * Checks if the buffer_size is a power of two. * Due to the design only RING_BUFFER_SIZE-1 items * can be contained in the buffer. * buffer_size must be a power of two. * 限制2^N ​​预计总耗时1.5 ms(位运算和内存对齐优势)​, 可修改不限制但是​预计总耗时12 ms */ #define RING_BUFFER_IS_POWER_OF_TWO(buffer_size) ((buffer_size & (buffer_size - 1)) == 0) /** * The type which is used to hold the size * and the indicies of the buffer. */ typedef size_t ring_buffer_size_t; /** * Used as a modulo operator * as a % b = (a & (b ? 1)) * where \c a is a positive index in the buffer and * \c b is the (power of two) size of the buffer. */ #define RING_BUFFER_MASK(rb) (rb->buffer_mask) /** * Simplifies the use of struct ring_buffer_t. */ typedef struct ring_buffer_t ring_buffer_t; /** * Structure which holds a ring buffer. * The buffer contains a buffer array * as well as metadata for the ring buffer. */ struct ring_buffer_t { /** Buffer memory. */ char *buffer; /** Buffer mask. */ ring_buffer_size_t buffer_mask; /** Index of tail. */ ring_buffer_size_t tail_index; /** Index of head. */ ring_buffer_size_t head_index; }; /** * Initializes the ring buffer pointed to by buffer. * This function can also be used to empty/reset the buffer. * @param buffer The ring buffer to initialize. * @param buf The buffer allocated for the ringbuffer. * @param buf_size The size of the allocated ringbuffer. */ void ring_buffer_init(ring_buffer_t *buffer, char *buf, size_t buf_size); /** * Adds a byte to a ring buffer. * @param buffer The buffer in which the data should be placed. * @param data The byte to place. */ void ring_buffer_queue(ring_buffer_t *buffer, char data); /** * Adds an array of bytes to a ring buffer. * @param buffer The buffer in which the data should be placed. * @param data A pointer to the array of bytes to place in the queue. * @param size The size of the array. */ void ring_buffer_queue_arr(ring_buffer_t *buffer, const char *data, ring_buffer_size_t size); /** * Returns the oldest byte in a ring buffer. * @param buffer The buffer from which the data should be returned. * @param data A pointer to the location at which the data should be placed. * @return 1 if data was returned; 0 otherwise. */ uint8_t ring_buffer_dequeue(ring_buffer_t *buffer, char *data); /** * Returns the len oldest bytes in a ring buffer. * @param buffer The buffer from which the data should be returned. * @param data A pointer to the array at which the data should be placed. * @param len The maximum number of bytes to return. * @return The number of bytes returned. */ ring_buffer_size_t ring_buffer_dequeue_arr(ring_buffer_t *buffer, char *data, ring_buffer_size_t len); /** * Peeks a ring buffer, i.e. returns an element without removing it. * @param buffer The buffer from which the data should be returned. * @param data A pointer to the location at which the data should be placed. * @param index The index to peek. * @return 1 if data was returned; 0 otherwise. */ uint8_t ring_buffer_peek(ring_buffer_t *buffer, char *data, ring_buffer_size_t index); /** * Returns whether a ring buffer is empty. * @param buffer The buffer for which it should be returned whether it is empty. * @return 1 if empty; 0 otherwise. */ inline uint8_t ring_buffer_is_empty(ring_buffer_t *buffer) { return (buffer->head_index == buffer->tail_index); } /** * Returns whether a ring buffer is full. * @param buffer The buffer for which it should be returned whether it is full. * @return 1 if full; 0 otherwise. */ inline uint8_t ring_buffer_is_full(ring_buffer_t *buffer) { return ((buffer->head_index - buffer->tail_index) & RING_BUFFER_MASK(buffer)) == RING_BUFFER_MASK(buffer); } /** * Returns the number of items in a ring buffer. * @param buffer The buffer for which the number of items should be returned. * @return The number of items in the ring buffer. */ inline ring_buffer_size_t ring_buffer_num_items(ring_buffer_t *buffer) { return ((buffer->head_index - buffer->tail_index) & RING_BUFFER_MASK(buffer)); } #ifdef __cplusplus } #endif #endif /* RINGBUFFER_H */