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

MINOR: listener: export manage_global_listener_queue()

Browse Source 
This one pops up in tasks lists when running against a saturated
listener.
This commit is contained in:
Willy Tarreau 2021-01-29 14:29:06 +01:00
parent 5a2f938732
commit d597ec2718
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/haproxy/listener.h
View File

@ -214,6 +214,7 @@ static inline const char *listener_state_str(const struct listener *l)
}
struct task *accept_queue_process(struct task *t, void *context, unsigned short state);
struct task *manage_global_listener_queue(struct task *t, void *context, unsigned short state);
extern struct accept_queue_ring accept_queue_rings[MAX_THREADS] __attribute__((aligned(64)));

6
src/listener.c
View File

@ -45,7 +45,6 @@ static struct bind_kw_list bind_keywords = {
/* list of the temporarily limited listeners because of lack of resource */
static struct mt_list global_listener_queue = MT_LIST_HEAD_INIT(global_listener_queue);
static struct task *global_listener_queue_task;
static struct task *manage_global_listener_queue(struct task *t, void *context, unsigned short state);
#if defined(USE_THREAD)
@ -1150,9 +1149,10 @@ REGISTER_POST_DEINIT(listener_queue_deinit);
/* This is the global management task for listeners. It enables listeners waiting
* for global resources when there are enough free resource, or at least once in
* a while. It is designed to be called as a task.
* a while. It is designed to be called as a task. It's exported so that it's easy
* to spot in "show tasks" or "show profiling".
*/
static struct task *manage_global_listener_queue(struct task *t, void *context, unsigned short state)
struct task *manage_global_listener_queue(struct task *t, void *context, unsigned short state)
{
/* If there are still too many concurrent connections, let's wait for
* some of them to go away. We don't need to re-arm the timer because

1
src/tools.c
View File

@ -4697,6 +4697,7 @@ const void *resolve_sym_name(struct buffer *buf, const char *pfx, const void *ad
{ .func = sock_conn_iocb, .name = "sock_conn_iocb" },
{ .func = dgram_fd_handler, .name = "dgram_fd_handler" },
{ .func = listener_accept, .name = "listener_accept" },
{ .func = manage_global_listener_queue, .name = "manage_global_listener_queue" },
{ .func = poller_pipe_io_handler, .name = "poller_pipe_io_handler" },
{ .func = mworker_accept_wrapper, .name = "mworker_accept_wrapper" },
{ .func = session_expire_embryonic, .name = "session_expire_embryonic" },