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 <stdint.h>
 
#include "clist.h"
#include "ztimer.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#define CONGURE_WND_SIZE_MAX    (UINT16_MAX)

typedef uint16_t congure_wnd_size_t;

typedef struct congure_snd_driver congure_snd_driver_t;

typedef struct {
    const congure_snd_driver_t *driver;
    void *ctx;
    congure_wnd_size_t cwnd;        
} congure_snd_t;

typedef struct {
    clist_node_t super;         
    ztimer_now_t send_time;
    congure_wnd_size_t size;    
    uint8_t resends;
} congure_snd_msg_t;

typedef struct {
    ztimer_now_t recv_time;
    uint32_t id;            
    congure_wnd_size_t size;
    congure_wnd_size_t wnd;
    uint16_t clean;
    uint16_t delay;
} congure_snd_ack_t;

struct congure_snd_driver {
    void (*init)(congure_snd_t *c, void *ctx);

    int32_t (*inter_msg_interval)(congure_snd_t *c, unsigned msg_size);

    void (*report_msg_sent)(congure_snd_t *c, unsigned msg_size);

    void (*report_msg_discarded)(congure_snd_t *c, unsigned msg_size);

    void (*report_msgs_timeout)(congure_snd_t *c, congure_snd_msg_t *msgs);

    void (*report_msgs_lost)(congure_snd_t *c, congure_snd_msg_t *msgs);

    void (*report_msg_acked)(congure_snd_t *c, congure_snd_msg_t *msg,
                             congure_snd_ack_t *ack);

    void (*report_ecn_ce)(congure_snd_t *c, ztimer_now_t time);
};
 
#ifdef __cplusplus
}
#endif