mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-12-06 18:21:17 +01:00
Code Issues Projects Releases Wiki Activity

MINOR: listener: export accept_queue_process

Browse Source 
This is only to make it resolve in "show tasks".
This commit is contained in:
Willy Tarreau 2021-01-29 12:25:23 +01:00
parent 7eff06e162
commit fb5401f296
3 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/haproxy/listener.h
View File

@ -213,6 +213,8 @@ static inline const char *listener_state_str(const struct listener *l)
return states[st];
}
struct task *accept_queue_process(struct task *t, void *context, unsigned short state);
extern struct accept_queue_ring accept_queue_rings[MAX_THREADS] __attribute__((aligned(64)));
#endif /* _HAPROXY_LISTENER_H */

6
src/listener.c
View File

@ -112,8 +112,10 @@ int accept_queue_push_mp(struct accept_queue_ring *ring, struct connection *conn
return 1;
}
/* proceed with accepting new connections */
static struct task *accept_queue_process(struct task *t, void *context, unsigned short state)
/* proceed with accepting new connections. Don't mark it static so that it appears
* in task dumps.
*/
struct task *accept_queue_process(struct task *t, void *context, unsigned short state)
{
struct accept_queue_ring *ring = context;
struct connection *conn;

3
src/tools.c
View File

@ -4699,6 +4699,9 @@ const void *resolve_sym_name(struct buffer *buf, const char *pfx, const void *ad
{ .func = listener_accept, .name = "listener_accept" },
{ .func = poller_pipe_io_handler, .name = "poller_pipe_io_handler" },
{ .func = mworker_accept_wrapper, .name = "mworker_accept_wrapper" },
#ifdef USE_THREAD
{ .func = accept_queue_process, .name = "accept_queue_process" },
#endif
#ifdef USE_LUA
{ .func = hlua_process_task, .name = "hlua_process_task" },
#endif