tx_sync.h

Go to the documentation of this file.

/*
 * Copyright (C) 2020 Otto-von-Guericke-Universität Magdeburg
 *
 * 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 NET_GNRC_TX_SYNC_H
#define NET_GNRC_TX_SYNC_H
 
#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
 
#endif /* NET_GNRC_TX_SYNC_H */