]> git.ipfire.org Git - thirdparty/haproxy.git/commitdiff
MINOR: quic: Implement qc_process_mux()
authorFrédéric Lécaille <flecaille@haproxy.com>
Mon, 20 Sep 2021 15:53:17 +0000 (17:53 +0200)
committerAmaury Denoyelle <adenoyelle@haproxy.com>
Thu, 23 Sep 2021 13:27:25 +0000 (15:27 +0200)
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

index 707769fa139e432616f5d55a8feab57ac4e43e59..8d2473a834d6cc6137e6e0dc3642d869b4d672ea 100644 (file)
@@ -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;
 }