mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2026-03-06 15:41:36 +01:00
Code Issues Projects Releases Wiki Activity

MINOR: mux-quic: add a trace context filling helper

Browse Source 
This helper is able to find a connection, a session, a stream, or a
frontend from its args.
This commit is contained in:
Willy Tarreau 2024-08-06 19:01:30 +02:00
parent b2cede590b
commit 6191de6aa6
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/qmux_trace.c
View File

@ -13,6 +13,9 @@ static void qmux_trace(enum trace_level level, uint64_t mask,
const struct ist where, const struct ist func,
const void *a1, const void *a2, const void *a3, const void *a4);
static void qmux_trace_fill_ctx(struct trace_ctx *ctx, const struct trace_source *src,
const void *a1, const void *a2, const void *a3, const void *a4);
static const struct name_desc qmux_trace_lockon_args[4] = {
/* arg1 */ { /* already used by the connection */ },
/* arg2 */ { .name="qcs", .desc="QUIC stream" },
@ -33,6 +36,7 @@ struct trace_source trace_qmux = {
.desc = "QUIC multiplexer",
.arg_def = TRC_ARG1_CONN, /* TRACE()'s first argument is always a connection */
.default_cb = qmux_trace,
.fill_ctx = qmux_trace_fill_ctx,
.known_events = qmux_trace_events,
.lockon_args = qmux_trace_lockon_args,
.decoding = qmux_trace_decoding,
@ -99,6 +103,28 @@ static void qmux_trace(enum trace_level level, uint64_t mask,
}
}
/* This fills the trace_ctx with extra info guessed from the args */
static void qmux_trace_fill_ctx(struct trace_ctx *ctx, const struct trace_source *src,
const void *a1, const void *a2, const void *a3, const void *a4)
{
const struct connection *conn = a1;
const struct qcc *qcc = conn ? conn->ctx : NULL;
const struct qcs *qcs = a2;
if (!ctx->conn)
ctx->conn = conn;
if (qcc) {
if (!ctx->fe)
ctx->fe = qcc->proxy;
}
if (qcs) {
if (!ctx->strm && qcs->sd && qcs->sd->sc)
ctx->strm = sc_strm(qcs->sd->sc);
}
}
/* register qmux traces */
INITCALL1(STG_REGISTER, trace_register_source, TRACE_SOURCE);