RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2025-04-01 22:48:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: mux-quic/h3: send SETTINGS as soon as transport is ready

Browse Source 
As specified by HTTP3 RFC, SETTINGS frame should be sent as soon as
possible. Before this patch, this was only done on the first qc_send()
invocation. This delay significantly SETTINGS emission until the first
H3 response is ready to be transferred.

This patch fixes this by ensuring SETTINGS is emitted when MUX-QUIC is
being setup.

As a side point, return value of finalize operation is checked. This
means that an error during SETTINGS emission will cause the connection
init to fail.

This should be backported up to 2.7.
This commit is contained in:
Amaury Denoyelle 2023-01-24 17:35:37 +01:00
parent 9a0f8ba837
commit 71fd03632f
3 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/haproxy/mux_quic-t.h
View File

@ -30,7 +30,6 @@ enum qcs_type {
#define QC_CF_CC_EMIT 0x00000001 /* A CONNECTION_CLOSE is set by the MUX */
#define QC_CF_BLK_MFCTL 0x00000002 /* sending blocked due to connection flow-control */
#define QC_CF_CONN_FULL 0x00000004 /* no stream buffers available on connection */
#define QC_CF_APP_FINAL 0x00000008 /* The application layer was finalized */
struct qcc {
struct connection *conn;

8
src/h3.c
View File

@ -1636,6 +1636,10 @@ static void h3_detach(struct qcs *qcs)
TRACE_LEAVE(H3_EV_H3S_END, qcs->qcc->conn, qcs);
}
/* Initialize H3 control stream and prepare SETTINGS emission.
*
* Returns 0 on success else non-zero.
*/
static int h3_finalize(void *ctx)
{
struct h3c *h3c = ctx;
@ -1643,12 +1647,12 @@ static int h3_finalize(void *ctx)
qcs = qcc_init_stream_local(h3c->qcc, 0);
if (!qcs)
return 0;
return 1;
h3_control_send(qcs, h3c);
h3c->ctrl_strm = qcs;
return 1;
return 0;
}
/* Generate a GOAWAY frame for <h3c> connection on the control stream.

24
src/mux_quic.c
View File

@ -883,6 +883,21 @@ int qcc_install_app_ops(struct qcc *qcc, const struct qcc_app_ops *app_ops)
TRACE_PROTO("application layer initialized", QMUX_EV_QCC_NEW, qcc->conn);
/* RFC 9114 7.2.4.2. Initialization
*
* Endpoints MUST NOT require any data to be
* received from the peer prior to sending the SETTINGS frame;
* settings MUST be sent as soon as the transport is ready to
* send data.
*/
if (qcc->app_ops->finalize) {
if (qcc->app_ops->finalize(qcc->ctx)) {
TRACE_ERROR("app ops finalize error", QMUX_EV_QCC_NEW, qcc->conn);
goto err;
}
tasklet_wakeup(qcc->wait_event.tasklet);
}
TRACE_LEAVE(QMUX_EV_QCC_NEW, qcc->conn);
return 0;
@ -1741,15 +1756,6 @@ static int qc_send(struct qcc *qcc)
if (qcc->flags & QC_CF_BLK_MFCTL)
goto err;
if (!(qcc->flags & QC_CF_APP_FINAL) && !eb_is_empty(&qcc->streams_by_id) &&
qcc->app_ops->finalize) {
/* Finalize the application layer before sending any stream.
* For h3 this consists in preparing the control stream data (SETTINGS h3).
*/
qcc->app_ops->finalize(qcc->ctx);
qcc->flags |= QC_CF_APP_FINAL;
}
/* Send STREAM/STOP_SENDING/RESET_STREAM data for registered streams. */
list_for_each_entry_safe(qcs, qcs_tmp, &qcc->send_list, el_send) {
/* Stream must not be present in send_list if it has nothing to send. */