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

BUG/MEDIUM: http-ana: Never for sending data in TUNNEL mode

Browse Source 
When a channel is set in TUNNEL mode, we now always set the CF_NEVER_WAIT flag,
to be sure to never wait for sending data. It is important because in TUNNEL
mode, we have no idea if more data are expected or not. Setting this flag
prevent the MSG_MORE flag to be set on the connection.

It is only a problem with the HTX, since the 2.2. On previous versions, the
MSG_MORE flag is only set on the mux initiative. In fact, the problem arises
because there is an ambiguity in tunnel mode about the HTX_FL_EOI flag. In this
mode, from the mux point of view, while the SHUTR is not received more data are
expected. But from the channel point of view, we want to send data asap.

At short term, this fix is good enough and is valid anyway. But for the long
term more reliable solution must be found. At least, the to_forward field must
regain its original meaning.

This patch must be backported as far as 2.2.
This commit is contained in:
Christopher Faulet 2020-12-15 13:32:55 +01:00
parent 3e1748bbf3
commit 198ef8b1de
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/http_ana.c
View File

@ -4225,8 +4225,11 @@ static void http_end_request(struct stream *s)
end: end:
chn->analysers &= AN_REQ_FLT_END; chn->analysers &= AN_REQ_FLT_END;
if (txn->req.msg_state == HTTP_MSG_TUNNEL && HAS_REQ_DATA_FILTERS(s)) if (txn->req.msg_state == HTTP_MSG_TUNNEL) {
chn->flags |= CF_NEVER_WAIT;
if (HAS_REQ_DATA_FILTERS(s))
chn->analysers |= AN_REQ_FLT_XFER_DATA; chn->analysers |= AN_REQ_FLT_XFER_DATA;
}
channel_auto_close(chn); channel_auto_close(chn);
channel_auto_read(chn); channel_auto_read(chn);
DBG_TRACE_LEAVE(STRM_EV_HTTP_ANA, s, txn); DBG_TRACE_LEAVE(STRM_EV_HTTP_ANA, s, txn);
@ -4280,7 +4283,6 @@ static void http_end_response(struct stream *s)
*/ */
if (txn->flags & TX_CON_WANT_TUN) { if (txn->flags & TX_CON_WANT_TUN) {
channel_auto_read(chn); channel_auto_read(chn);
chn->flags |= CF_NEVER_WAIT;
if (b_data(&chn->buf)) { if (b_data(&chn->buf)) {
DBG_TRACE_DEVEL("waiting to flush the respone", STRM_EV_HTTP_ANA, s, txn); DBG_TRACE_DEVEL("waiting to flush the respone", STRM_EV_HTTP_ANA, s, txn);
return; return;
@ -4340,8 +4342,11 @@ static void http_end_response(struct stream *s)
end: end:
chn->analysers &= AN_RES_FLT_END; chn->analysers &= AN_RES_FLT_END;
if (txn->rsp.msg_state == HTTP_MSG_TUNNEL && HAS_RSP_DATA_FILTERS(s)) if (txn->rsp.msg_state == HTTP_MSG_TUNNEL) {
chn->analysers |= AN_RES_FLT_XFER_DATA; chn->flags |= CF_NEVER_WAIT;
if (HAS_RSP_DATA_FILTERS(s))
chn->analysers |= AN_RES_FLT_XFER_DATA;
}
channel_auto_close(chn); channel_auto_close(chn);
channel_auto_read(chn); channel_auto_read(chn);
DBG_TRACE_LEAVE(STRM_EV_HTTP_ANA, s, txn); DBG_TRACE_LEAVE(STRM_EV_HTTP_ANA, s, txn);