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

MINOR: protocol: add protocol_stop_now() to instant-stop listeners

Browse Source 
This will instantly stop all listeners except those which belong to
a proxy configured with a grace time. This means that UDP listeners,
and peers will also be stopped when called this way.
This commit is contained in:
Willy Tarreau 2020-10-07 16:50:49 +02:00
parent acde152175
commit 02e8557e88
2 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
include/haproxy/protocol.h
View File

@ -50,6 +50,14 @@ int protocol_bind_all(int verbose);
*/ */
int protocol_unbind_all(void); int protocol_unbind_all(void);
/* stops all listeners of all registered protocols, except when the belong to a
* proxy configured with a grace time. This will normally catch every single
* listener, all protocols included, and the grace ones will have to be handled
* by the proxy stopping loop. This is to be used during soft_stop() only. It
* does not return any error.
*/
void protocol_stop_now(void);
/* pauses all listeners of all registered protocols. This is typically /* pauses all listeners of all registered protocols. This is typically
* used on SIG_TTOU to release all listening sockets for the time needed to * used on SIG_TTOU to release all listening sockets for the time needed to
* try to bind a new process. The listeners enter LI_PAUSED. It returns * try to bind a new process. The listeners enter LI_PAUSED. It returns

20
src/protocol.c
View File

@ -151,6 +151,26 @@ int protocol_unbind_all(void)
return err; return err;
} }
/* stops all listeners of all registered protocols, except when the belong to a
* proxy configured with a grace time. This will normally catch every single
* listener, all protocols included, and the grace ones will have to be handled
* by the proxy stopping loop. This is to be used during soft_stop() only. It
* does not return any error.
*/
void protocol_stop_now(void)
{
struct protocol *proto;
struct listener *listener, *lback;
HA_SPIN_LOCK(PROTO_LOCK, &proto_lock);
list_for_each_entry(proto, &protocols, list) {
list_for_each_entry_safe(listener, lback, &proto->receivers, rx.proto_list)
if (!listener->bind_conf->frontend->grace)
stop_listener(listener, 0, 1, 0);
}
HA_SPIN_UNLOCK(PROTO_LOCK, &proto_lock);
}
/* pauses all listeners of all registered protocols. This is typically /* pauses all listeners of all registered protocols. This is typically
* used on SIG_TTOU to release all listening sockets for the time needed to * used on SIG_TTOU to release all listening sockets for the time needed to
* try to bind a new process. The listeners enter LI_PAUSED. It returns * try to bind a new process. The listeners enter LI_PAUSED. It returns