coevent.h

Aller à la documentation de ce fichier.

#pragma once
 
#include "dynarray.h"
#include <stdint.h>
 
typedef enum CoEventStatus {
    CO_EVENT_PENDING,
    CO_EVENT_SIGNALED,
    CO_EVENT_CANCELED
} CoEventStatus;
 
typedef struct BoxedTask BoxedTask;
 
typedef struct CoEvent {
    DYNAMIC_ARRAY(BoxedTask) subscribers; // Tableau des tâches dépendantes de l'evenement
    uint32_t unique_id; // Securite pour la destruction d'evenement
    uint32_t num_signaled; // Nombre de fois ou l'evenement a ete signale
} CoEvent;
 
/* Photo d'un evenement */
/* Permet de comparer les events au moment de réveiller les taches */
typedef struct CoEventSnapshot {
    uint32_t unique_id;
    uint32_t num_signaled;
} CoEventSnapshot;
 
// Technique interdite du jujutsu union GPT
#define COEVENTS_ARRAY(...) \
    union { \
        CoEvent _first_event_; \
        struct { CoEvent __VA_ARGS__; }; \
    }
 
typedef COEVENTS_ARRAY(finished) CoTaskEvents;
 
#include "cotask.h"

void coevent_init(CoEvent *evt);
 
void coevent_signal(CoEvent *evt);

CoEventSnapshot coevent_snapshot(const CoEvent *evt);

CoEventStatus coevent_poll(const CoEvent *evt, const CoEventSnapshot *snap);

void coevent_cleanup_subscribers(CoEvent *evt);

void coevent_add_subscriber(CoEvent *evt, CoTask *task);

void coevent_signal(CoEvent *evt);

void coevent_signal_once(CoEvent *evt);

void coevent_cancel(CoEvent *evt);

void _coevent_array_action(unsigned int num, CoEvent *events, void (*func)(CoEvent*));
 
#define COEVENT_ARRAY_ACTION(func, array) \
    (_coevent_array_action(sizeof(array)/sizeof(CoEvent), &((array)._first_event_), func))
#define COEVENT_INIT_ARRAY(array) COEVENT_ARRAY_ACTION(coevent_init, array)
#define COEVENT_CANCEL_ARRAY(array) COEVENT_ARRAY_ACTION(coevent_cancel, array)