WIP: quic: quic_cc modifications for BBR

Author: haproxyFred

include/haproxy/quic_cc-t.h

@@ -31,6 +31,7 @@
 
 #include <haproxy/buf-t.h>
 #include <haproxy/quic_loss-t.h>
+#include <haproxy/quic_tx-t.h>
 
 #define QUIC_CC_INFINITE_SSTHESH ((uint32_t)-1)
 
@@ -56,6 +57,8 @@ enum quic_cc_algo_state_type {
 };
 
 enum quic_cc_event_type {
+	/* TX done */
+	QUIC_CC_EVT_TX,
 	/* ACK receipt. */
 	QUIC_CC_EVT_ACK,
 	/* Packet loss. */
@@ -70,7 +73,9 @@ struct quic_cc_event {
 		struct ack {
 			uint64_t acked;
 			uint64_t pn;
+			unsigned int bytes_lost;
 			unsigned int time_sent;
+			unsigned int rtt;
 		} ack;
 		struct loss {
 			unsigned int time_sent;
@@ -90,7 +95,7 @@ struct quic_cc {
 	/* <conn> is there only for debugging purpose. */
 	struct quic_conn *qc;
 	struct quic_cc_algo *algo;
-	uint32_t priv[116];
+	uint32_t priv[120];
 };
 
 struct quic_cc_path {
@@ -129,6 +134,16 @@ struct quic_cc_algo {
 	void (*state_trace)(struct buffer *buf, const struct quic_cc *cc);
 	void (*state_cli)(struct buffer *buf, const struct quic_cc_path *path);
 	void (*hystart_start_round)(struct quic_cc *cc, uint64_t pn);
+	struct quic_cc_drs *(*get_drs)(struct quic_cc *cc);
+	void (*on_transmit)(struct quic_cc *cc);
+	void (*drs_on_transmit)(struct quic_cc *cc, struct quic_tx_packet *pkt);
+	void (*on_ack_rcvd)(struct quic_cc *cc, uint32_t acked, uint32_t delivered,
+	                    uint32_t ack_rtt, uint32_t bytes_lost,
+	                    unsigned int largest_pkt_sent_ts);
+	void (*on_pkt_lost)(struct quic_cc *cc,
+	                    struct quic_tx_packet *pkt, uint32_t lost_bytes);
+	void (*congestion_event)(struct quic_cc *cc, uint32_t ts);
+	unsigned long long (*pacing_delay_ns)(const struct quic_cc *cc);
 };
 
 #endif /* USE_QUIC */

include/haproxy/quic_cc.h

@@ -56,6 +56,9 @@ static inline void quic_cc_event_trace(struct buffer *buf, const struct quic_cc_
 {
 	chunk_appendf(buf, " event=");
 	switch (ev->type) {
+	case QUIC_CC_EVT_TX:
+		chunk_appendf(buf, "tx done");
+		break;
 	case QUIC_CC_EVT_ACK:
 		chunk_appendf(buf, "ack acked=%llu time_sent:%dms",
 		              (unsigned long long)ev->ack.acked, TICKS_TO_MS(tick_remain(ev->ack.time_sent, now_ms)));
@@ -95,7 +98,7 @@ static inline void quic_cc_path_init(struct quic_cc_path *path, int ipv4, unsign
 	path->ifae_pkts = 0;
 	quic_cc_init(&path->cc, algo, qc);
 	path->delivery_rate = 0;
-	path->send_quantum = path->mtu * 10;
+	path->send_quantum = 64 * 1024;
 }
 
 /* Return the remaining <room> available on <path> QUIC path for prepared data

src/quic_cc.c

@@ -40,7 +40,8 @@ void quic_cc_init(struct quic_cc *cc,
 /* Send <ev> event to <cc> congestion controller. */
 void quic_cc_event(struct quic_cc *cc, struct quic_cc_event *ev)
 {
-	cc->algo->event(cc, ev);
+	if (cc->algo->event)
+		cc->algo->event(cc, ev);
 }
 
 void quic_cc_state_trace(struct buffer *buf, const struct quic_cc *cc)