deferred_callback.h

Go to the documentation of this file.

/*
 * Copyright (C) 2025 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.
 */
 
#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