From 1d40240f257a7a0f361db49f8de0578f9bab0750 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fr=C3=A9d=C3=A9ric=20L=C3=A9caille?= Date: Mon, 20 Sep 2021 17:53:17 +0200 Subject: [PATCH] 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. --- src/mux_quic.c | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/src/mux_quic.c b/src/mux_quic.c index 707769fa1..8d2473a83 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; }