mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-09-23 14:51:27 +02:00
Code Issues Projects Releases Wiki Activity

MINOR: mux-h2: set CO_SFL_MSG_MORE when sending multiple buffers

Browse Source 
Traces show that sendto() rarely has MSG_MORE on H2 despite sending
multiple buffers. The reason is that the loop iterating over the buffer
ring doesn't have this info and doesn't pass it down.

But now we know how many buffers are left to be sent, so we know whether
or not the current buffer is the last one. As such we can set this flag
for all buffers but the last one.
This commit is contained in:
Willy Tarreau 2023-03-17 16:09:14 +01:00
parent 88718955f4
commit 464fa06e9a
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/mux_h2.c
View File

@ -3798,6 +3798,7 @@ static int h2_send(struct h2c *h2c)
unsigned int flags = 0; unsigned int flags = 0;
unsigned int released = 0; unsigned int released = 0;
struct buffer *buf; struct buffer *buf;
uint to_send;
/* fill as much as we can into the current buffer */ /* fill as much as we can into the current buffer */
while (((h2c->flags & (H2_CF_MUX_MFULL|H2_CF_MUX_MALLOC)) == 0) && !done) while (((h2c->flags & (H2_CF_MUX_MFULL|H2_CF_MUX_MALLOC)) == 0) && !done)
@ -3813,7 +3814,8 @@ static int h2_send(struct h2c *h2c)
if (h2c->flags & (H2_CF_MUX_MFULL | H2_CF_DEM_MROOM)) if (h2c->flags & (H2_CF_MUX_MFULL | H2_CF_DEM_MROOM))
flags |= CO_SFL_MSG_MORE; flags |= CO_SFL_MSG_MORE;
if (!br_single(h2c->mbuf)) { to_send = br_count(h2c->mbuf);
if (to_send > 1) {
/* usually we want to emit small TLS records to speed /* usually we want to emit small TLS records to speed
* up the decoding on the client. That's what is being * up the decoding on the client. That's what is being
* done by default. However if there is more than one * done by default. However if there is more than one
@ -3825,12 +3827,14 @@ static int h2_send(struct h2c *h2c)
for (buf = br_head(h2c->mbuf); b_size(buf); buf = br_del_head(h2c->mbuf)) { for (buf = br_head(h2c->mbuf); b_size(buf); buf = br_del_head(h2c->mbuf)) {
if (b_data(buf)) { if (b_data(buf)) {
int ret = conn->xprt->snd_buf(conn, conn->xprt_ctx, buf, b_data(buf), flags); int ret = conn->xprt->snd_buf(conn, conn->xprt_ctx, buf, b_data(buf),
flags | (to_send > 1 ? CO_SFL_MSG_MORE : 0));
if (!ret) { if (!ret) {
done = 1; done = 1;
break; break;
} }
sent = 1; sent = 1;
to_send--;
TRACE_DATA("sent data", H2_EV_H2C_SEND, h2c->conn, 0, buf, (void*)(long)ret); TRACE_DATA("sent data", H2_EV_H2C_SEND, h2c->conn, 0, buf, (void*)(long)ret);
b_del(buf, ret); b_del(buf, ret);
if (b_data(buf)) { if (b_data(buf)) {