event.h

Go to the documentation of this file.

#pragma once
#include "sync.h"
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>

#ifdef __cplusplus
extern "C" {
#endif

typedef void *sys_event_t;

typedef struct {
  sys_event_t *items;   
  size_t capacity;      
  size_t head;          
  size_t tail;          
  size_t count;         
  sys_mutex_t mutex;    
  sys_cond_t not_empty; 
  bool shutdown;        
} sys_event_queue_t;

sys_event_queue_t sys_event_queue_init(size_t capacity);

void sys_event_queue_finalize(sys_event_queue_t *queue);

bool sys_event_queue_push(sys_event_queue_t *queue, sys_event_t event);

bool sys_event_queue_try_push(sys_event_queue_t *queue, sys_event_t event);

sys_event_t sys_event_queue_peek(sys_event_queue_t *queue);

sys_event_t sys_event_queue_pop(sys_event_queue_t *queue);

sys_event_t sys_event_queue_try_pop(sys_event_queue_t *queue);

sys_event_t sys_event_queue_timed_pop(sys_event_queue_t *queue,
                                      uint32_t timeout_ms);

size_t sys_event_queue_size(sys_event_queue_t *queue);

bool sys_event_queue_empty(sys_event_queue_t *queue);

void sys_event_queue_shutdown(sys_event_queue_t *queue);

bool sys_event_queue_lock(sys_event_queue_t *queue);

bool sys_event_queue_unlock(sys_event_queue_t *queue);

static inline bool sys_event_queue_valid(sys_event_queue_t *queue) {
  // Check if the queue pointer is valid and has a non-zero capacity
  if (queue == NULL) {
    return false;
  }
  if (queue->items == NULL || queue->capacity == 0) {
    return false;
  }
  // Ensure the queue is not in a shutdown state
  if (queue->shutdown == true) {
    return false;
  }
  return true;
}

#ifdef __cplusplus
}
#endif