tx_sync.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2020 Otto-von-Guericke-Universität Magdeburg
 * SPDX-License-Identifier: LGPL-2.1-only
 */
 
#pragma once
 
#include <errno.h>
#include <stdint.h>
 
#include "mutex.h"
#include "net/gnrc/pktbuf.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct {
    mutex_t signal;     
} gnrc_tx_sync_t;
 
static inline gnrc_tx_sync_t gnrc_tx_sync_init(void)
{
    gnrc_tx_sync_t result = { .signal = MUTEX_INIT_LOCKED };
    return result;
}
 
static inline gnrc_pktsnip_t * gnrc_tx_sync_build(gnrc_tx_sync_t *tx_sync)
{
    *tx_sync = gnrc_tx_sync_init();
    gnrc_pktsnip_t *snip = gnrc_pktbuf_add(NULL, NULL, 0, GNRC_NETTYPE_TX_SYNC);
    if (!snip) {
        return NULL;
    }
    snip->data = tx_sync;
    return snip;
}
 
static inline int gnrc_tx_sync_append(gnrc_pktsnip_t *pkt,
                                      gnrc_tx_sync_t *tx_sync)
{
    gnrc_pktsnip_t *snip = gnrc_tx_sync_build(tx_sync);
    if (!snip) {
        return -ENOMEM;
    }
    gnrc_pkt_append(pkt, snip);
    return 0;
}
 
gnrc_pktsnip_t * gnrc_tx_sync_split(gnrc_pktsnip_t *pkt);
 
static inline void gnrc_tx_complete(gnrc_pktsnip_t *pkt)
{
    assert(IS_USED(MODULE_GNRC_TX_SYNC) && (pkt->type == GNRC_NETTYPE_TX_SYNC));
    gnrc_tx_sync_t *sync = (gnrc_tx_sync_t*)pkt->data;
    mutex_unlock(&sync->signal);
}
 
static inline void gnrc_tx_sync(gnrc_tx_sync_t *sync)
{
    mutex_lock(&sync->signal);
}
 
#ifdef __cplusplus
}
#endif