reno.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 "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