mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2026-05-04 12:41:00 +02:00
Code Issues Projects Releases Wiki Activity

MEDIUM: stconn: Properly handle large buffers during a receive

Browse Source 
While large buffers are still unused internally, functions receiving data
from endpoint (connections or applets) were updated to block the receives
when channels are using large buffer and the data forwarding was started.

The goal of this patch is to be able to flush large buffers at the end of
the analyzis stage to return asap on regular buffers.
This commit is contained in:
Christopher Faulet 2026-02-03 07:53:13 +01:00
parent ce912271db
commit bd25c63067
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/stconn.c
View File

@ -1378,6 +1378,10 @@ int sc_conn_recv(struct stconn *sc)
if (!sc_alloc_ibuf(sc, &(__sc_strm(sc)->buffer_wait)))
goto end_recv;
if ((ic->flags & CF_WROTE_DATA) && b_size(sc_ib(sc)) > global.tune.bufsize) {
sc_need_room(sc, -1);
goto done_recv;
}
/* For an HTX stream, if the buffer is stuck (no output data with some
* input data) and if the HTX message is fragmented or if its free space
* wraps, we force an HTX deframentation. It is a way to have a
@ -2063,6 +2067,11 @@ int sc_applet_recv(struct stconn *sc)
if (!sc_alloc_ibuf(sc, &appctx->buffer_wait))
goto end_recv;
if ((ic->flags & CF_WROTE_DATA) && b_size(sc_ib(sc)) > global.tune.bufsize) {
sc_need_room(sc, -1);
goto done_recv;
}
/* For an HTX stream, if the buffer is stuck (no output data with some
* input data) and if the HTX message is fragmented or if its free space
* wraps, we force an HTX deframentation. It is a way to have a