source.h

Go to the documentation of this file.

/*
 * Copyright (C) 2022 ML!PA Consulting GmbH
 *
 * This file is subject to the terms and conditions of the GNU Lesser
 * General Public License v2.1. See the file LICENSE in the top level
 * directory for more details.
 */
 
#ifndef EVENT_SOURCE_H
#define EVENT_SOURCE_H
 
#include "event.h"
#include "list.h"
#include "irq.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct {
    list_node_t list;       
} event_source_t;
 
typedef struct {
    list_node_t node;       
    event_t *event;         
    event_queue_t *queue;   
} event_source_subscriber_t;
 
#define EVENT_SOURCE_INIT  { 0 }
 
#define EVENT_SOURCE_SUBSCRIBER_INIT(e, q) { .event = (event_t *)e, .queue = q }
 
static inline void event_source_attach(event_source_t *source,
                                       event_source_subscriber_t *event)
{
    unsigned state = irq_disable();
 
    list_add(&source->list, &event->node);
 
    irq_restore(state);
}
 
static inline void event_source_detach(event_source_t *source,
                                       event_source_subscriber_t *event)
{
    unsigned state = irq_disable();
 
    list_remove(&source->list, &event->node);
 
    irq_restore(state);
}
 
static inline void event_source_trigger(event_source_t *source)
{
    unsigned state = irq_disable();
 
    event_source_subscriber_t *event = container_of(source->list.next,
                                                    event_source_subscriber_t,
                                                    node);
    while (event) {
        event_post(event->queue, event->event);
        event = container_of(event->node.next, event_source_subscriber_t, node);
    }
 
    irq_restore(state);
}
 
#ifdef __cplusplus
}
#endif
#endif /* EVENT_SOURCE_H */