MINOR: quic: Wake up the mux upon ACK receipt
When ACK have been received by the xprt, it must wake up the
mux if this latter has subscribed to SEND events. This is the
role of qcs_try_to_consume() to detect such a situation. This
is the function which consumes the buffer filled by the mux.
diff --git a/src/xprt_quic.c b/src/xprt_quic.c
index 88ac8a4..d073fb1 100644
--- a/src/xprt_quic.c
+++ b/src/xprt_quic.c
@@ -1154,10 +1154,12 @@
/* Remove from <qcs> stream the acknowledged frames.
* Never fails.
*/
-static void qcs_try_to_consume(struct qcs *qcs)
+static int qcs_try_to_consume(struct qcs *qcs)
{
+ int ret;
struct eb64_node *frm_node;
+ ret = 0;
frm_node = eb64_first(&qcs->tx.acked_frms);
while (frm_node) {
struct quic_stream *strm;
@@ -1170,15 +1172,21 @@
qcs->tx.ack_offset += strm->len;
frm_node = eb64_next(frm_node);
eb64_delete(&strm->offset);
+ ret = 1;
}
+
+ return ret;
}
/* Treat <frm> frame whose packet it is attached to has just been acknowledged. */
static inline void qc_treat_acked_tx_frm(struct quic_frame *frm,
struct ssl_sock_ctx *ctx)
{
+ int stream_acked;
+ struct quic_conn *qc = ctx->conn->qc;
TRACE_PROTO("Removing frame", QUIC_EV_CONN_PRSAFRM, ctx->conn, frm);
+ stream_acked = 0;
switch (frm->type) {
case QUIC_FT_STREAM_8 ... QUIC_FT_STREAM_F:
{
@@ -1190,17 +1198,30 @@
qcs->tx.ack_offset += strm->len;
LIST_DELETE(&frm->list);
pool_free(pool_head_quic_frame, frm);
+ qc->qcc->flags &= ~QC_CF_MUX_MFULL;
+ stream_acked = 1;
}
else {
eb64_insert(&qcs->tx.acked_frms, &strm->offset);
}
- qcs_try_to_consume(qcs);
+ stream_acked |= qcs_try_to_consume(qcs);
}
break;
default:
LIST_DELETE(&frm->list);
pool_free(pool_head_quic_frame, frm);
}
+
+ if (stream_acked) {
+ struct qcc *qcc = qc->qcc;
+
+ if (qcc->subs && qcc->subs->events & SUB_RETRY_SEND) {
+ tasklet_wakeup(qcc->subs->tasklet);
+ qcc->subs->events &= ~SUB_RETRY_SEND;
+ if (!qcc->subs->events)
+ qcc->subs = NULL;
+ }
+ }
}
/* Remove <largest> down to <smallest> node entries from <pkts> tree of TX packet,