Skip to content

Commit 9cb35ec

Browse files
committed
MINOR: quic: define quic_pacing module
Define a new module quic_pacing. This defines a quic_pacer which can be used as a pacing engine for QUIC emission.
1 parent 954bdce commit 9cb35ec

File tree

5 files changed

+32
-1
lines changed

5 files changed

+32
-1
lines changed

Makefile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -653,7 +653,7 @@ OPTIONS_OBJS += src/quic_rx.o src/mux_quic.o src/h3.o src/quic_tx.o \
653653
src/cfgparse-quic.o src/qmux_trace.o src/qpack-enc.o \
654654
src/qpack-tbl.o src/h3_stats.o src/quic_stats.o \
655655
src/quic_fctl.o src/cbuf.o src/quic_rules.o \
656-
src/quic_token.o
656+
src/quic_token.o src/quic_pacing.o
657657
endif
658658
659659
ifneq ($(USE_QUIC_OPENSSL_COMPAT:0=),)

include/haproxy/quic_conn.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
#include <haproxy/quic_enc.h>
4646
#include <haproxy/quic_frame.h>
4747
#include <haproxy/quic_loss.h>
48+
#include <haproxy/quic_pacing.h>
4849
#include <haproxy/quic_rx.h>
4950
#include <haproxy/mux_quic.h>
5051

include/haproxy/quic_pacing-t.h

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
#ifndef _HAPROXY_QUIC_PACING_T_H
2+
#define _HAPROXY_QUIC_PACING_T_H
3+
4+
#include <haproxy/api-t.h>
5+
#include <haproxy/quic_cc-t.h>
6+
7+
struct quic_pacer {
8+
struct list *frms;
9+
const struct quic_cc *cc;
10+
};
11+
12+
#endif /* _HAPROXY_QUIC_PACING_T_H */

include/haproxy/quic_pacing.h

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
#ifndef _HAPROXY_QUIC_PACING_H
2+
#define _HAPROXY_QUIC_PACING_H
3+
4+
#include <haproxy/quic_pacing-t.h>
5+
6+
#include <haproxy/list.h>
7+
#include <haproxy/quic_frame.h>
8+
9+
static inline void quic_pacing_init(struct quic_pacer *pacer,
10+
const struct quic_cc *cc,
11+
struct list *frms)
12+
{
13+
pacer->cc = cc;
14+
pacer->frms = frms;
15+
}
16+
17+
#endif /* _HAPROXY_QUIC_PACING_H */

src/quic_pacing.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
#include <haproxy/quic_pacing.h>

0 commit comments

Comments
 (0)