deferred_callback.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2025 ML!PA Consulting GmbH
 * SPDX-License-Identifier: LGPL-2.1-only
 */
 
#pragma once
 
#include <assert.h>
#include "event/callback.h"
#include "ztimer.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct {
    event_callback_t event;     
    event_queue_t *queue;       
    ztimer_t timer;             
} event_deferred_callback_t;
 
static inline void _event_deferred_post(void *arg)
{
    event_deferred_callback_t *event_timeout = arg;
 
    event_post(event_timeout->queue, arg);
}
 
static inline void event_deferred_callback_post(event_deferred_callback_t *event,
                                                event_queue_t *queue,
                                                ztimer_clock_t *clock, uint32_t timeout,
                                                void (*callback)(void *), void *arg)
{
    /* cancel the event if it has already been queued */
    ztimer_remove(clock, &event->timer);
    event_cancel(queue, &event->event.super);
 
    event->event = (event_callback_t) {
        .super.handler = _event_callback_handler,
        .callback = callback,
        .arg = arg,
    };
    event->timer = (ztimer_t) {
        .callback = _event_deferred_post,
        .arg = event,
    };
    event->queue = queue;
 
    ztimer_set(clock, &event->timer, timeout);
}
 
static inline void event_deferred_callback_cancel(event_deferred_callback_t *event,
                                                  ztimer_clock_t *clock)
{
    ztimer_remove(clock, &event->timer);
    event_cancel(event->queue, (event_t *)event);
}
 
#ifdef __cplusplus
}
#endif