From: Frédéric Lécaille <flecaille@haproxy.com>
Date: Mon, 20 Sep 2021 15:53:17 +0000 (+0200)
Subject: MINOR: quic: Implement qc_process_mux()
X-Git-Tag: v2.5-dev8~27
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=1d40240f257a7a0f361db49f8de0578f9bab0750;p=thirdparty%2Fhaproxy.git

MINOR: quic: Implement qc_process_mux()

At this time, we only add calls to qc_resume_each_sending_qcs()
which handle the flow control and send lists.
---

diff --git a/src/mux_quic.c b/src/mux_quic.c
index 707769fa13..8d2473a834 100644
--- a/src/mux_quic.c
+++ b/src/mux_quic.c
@@ -1272,9 +1272,16 @@ __maybe_unused
 static int qc_process_mux(struct qcc *qcc)
 {
 	TRACE_ENTER(QC_EV_QCC_WAKE, qcc->conn);
-	/* XXX TO DO XXX */
+
+	/* First we always process the flow control list because the streams
+	 * waiting there were already elected for immediate emission but were
+	 * blocked just on this.
+	 */
+	qc_resume_each_sending_qcs(qcc, &qcc->fctl_list);
+	qc_resume_each_sending_qcs(qcc, &qcc->send_list);
+
 	TRACE_LEAVE(QC_EV_QCC_WAKE, qcc->conn);
-	return 0;
+	return 1;
 }