mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-08-10 00:57:02 +02:00
Code Issues Projects Releases Wiki Activity

MINOR: mux-quic: free RX buf if empty

Browse Source 
Release the QCS RX buffer if emptied afer qcs_consume(). This improves
memory usage and avoids a QCS to keep an allocated buffer, particularly
when no data is received anymore. Buffer is automatically reallocated if
needed via qc_get_ncbuf().
This commit is contained in:
Amaury Denoyelle 2022-05-18 16:19:47 +02:00
parent 7313f5ee7e
commit 8b87b15c22
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/mux_quic.c
View File

@ -296,13 +296,17 @@ void qcs_consume(struct qcs *qcs, uint64_t bytes)
{ {
struct qcc *qcc = qcs->qcc; struct qcc *qcc = qcs->qcc;
struct quic_frame *frm; struct quic_frame *frm;
struct ncbuf *buf = &qcs->rx.ncbuf;
enum ncb_ret ret; enum ncb_ret ret;
ret = ncb_advance(&qcs->rx.ncbuf, bytes); ret = ncb_advance(buf, bytes);
if (ret) { if (ret) {
ABORT_NOW(); /* should not happens because removal only in data */ ABORT_NOW(); /* should not happens because removal only in data */
} }
if (ncb_is_empty(buf))
qc_free_ncbuf(qcs, buf);
qcs->rx.offset += bytes; qcs->rx.offset += bytes;
if (qcs->rx.msd - qcs->rx.offset < qcs->rx.msd_init / 2) { if (qcs->rx.msd - qcs->rx.offset < qcs->rx.msd_init / 2) {
frm = pool_zalloc(pool_head_quic_frame); frm = pool_zalloc(pool_head_quic_frame);