mirror of
https://github.com/haproxy/haproxy.git
synced 2026-05-21 01:15:17 -04:00
MINOR: mux_quic: implement basic committed_extra_streams accounting
Account QUIC frontend connections into committed_extra_streams when stream elasticity setting is active. This is performed in QCC init and release functions. This patch has no impact on QUIC subsystem for now. Connections will still allow a static number of concurrent streams based on tune.quic.fe.stream.max-concurrent. However, this has a direct repercussion on H2 subsystem, as a higher count of QUIC connections will reduce the concurrent streams allowed there.
This commit is contained in:
parent
33c8270903
commit
e4adba6e64
1 changed files with 11 additions and 0 deletions
|
|
@ -3586,6 +3586,12 @@ static void qcc_release(struct qcc *qcc)
|
|||
}
|
||||
TRACE_PROTO("application layer released", QMUX_EV_QCC_END, conn);
|
||||
|
||||
if (!(qcc->flags & QC_CF_IS_BACK) && global.tune.streams_elasticity &&
|
||||
qcc->lfctl.ms_bidi_init > 1) {
|
||||
_HA_ATOMIC_SUB(&tg_ctx->committed_extra_streams,
|
||||
qcc->lfctl.ms_bidi_init - 1);
|
||||
}
|
||||
|
||||
if (conn && !conn_is_quic(conn)) {
|
||||
b_free(&qcc->rx.qmux_buf);
|
||||
b_free(&qcc->tx.qmux_buf);
|
||||
|
|
@ -3928,6 +3934,11 @@ static int qcm_init(struct connection *conn, struct proxy *prx,
|
|||
qcc->next_bidi_l = 0x01;
|
||||
qcc->largest_uni_r = 0x02;
|
||||
qcc->next_uni_l = 0x03;
|
||||
|
||||
if (global.tune.streams_elasticity && qcc->lfctl.ms_bidi_init > 1) {
|
||||
_HA_ATOMIC_ADD(&tg_ctx->committed_extra_streams,
|
||||
qcc->lfctl.ms_bidi_init - 1);
|
||||
}
|
||||
}
|
||||
|
||||
qcc->wait_event.tasklet = tasklet_new();
|
||||
|
|
|
|||
Loading…
Reference in a new issue