RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2025-04-01 22:48:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

BUG/MEDIUM: cli: Never wait for more data on client shutdown

Browse Source 
When a shutdown is detected on the cli, we try to execute all pending
commands first before closing the connection. It is required because
commands execution is serialized. However, when the last part is a partial
command, the cli connection is not closed, waiting for more data. Because
there is no timeout for now on the cli socket, the connection remains
infinitely in this state. And because the maxconn is set to 10, if it
happens several times, the cli socket quickly becomes unresponsive because
all its slots are waiting for more data on a closed connections.

This patch should fix the issue #1512. It must be backported as far as 2.0.
This commit is contained in:
Christopher Faulet 2022-01-18 08:44:23 +01:00 committed by Willy Tarreau
parent 94fca87f6a
commit 0f727dabf5
1 changed files with 23 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/cli.c
View File

@ -2441,20 +2441,11 @@ read_again:
/* We don't know yet to which server we will connect */
channel_dont_connect(req);
/* we are not waiting for a response, there is no more request and we
* receive a close from the client, we can leave */
if (!(ci_data(req)) && req->flags & CF_SHUTR) {
channel_shutw_now(&s->res);
s->req.analysers &= ~AN_REQ_WAIT_CLI;
return 1;
}
req->flags |= CF_READ_DONTWAIT;
/* need more data */
if (!ci_data(req))
return 0;
goto missing_data;
/* If there is data available for analysis, log the end of the idle time. */
if (c_data(req) && s->logs.t_idle == -1)
@ -2497,14 +2488,14 @@ read_again:
/* we trimmed things but we might have other commands to consume */
pcli_write_prompt(s);
goto read_again;
} else if (to_forward == -1 && errmsg) {
/* there was an error during the parsing */
pcli_reply_and_close(s, errmsg);
s->req.analysers &= ~AN_REQ_WAIT_CLI;
return 0;
} else if (to_forward == -1 && channel_full(req, global.tune.maxrewrite)) {
/* buffer is full and we didn't catch the end of a command */
goto send_help;
} else if (to_forward == -1) {
if (errmsg) {
/* there was an error during the parsing */
pcli_reply_and_close(s, errmsg);
s->req.analysers &= ~AN_REQ_WAIT_CLI;
return 0;
}
goto missing_data;
}
return 0;
@ -2514,6 +2505,20 @@ send_help:
b_putblk(&req->buf, "help\n", 5);
goto read_again;
missing_data:
if (req->flags & CF_SHUTR) {
/* There is no more request or a only a partial one and we
* receive a close from the client, we can leave */
channel_shutw_now(&s->res);
s->req.analysers &= ~AN_REQ_WAIT_CLI;
return 1;
}
else if (channel_full(req, global.tune.maxrewrite)) {
/* buffer is full and we didn't catch the end of a command */
goto send_help;
}
return 0;
server_disconnect:
pcli_reply_and_close(s, "Can't connect to the target CLI!\n");
return 0;