upstream/haproxy
1
0
Fork 0
mirror of https://github.com/haproxy/haproxy.git synced 2026-06-25 01:10:59 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 12

cleanup

Browse source
This commit is contained in:
Frederic Lecaille 2026-06-22 16:45:18 +02:00
parent 26ce14ea82
commit ff434c5a19
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/haload.c
View file

@ -1119,7 +1119,6 @@ struct task *hld_strm_task(struct task *t, void *context, unsigned int state)
if (!hs->conn) {
struct protocol *proto;
const struct mux_ops *mux_ops;
int flags = arg_fast ? (CONNECT_HAS_DATA|CONNECT_DELACK_ALWAYS) : 0;
int status;
@ -1182,6 +1181,8 @@ struct task *hld_strm_task(struct task *t, void *context, unsigned int state)
}
if (!conn_is_ssl(conn) || !srv->ssl_ctx.alpn_str) {
const struct mux_ops *mux_ops;
if (srv->mux_proto)
mux_ops = srv->mux_proto->mux;
else
@ -1277,8 +1278,10 @@ struct task *hld_strm_task(struct task *t, void *context, unsigned int state)
thrs_info[tid].tot_perr++;
url->mreqs++;
BUG_ON(!url->tot_rconn_sent);
url->tot_rconn_sent--;
if (arg_rcon > 0) {
BUG_ON(!url->tot_rconn_sent);
url->tot_rconn_sent--;
}
BUG_ON(arg_rcon > 0 && url->tot_rconn_done > arg_rcon);
/* Note that the user task will release all the expired streams
* attached to it.
@ -1435,7 +1438,8 @@ static struct task *hld_usr_task(struct task *t, void *context, unsigned int sta
url->cfg->cur_path = hld_next_path(url->cfg->paths, path);
BUG_ON(!url->mreqs || !usr->nreqs || !nreqs);
url->tot_rconn_sent++;
if (arg_rcon > 0)
url->tot_rconn_sent++;
url->mreqs--;
nreqs--;
usr->nreqs = usr->nreqs == -1 ? -1 : usr->nreqs - 1;