reno.h

Go to the documentation of this file.

/*
 * Copyright (C) 2021 Freie Universität Berlin
 *
 * 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 <stdint.h>
 
#include "congure.h"
 
#ifdef __cplusplus
extern "C" {
#endif

typedef struct congure_reno_snd congure_reno_snd_t;

typedef struct {
    void (*fr)(congure_reno_snd_t *c);

    bool (*same_wnd_adv)(congure_reno_snd_t *c, congure_snd_ack_t *ack);

    void (*ss_cwnd_inc)(congure_reno_snd_t *c);

    void (*ca_cwnd_inc)(congure_reno_snd_t *c);

    void (*fr_cwnd_dec)(congure_reno_snd_t *c);

    unsigned init_mss;

    congure_wnd_size_t cwnd_upper;

    congure_wnd_size_t cwnd_lower;

    congure_wnd_size_t init_ssthresh;

    uint8_t frthresh;
} congure_reno_snd_consts_t;

struct congure_reno_snd {
    congure_snd_t super;            

    const congure_reno_snd_consts_t *consts;
    uint32_t last_ack;              
    congure_wnd_size_t mss;
    congure_wnd_size_t ssthresh;    
    uint16_t in_flight_size;
    uint8_t dup_acks;               
};

void congure_reno_snd_setup(congure_reno_snd_t *c,
                            const congure_reno_snd_consts_t *consts);

void congure_reno_set_mss(congure_reno_snd_t *c, congure_wnd_size_t mss);

void congure_reno_snd_init(congure_snd_t *c, void *ctx);

int32_t congure_reno_snd_inter_msg_interval(congure_snd_t *c,
                                            unsigned msg_size);

void congure_reno_snd_report_msg_sent(congure_snd_t *c, unsigned msg_size);

void congure_reno_snd_report_msg_discarded(congure_snd_t *c, unsigned msg_size);

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

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

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

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