mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-08-10 00:57:02 +02:00
Code Issues Projects Releases Wiki Activity

DEBUG: quic: export the few task handlers that often appear in task dumps

Browse Source 
The following task/tasklet handlers often appear in "show profiling tasks"
but were not resolved since static:

 qc_io_cb, quic_conn_app_io_cb, process_timer,
 quic_accept_run, qc_idle_timer_task

This commit simply exports them so they can be resolved now. "process_timer"
which was a bit too generic and renamed to qc_process_timer.
This commit is contained in:
Willy Tarreau 2022-09-08 15:12:59 +02:00
parent 0fbc16cfb9
commit 41e701e2c1
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/mux_quic.c
View File

@ -1854,7 +1854,7 @@ static void qc_release(struct qcc *qcc)
TRACE_LEAVE(QMUX_EV_QCC_END); TRACE_LEAVE(QMUX_EV_QCC_END);
} }
static struct task *qc_io_cb(struct task *t, void *ctx, unsigned int status) struct task *qc_io_cb(struct task *t, void *ctx, unsigned int status)
{ {
struct qcc *qcc = ctx; struct qcc *qcc = ctx;

2
src/quic_sock.c
View File

@ -461,7 +461,7 @@ void quic_accept_push_qc(struct quic_conn *qc)
/* Tasklet handler to accept QUIC connections. Call listener_accept on every /* Tasklet handler to accept QUIC connections. Call listener_accept on every
* listener instances registered in the accept queue. * listener instances registered in the accept queue.
*/ */
static struct task *quic_accept_run(struct task *t, void *ctx, unsigned int i) struct task *quic_accept_run(struct task *t, void *ctx, unsigned int i)
{ {
struct li_per_thread *lthr; struct li_per_thread *lthr;
struct mt_list *elt1, elt2; struct mt_list *elt1, elt2;

10
src/xprt_quic.c
View File

@ -214,7 +214,7 @@ static struct quic_tx_packet *qc_build_pkt(unsigned char **pos, const unsigned c
struct list *frms, struct quic_conn *qc, struct list *frms, struct quic_conn *qc,
const struct quic_version *ver, size_t dglen, int pkt_type, const struct quic_version *ver, size_t dglen, int pkt_type,
int force_ack, int padding, int probe, int cc, int *err); int force_ack, int padding, int probe, int cc, int *err);
static struct task *quic_conn_app_io_cb(struct task *t, void *context, unsigned int state); struct task *quic_conn_app_io_cb(struct task *t, void *context, unsigned int state);
static void qc_idle_timer_do_rearm(struct quic_conn *qc); static void qc_idle_timer_do_rearm(struct quic_conn *qc);
static void qc_idle_timer_rearm(struct quic_conn *qc, int read); static void qc_idle_timer_rearm(struct quic_conn *qc, int read);
static int qc_conn_alloc_ssl_ctx(struct quic_conn *qc); static int qc_conn_alloc_ssl_ctx(struct quic_conn *qc);
@ -4172,7 +4172,7 @@ static void qc_dgrams_retransmit(struct quic_conn *qc)
} }
/* QUIC connection packet handler task (post handshake) */ /* QUIC connection packet handler task (post handshake) */
static struct task *quic_conn_app_io_cb(struct task *t, void *context, unsigned int state) struct task *quic_conn_app_io_cb(struct task *t, void *context, unsigned int state)
{ {
struct ssl_sock_ctx *ctx; struct ssl_sock_ctx *ctx;
struct quic_conn *qc; struct quic_conn *qc;
@ -4569,7 +4569,7 @@ static void quic_close(struct connection *conn, void *xprt_ctx)
} }
/* Callback called upon loss detection and PTO timer expirations. */ /* Callback called upon loss detection and PTO timer expirations. */
static struct task *process_timer(struct task *task, void *ctx, unsigned int state) struct task *qc_process_timer(struct task *task, void *ctx, unsigned int state)
{ {
struct ssl_sock_ctx *conn_ctx; struct ssl_sock_ctx *conn_ctx;
struct quic_conn *qc; struct quic_conn *qc;
@ -4868,7 +4868,7 @@ static int quic_conn_init_timer(struct quic_conn *qc)
} }
qc->timer = TICK_ETERNITY; qc->timer = TICK_ETERNITY;
qc->timer_task->process = process_timer; qc->timer_task->process = qc_process_timer;
qc->timer_task->context = qc->xprt_ctx; qc->timer_task->context = qc->xprt_ctx;
ret = 1; ret = 1;
@ -4905,7 +4905,7 @@ static void qc_idle_timer_rearm(struct quic_conn *qc, int read)
} }
/* The task handling the idle timeout */ /* The task handling the idle timeout */
static struct task *qc_idle_timer_task(struct task *t, void *ctx, unsigned int state) struct task *qc_idle_timer_task(struct task *t, void *ctx, unsigned int state)
{ {
struct quic_conn *qc = ctx; struct quic_conn *qc = ctx;
struct quic_counters *prx_counters = qc->prx_counters; struct quic_counters *prx_counters = qc->prx_counters;