queue.h

#pragma once
 
#include <stdbool.h>
#include <stdint.h>
 
#define QUEUE_LENGTH    256
 
struct Queue {
    volatile uint16_t write_cursor;
    volatile uint16_t read_cursor;
    volatile bool empty;
    uint8_t depth;
    uint8_t item_size;
    unsigned char content[];
};
 
#pragma GCC diagnostic push
/* Ignore warning about incorrect VLA use.
 * The code is not portable outside GCC but works as designed */
#pragma GCC diagnostic ignored "-Wpedantic"
struct BasicQueue {
  union {
    struct Queue q;
    unsigned char buffer[sizeof(struct Queue) + QUEUE_LENGTH];
  };
};
 
#define STATIC_QUEUE_T(name, size) \
typedef struct {\
    union {\
        struct Queue q;\
        unsigned char buffer[sizeof(struct Queue) + size];\
    };\
} name
#pragma GCC diagnostic pop
 
//#define unpack_queue(__q) _Generic((__q), struct Queue * : (__q), default: ((__q)->q))
 
bool queue_init(struct Queue * queue, uint8_t depth, uint8_t item_size);
 
bool queue_send(struct Queue * queue, const void * data);
 
bool queue_send_silent(struct Queue * queue, const void * data);
 
 
bool queue_receive_timeout(struct Queue * queue, void * data, uint32_t timeout_us);
 
static inline bool queue_receive(struct Queue * queue, void * data)
{
  return queue_receive_timeout(queue, data, 0);
}
 
bool queue_empty(struct Queue * queue);
 
bool queue_full(struct Queue * queue);