congure.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2021 Freie Universität Berlin
 * SPDX-License-Identifier: LGPL-2.1-only
 */
 
#pragma once

 
#include <stdbool.h>
#include <stdlib.h>
 
#include "congure.h"
#include "modules.h"
#include "net/gnrc/sixlowpan/frag/sfr.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#define GNRC_SIXLOWPAN_FRAG_SFR_CONGURE_UNIT    (1U)
 
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE) || DOXYGEN
congure_snd_t *gnrc_sixlowpan_frag_sfr_congure_snd_get(void);
#else
static inline congure_snd_t *gnrc_sixlowpan_frag_sfr_congure_snd_get(void)
{
    return NULL;
}
#endif

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_free(congure_snd_t *c)
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    c->driver = NULL;
#else
    (void)c;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_destroy(gnrc_sixlowpan_frag_fb_t *fb)
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    gnrc_sixlowpan_frag_sfr_congure_snd_free(fb->sfr.congure);
    fb->sfr.congure = NULL;
#else
    (void)fb;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_init(gnrc_sixlowpan_frag_fb_t *fb)
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    fb->sfr.congure->driver->init(fb->sfr.congure, fb);
#else
    (void)fb;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_setup(gnrc_sixlowpan_frag_fb_t *fb)
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    if (fb->sfr.congure == NULL) {
        fb->sfr.congure = gnrc_sixlowpan_frag_sfr_congure_snd_get();
        assert(fb->sfr.congure);
        gnrc_sixlowpan_frag_sfr_congure_snd_init(fb);
        if (fb->sfr.congure->cwnd > CONFIG_GNRC_SIXLOWPAN_SFR_MAX_WIN_SIZE) {
            fb->sfr.congure->cwnd = CONFIG_GNRC_SIXLOWPAN_SFR_MAX_WIN_SIZE;
        }
    }
#else
    (void)fb;
#endif
}

static inline bool gnrc_sixlowpan_frag_sfr_congure_snd_in_cwnd(gnrc_sixlowpan_frag_fb_t *fb)
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    return fb->sfr.frags_sent < fb->sfr.congure->cwnd;
#else
    return fb->sfr.frags_sent < CONFIG_GNRC_SIXLOWPAN_SFR_OPT_WIN_SIZE;
#endif
}

static inline bool gnrc_sixlowpan_frag_sfr_congure_snd_next_in_cwnd(gnrc_sixlowpan_frag_fb_t *fb)
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    return (fb->sfr.frags_sent + GNRC_SIXLOWPAN_FRAG_SFR_CONGURE_UNIT)
        < fb->sfr.congure->cwnd;
#else
    return (fb->sfr.frags_sent + GNRC_SIXLOWPAN_FRAG_SFR_CONGURE_UNIT)
        < CONFIG_GNRC_SIXLOWPAN_SFR_OPT_WIN_SIZE;
#endif
}

static inline bool gnrc_sixlowpan_frag_sfr_congure_snd_has_inter_frame_gap(void)
{
    return (CONFIG_GNRC_SIXLOWPAN_SFR_INTER_FRAME_GAP_US > 0) ||
           IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE);
}

static inline uint32_t gnrc_sixlowpan_frag_sfr_congure_snd_inter_frame_gap(
        gnrc_sixlowpan_frag_fb_t *fb
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    if (fb != NULL) {
        congure_snd_t *c = fb->sfr.congure;
        int32_t res = c->driver->inter_msg_interval(
            c, GNRC_SIXLOWPAN_FRAG_SFR_CONGURE_UNIT
        );
 
        if ((res >= 0) &&
            ((unsigned)res >= CONFIG_GNRC_SIXLOWPAN_SFR_INTER_FRAME_GAP_US)) {
            return (uint32_t)res;
        }
    }
#else
    (void)fb;
#endif
    return CONFIG_GNRC_SIXLOWPAN_SFR_INTER_FRAME_GAP_US;
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_report_frag_sent(
        gnrc_sixlowpan_frag_fb_t *fb
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    congure_snd_t *c = fb->sfr.congure;
 
    c->driver->report_msg_sent(c, GNRC_SIXLOWPAN_FRAG_SFR_CONGURE_UNIT);
#else
    (void)fb;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_report_frag_discard(
        gnrc_sixlowpan_frag_fb_t *fb
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    congure_snd_t *c = fb->sfr.congure;
 
    c->driver->report_msg_discarded(c, GNRC_SIXLOWPAN_FRAG_SFR_CONGURE_UNIT);
#else
    (void)fb;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_report_frags_timeout(
        gnrc_sixlowpan_frag_fb_t *fb
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    congure_snd_t *c = fb->sfr.congure;
 
    c->driver->report_msgs_timeout(c, (congure_snd_msg_t *)(&fb->sfr.window));
#else
    (void)fb;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_report_frags_lost(
        gnrc_sixlowpan_frag_fb_t *fb, congure_snd_msg_t *frags
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    congure_snd_t *c = fb->sfr.congure;
 
    c->driver->report_msgs_lost(c, frags);
#else
    (void)fb;
    (void)frags;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_report_frag_acked(
        gnrc_sixlowpan_frag_fb_t *fb,
        congure_snd_msg_t *frag,
        congure_snd_ack_t *ack
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    congure_snd_t *c = fb->sfr.congure;
 
    c->driver->report_msg_acked(c, frag, ack);
    if (c->cwnd > CONFIG_GNRC_SIXLOWPAN_SFR_MAX_WIN_SIZE) {
        c->cwnd = CONFIG_GNRC_SIXLOWPAN_SFR_MAX_WIN_SIZE;
    }
#else
    (void)fb;
    (void)frag;
    (void)ack;
#endif
}

static inline void gnrc_sixlowpan_frag_sfr_congure_snd_report_ecn(
        gnrc_sixlowpan_frag_fb_t *fb, uint32_t time
    )
{
#if IS_USED(MODULE_GNRC_SIXLOWPAN_FRAG_SFR_CONGURE)
    congure_snd_t *c = fb->sfr.congure;
 
    c->driver->report_ecn_ce(c, (ztimer_now_t)time);
#else
    (void)fb;
    (void)time;
#endif
}
 
#ifdef __cplusplus
}
#endif