TO BE MERGED into BBR implementation

Author: haproxyFred

src/quic_cc_bbr.c

@@ -382,8 +382,8 @@ static int bbr_init(struct quic_cc *cc)
 		return 0;
 
 	quic_cc_drs_init(bbr->drs);
-	wf_init(&bbr->max_bw_filter, BBR_MAX_BW_FILTERLEN);
-	wf_init(&bbr->extra_acked_filter, BBR_EXTRA_ACKED_FILTERLEN);
+	wf_init(&bbr->max_bw_filter, BBR_MAX_BW_FILTERLEN, 0, ~0U);
+	wf_init(&bbr->extra_acked_filter, BBR_EXTRA_ACKED_FILTERLEN, 0, ~0U);
 	/* InitWindowedMaxFilter() */
 	bbr->min_rtt = UINT32_MAX;
 	bbr->min_rtt_stamp = now_ms;
@@ -829,10 +829,9 @@ static void bbr_update_max_bw(struct bbr *bbr, struct quic_cc_path *p,
 	struct quic_cc_rs *rs = &bbr->drs->rs;
 
 	bbr_update_round(bbr, delivered);
-	if (p->delivery_rate >= bbr->max_bw || !rs->is_app_limited) {
-		wf_update(&bbr->max_bw_filter, p->delivery_rate, bbr->cycle_count);
-		bbr->max_bw = wf_get_best(&bbr->max_bw_filter);
-	}
+	if (p->delivery_rate >= bbr->max_bw || !rs->is_app_limited)
+		bbr->max_bw = wf_max_update(&bbr->max_bw_filter,
+		                            p->delivery_rate, bbr->cycle_count);
 }
 
 static void bbr_init_lower_bounds(struct bbr *bbr, struct quic_cc_path *p)
@@ -900,11 +899,7 @@ static void bbr_update_ack_aggregation(struct bbr *bbr,
 	extra = bbr->extra_acked_delivered - expected_delivered;
 	extra = MIN(extra, p->cwnd);
 
-	/* XXX CHECK THIS XXX: the RFC make use of a <window_length> parameter
-	 * to be passed to wf_update().
-	 */
-	wf_update(&bbr->extra_acked_filter, extra, bbr->round_count);
-	bbr->extra_acked = wf_get_best(&bbr->extra_acked_filter);
+	bbr->extra_acked = wf_max_update(&bbr->extra_acked_filter, extra, bbr->round_count);
 }
 
 static void bbr_advance_latest_delivery_signals(struct bbr *bbr,