mirror of
https://github.com/haproxy/haproxy.git
synced 2026-04-22 23:02:34 -04:00
979588227f
Each QUIC congestion algorithm is defined as a structure with callbacks in it. Every quic_conn has a member pointing to the configured algorithm, inherited from the bind-conf keyword or to the default CUBIC value. Convert all these definitions to const. This ensures that there never will be an accidental modification of a globally shared structure. This also requires to mark quic_cc_algo field in bind_conf and quic_cc as const.
80 lines
2.2 KiB
C
80 lines
2.2 KiB
C
/*
|
|
* Fake congestion control algorithm which does nothing except initializing
|
|
* the congestion control window to a fixed value.
|
|
*
|
|
*/
|
|
|
|
#include <haproxy/api-t.h>
|
|
#include <haproxy/quic_cc.h>
|
|
#include <haproxy/quic_conn-t.h>
|
|
#include <haproxy/quic_trace.h>
|
|
#include <haproxy/trace.h>
|
|
|
|
static int quic_cc_nocc_init(struct quic_cc *cc)
|
|
{
|
|
struct quic_cc_path *path;
|
|
|
|
path = container_of(cc, struct quic_cc_path, cc);
|
|
path->cwnd = path->limit_max;
|
|
return 1;
|
|
}
|
|
|
|
static void quic_cc_nocc_slow_start(struct quic_cc *cc)
|
|
{
|
|
}
|
|
|
|
/* Slow start callback. */
|
|
static void quic_cc_nocc_ss_cb(struct quic_cc *cc, struct quic_cc_event *ev)
|
|
{
|
|
TRACE_ENTER(QUIC_EV_CONN_CC, cc->qc);
|
|
TRACE_PROTO("CC nocc", QUIC_EV_CONN_CC, cc->qc, ev, cc);
|
|
TRACE_LEAVE(QUIC_EV_CONN_CC, cc->qc);
|
|
}
|
|
|
|
/* Congestion avoidance callback. */
|
|
static void quic_cc_nocc_ca_cb(struct quic_cc *cc, struct quic_cc_event *ev)
|
|
{
|
|
TRACE_ENTER(QUIC_EV_CONN_CC, cc->qc);
|
|
TRACE_PROTO("CC nocc", QUIC_EV_CONN_CC, cc->qc, ev, cc);
|
|
TRACE_LEAVE(QUIC_EV_CONN_CC, cc->qc);
|
|
}
|
|
|
|
/* Recovery period callback. */
|
|
static void quic_cc_nocc_rp_cb(struct quic_cc *cc, struct quic_cc_event *ev)
|
|
{
|
|
TRACE_ENTER(QUIC_EV_CONN_CC, cc->qc);
|
|
TRACE_PROTO("CC nocc", QUIC_EV_CONN_CC, cc->qc, ev, cc);
|
|
TRACE_LEAVE(QUIC_EV_CONN_CC, cc->qc);
|
|
}
|
|
|
|
static void quic_cc_nocc_state_trace(struct buffer *buf, const struct quic_cc *cc)
|
|
{
|
|
struct quic_cc_path *path;
|
|
|
|
path = container_of(cc, struct quic_cc_path, cc);
|
|
chunk_appendf(buf, " cwnd=%llu", (unsigned long long)path->cwnd);
|
|
}
|
|
|
|
static void (*quic_cc_nocc_state_cbs[])(struct quic_cc *cc,
|
|
struct quic_cc_event *ev) = {
|
|
[QUIC_CC_ST_SS] = quic_cc_nocc_ss_cb,
|
|
[QUIC_CC_ST_CA] = quic_cc_nocc_ca_cb,
|
|
[QUIC_CC_ST_RP] = quic_cc_nocc_rp_cb,
|
|
};
|
|
|
|
static void quic_cc_nocc_event(struct quic_cc *cc, struct quic_cc_event *ev)
|
|
{
|
|
return quic_cc_nocc_state_cbs[QUIC_CC_ST_SS](cc, ev);
|
|
}
|
|
|
|
const struct quic_cc_algo quic_cc_algo_nocc = {
|
|
.type = QUIC_CC_ALGO_TP_NOCC,
|
|
.flags = QUIC_CC_ALGO_FL_OPT_PACING,
|
|
.init = quic_cc_nocc_init,
|
|
.event = quic_cc_nocc_event,
|
|
.pacing_inter = quic_cc_default_pacing_inter,
|
|
.pacing_burst = NULL,
|
|
.slow_start = quic_cc_nocc_slow_start,
|
|
.state_trace = quic_cc_nocc_state_trace,
|
|
};
|
|
|