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

BUG/MEDIUM: h2: always add a stream to the send or fctl list when blocked

Browse Source 
When a stream blocks on a mux buffer full/unallocated or on connection
flow control, a flag among H2_SF_MUX_M* is set, but the stream is not
always added to the connection's list. It's properly done when the
operations are performed from the connection handler but not always when
done from the stream handler. For instance, a simple shutr or shutw may
fail by lack of room. If it's immediately followed by a call to h2_detach(),
the stream remains lying around in no list at all, and prevents the
connection from ending. This problem is actually quite difficult to
trigger and seems to require some large objects and low server-side
timeouts.

This patch covers all identified paths. Some are redundant but since the
code will change and will be simplified in 1.9, it's better to stay on
the safe side here for now. It must be backported to 1.8.
This commit is contained in:
Willy Tarreau 2018-03-30 17:35:38 +02:00
parent 1a1dd6066f
commit b2e290acb6
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/mux_h2.c
View File

@ -2505,17 +2505,25 @@ static void h2_shutr(struct conn_stream *cs, enum cs_shr_mode mode)
*/ */
if (!(h2s->flags & H2_SF_RST_SENT) && if (!(h2s->flags & H2_SF_RST_SENT) &&
h2s_send_rst_stream(h2s->h2c, h2s) <= 0) h2s_send_rst_stream(h2s->h2c, h2s) <= 0)
return; goto add_to_list;
if (!(h2s->flags & H2_SF_OUTGOING_DATA) && if (!(h2s->flags & H2_SF_OUTGOING_DATA) &&
!(h2s->h2c->flags & (H2_CF_GOAWAY_SENT|H2_CF_GOAWAY_FAILED)) && !(h2s->h2c->flags & (H2_CF_GOAWAY_SENT|H2_CF_GOAWAY_FAILED)) &&
h2c_send_goaway_error(h2s->h2c, h2s) <= 0) h2c_send_goaway_error(h2s->h2c, h2s) <= 0)
return; goto add_to_list;
if (h2s->h2c->mbuf->o && !(cs->conn->flags & CO_FL_XPRT_WR_ENA)) if (h2s->h2c->mbuf->o && !(cs->conn->flags & CO_FL_XPRT_WR_ENA))
conn_xprt_want_send(cs->conn); conn_xprt_want_send(cs->conn);
h2s_close(h2s); h2s_close(h2s);
add_to_list:
if (LIST_ISEMPTY(&h2s->list)) {
if (h2s->flags & H2_SF_BLK_MFCTL)
LIST_ADDQ(&h2s->h2c->fctl_list, &h2s->list);
else if (h2s->flags & (H2_SF_BLK_MBUSY|H2_SF_BLK_MROOM))
LIST_ADDQ(&h2s->h2c->send_list, &h2s->list);
}
} }
static void h2_shutw(struct conn_stream *cs, enum cs_shw_mode mode) static void h2_shutw(struct conn_stream *cs, enum cs_shw_mode mode)
@ -2530,7 +2538,7 @@ static void h2_shutw(struct conn_stream *cs, enum cs_shw_mode mode)
if (!(h2s->flags & (H2_SF_ES_SENT|H2_SF_RST_SENT)) && if (!(h2s->flags & (H2_SF_ES_SENT|H2_SF_RST_SENT)) &&
h2_send_empty_data_es(h2s) <= 0) h2_send_empty_data_es(h2s) <= 0)
return; goto add_to_list;
if (h2s->st == H2_SS_HREM) if (h2s->st == H2_SS_HREM)
h2s_close(h2s); h2s_close(h2s);
@ -2544,18 +2552,26 @@ static void h2_shutw(struct conn_stream *cs, enum cs_shw_mode mode)
*/ */
if (!(h2s->flags & H2_SF_RST_SENT) && if (!(h2s->flags & H2_SF_RST_SENT) &&
h2s_send_rst_stream(h2s->h2c, h2s) <= 0) h2s_send_rst_stream(h2s->h2c, h2s) <= 0)
return; goto add_to_list;
if (!(h2s->flags & H2_SF_OUTGOING_DATA) && if (!(h2s->flags & H2_SF_OUTGOING_DATA) &&
!(h2s->h2c->flags & (H2_CF_GOAWAY_SENT|H2_CF_GOAWAY_FAILED)) && !(h2s->h2c->flags & (H2_CF_GOAWAY_SENT|H2_CF_GOAWAY_FAILED)) &&
h2c_send_goaway_error(h2s->h2c, h2s) <= 0) h2c_send_goaway_error(h2s->h2c, h2s) <= 0)
return; goto add_to_list;
h2s_close(h2s); h2s_close(h2s);
} }
if (h2s->h2c->mbuf->o && !(cs->conn->flags & CO_FL_XPRT_WR_ENA)) if (h2s->h2c->mbuf->o && !(cs->conn->flags & CO_FL_XPRT_WR_ENA))
conn_xprt_want_send(cs->conn); conn_xprt_want_send(cs->conn);
add_to_list:
if (LIST_ISEMPTY(&h2s->list)) {
if (h2s->flags & H2_SF_BLK_MFCTL)
LIST_ADDQ(&h2s->h2c->fctl_list, &h2s->list);
else if (h2s->flags & (H2_SF_BLK_MBUSY|H2_SF_BLK_MROOM))
LIST_ADDQ(&h2s->h2c->send_list, &h2s->list);
}
} }
/* Decode the payload of a HEADERS frame and produce the equivalent HTTP/1 /* Decode the payload of a HEADERS frame and produce the equivalent HTTP/1
@ -3328,6 +3344,12 @@ static int h2_snd_buf(struct conn_stream *cs, struct buffer *buf, int flags)
LIST_DEL(&h2s->list); LIST_DEL(&h2s->list);
LIST_INIT(&h2s->list); LIST_INIT(&h2s->list);
} }
else if (LIST_ISEMPTY(&h2s->list)) {
if (h2s->flags & H2_SF_BLK_MFCTL)
LIST_ADDQ(&h2s->h2c->fctl_list, &h2s->list);
else if (h2s->flags & (H2_SF_BLK_MBUSY|H2_SF_BLK_MROOM))
LIST_ADDQ(&h2s->h2c->send_list, &h2s->list);
}
return total; return total;
} }