[lttng-modules.git] / include / instrumentation / events / rpc.h

/* SPDX-License-Identifier: GPL-2.0-only */
#undef TRACE_SYSTEM
#define TRACE_SYSTEM rpc

#if !defined(LTTNG_TRACE_RPC_H) || defined(TRACE_HEADER_MULTI_READ)
#define LTTNG_TRACE_RPC_H

#include <lttng/tracepoint-event.h>
#include <linux/sunrpc/sched.h>
#include <linux/sunrpc/clnt.h>

#ifndef ONCE_LTTNG_RPC_H
#define ONCE_LTTNG_RPC_H

static inline
int lttng_get_clid(const struct rpc_task *task)
{
	struct rpc_clnt *tk_client;

	tk_client = task->tk_client;
	if (!tk_client)
		return -1;
	/*
	 * The cl_clid field is always initialized to positive signed
	 * integers. Negative signed integer values are treated as
	 * errors.
	 */
	return (int) tk_client->cl_clid;
}

#endif /* ONCE_LTTNG_RPC_H */

#if (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(5,0,0) || \
	LTTNG_RHEL_KERNEL_RANGE(4,18,0,193,0,0, 4,19,0,0,0,0))
LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_status,

	TP_PROTO(const struct rpc_task *task),

	TP_ARGS(task),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer(int, status, task->tk_status)
	)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_call_status,
	TP_PROTO(const struct rpc_task *task),

	TP_ARGS(task)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_bind_status,
	TP_PROTO(const struct rpc_task *task),

	TP_ARGS(task)
)
#else
LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_status,

	TP_PROTO(struct rpc_task *task),

	TP_ARGS(task),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer(int, status, task->tk_status)
	)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_call_status,
	TP_PROTO(struct rpc_task *task),

	TP_ARGS(task)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_bind_status,
	TP_PROTO(struct rpc_task *task),

	TP_ARGS(task)
)
#endif

#if (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(5,0,0))
LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_connect_status,
	TP_PROTO(const struct rpc_task *task),

	TP_ARGS(task)
)
#elif (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(4,17,0))
LTTNG_TRACEPOINT_EVENT(rpc_connect_status,
	TP_PROTO(const struct rpc_task *task),

	TP_ARGS(task),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer(int, status, task->tk_status)
	)
)
#else
LTTNG_TRACEPOINT_EVENT(rpc_connect_status,
	TP_PROTO(struct rpc_task *task, int status),

	TP_ARGS(task, status),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer(int, status, status)
	)
)
#endif

#if (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(4,17,0))
LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_running,

	TP_PROTO(const struct rpc_task *task, const void *action),

	TP_ARGS(task, action),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer_hex(const void *, action, action)
		ctf_integer(unsigned long, runstate, task->tk_runstate)
		ctf_integer(int, status, task->tk_status)
		ctf_integer(unsigned short, flags, task->tk_flags)
	)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_begin,

	TP_PROTO(const struct rpc_task *task, const void *action),

	TP_ARGS(task, action)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_run_action,

	TP_PROTO(const struct rpc_task *task, const void *action),

	TP_ARGS(task, action)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_complete,

	TP_PROTO(const struct rpc_task *task, const void *action),

	TP_ARGS(task, action)
)

LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_queued,

	TP_PROTO(const struct rpc_task *task, const struct rpc_wait_queue *q),

	TP_ARGS(task, q),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer(unsigned long, timeout, task->tk_timeout)
		ctf_integer(unsigned long, runstate, task->tk_runstate)
		ctf_integer(int, status, task->tk_status)
		ctf_integer(unsigned short, flags, task->tk_flags)
		ctf_string(q_name, rpc_qname(q))
	)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_sleep,

	TP_PROTO(const struct rpc_task *task, const struct rpc_wait_queue *q),

	TP_ARGS(task, q)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_wakeup,

	TP_PROTO(const struct rpc_task *task, const struct rpc_wait_queue *q),

	TP_ARGS(task, q)
)

#else
LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_running,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),

	TP_ARGS(clnt, task, action),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer_hex(const void *, action, action)
		ctf_integer(unsigned long, runstate, task->tk_runstate)
		ctf_integer(int, status, task->tk_status)
		ctf_integer(unsigned short, flags, task->tk_flags)
	)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_begin,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),

	TP_ARGS(clnt, task, action)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_run_action,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),

	TP_ARGS(clnt, task, action)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_complete,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),

	TP_ARGS(clnt, task, action)
)

LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_queued,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),

	TP_ARGS(clnt, task, q),

	TP_FIELDS(
		ctf_integer(unsigned int, task_id, task->tk_pid)
		ctf_integer(int, client_id, lttng_get_clid(task))
		ctf_integer(unsigned long, timeout, task->tk_timeout)
		ctf_integer(unsigned long, runstate, task->tk_runstate)
		ctf_integer(int, status, task->tk_status)
		ctf_integer(unsigned short, flags, task->tk_flags)
		ctf_string(q_name, rpc_qname(q))
	)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_sleep,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),

	TP_ARGS(clnt, task, q)
)

LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_wakeup,

	TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),

	TP_ARGS(clnt, task, q)
)
#endif

#endif /* LTTNG_TRACE_RPC_H */

#include <lttng/define_trace.h>
Commit	Line	Data
	1	/* SPDX-License-Identifier: GPL-2.0-only */
	2	#undef TRACE_SYSTEM
	3	#define TRACE_SYSTEM rpc
	4
	5	#if !defined(LTTNG_TRACE_RPC_H) \|\| defined(TRACE_HEADER_MULTI_READ)
	6	#define LTTNG_TRACE_RPC_H
	7
	8	#include <lttng/tracepoint-event.h>
	9	#include <linux/sunrpc/sched.h>
	10	#include <linux/sunrpc/clnt.h>
	11
	12	#ifndef ONCE_LTTNG_RPC_H
	13	#define ONCE_LTTNG_RPC_H
	14
	15	static inline
	16	int lttng_get_clid(const struct rpc_task *task)
	17	{
	18	struct rpc_clnt *tk_client;
	19
	20	tk_client = task->tk_client;
	21	if (!tk_client)
	22	return -1;
	23	/*
	24	* The cl_clid field is always initialized to positive signed
	25	* integers. Negative signed integer values are treated as
	26	* errors.
	27	*/
	28	return (int) tk_client->cl_clid;
	29	}
	30
	31	#endif /* ONCE_LTTNG_RPC_H */
	32
	33	#if (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(5,0,0) \|\| \
	34	LTTNG_RHEL_KERNEL_RANGE(4,18,0,193,0,0, 4,19,0,0,0,0))
	35	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_status,
	36
	37	TP_PROTO(const struct rpc_task *task),
	38
	39	TP_ARGS(task),
	40
	41	TP_FIELDS(
	42	ctf_integer(unsigned int, task_id, task->tk_pid)
	43	ctf_integer(int, client_id, lttng_get_clid(task))
	44	ctf_integer(int, status, task->tk_status)
	45	)
	46	)
	47
	48	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_call_status,
	49	TP_PROTO(const struct rpc_task *task),
	50
	51	TP_ARGS(task)
	52	)
	53
	54	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_bind_status,
	55	TP_PROTO(const struct rpc_task *task),
	56
	57	TP_ARGS(task)
	58	)
	59	#else
	60	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_status,
	61
	62	TP_PROTO(struct rpc_task *task),
	63
	64	TP_ARGS(task),
	65
	66	TP_FIELDS(
	67	ctf_integer(unsigned int, task_id, task->tk_pid)
	68	ctf_integer(int, client_id, lttng_get_clid(task))
	69	ctf_integer(int, status, task->tk_status)
	70	)
	71	)
	72
	73	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_call_status,
	74	TP_PROTO(struct rpc_task *task),
	75
	76	TP_ARGS(task)
	77	)
	78
	79	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_bind_status,
	80	TP_PROTO(struct rpc_task *task),
	81
	82	TP_ARGS(task)
	83	)
	84	#endif
	85
	86	#if (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(5,0,0))
	87	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_connect_status,
	88	TP_PROTO(const struct rpc_task *task),
	89
	90	TP_ARGS(task)
	91	)
	92	#elif (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(4,17,0))
	93	LTTNG_TRACEPOINT_EVENT(rpc_connect_status,
	94	TP_PROTO(const struct rpc_task *task),
	95
	96	TP_ARGS(task),
	97
	98	TP_FIELDS(
	99	ctf_integer(unsigned int, task_id, task->tk_pid)
	100	ctf_integer(int, client_id, lttng_get_clid(task))
	101	ctf_integer(int, status, task->tk_status)
	102	)
	103	)
	104	#else
	105	LTTNG_TRACEPOINT_EVENT(rpc_connect_status,
	106	TP_PROTO(struct rpc_task *task, int status),
	107
	108	TP_ARGS(task, status),
	109
	110	TP_FIELDS(
	111	ctf_integer(unsigned int, task_id, task->tk_pid)
	112	ctf_integer(int, client_id, lttng_get_clid(task))
	113	ctf_integer(int, status, status)
	114	)
	115	)
	116	#endif
	117
	118	#if (LTTNG_LINUX_VERSION_CODE >= LTTNG_KERNEL_VERSION(4,17,0))
	119	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_running,
	120
	121	TP_PROTO(const struct rpc_task task, const void action),
	122
	123	TP_ARGS(task, action),
	124
	125	TP_FIELDS(
	126	ctf_integer(unsigned int, task_id, task->tk_pid)
	127	ctf_integer(int, client_id, lttng_get_clid(task))
	128	ctf_integer_hex(const void *, action, action)
	129	ctf_integer(unsigned long, runstate, task->tk_runstate)
	130	ctf_integer(int, status, task->tk_status)
	131	ctf_integer(unsigned short, flags, task->tk_flags)
	132	)
	133	)
	134
	135	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_begin,
	136
	137	TP_PROTO(const struct rpc_task task, const void action),
	138
	139	TP_ARGS(task, action)
	140	)
	141
	142	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_run_action,
	143
	144	TP_PROTO(const struct rpc_task task, const void action),
	145
	146	TP_ARGS(task, action)
	147	)
	148
	149	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_complete,
	150
	151	TP_PROTO(const struct rpc_task task, const void action),
	152
	153	TP_ARGS(task, action)
	154	)
	155
	156	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_queued,
	157
	158	TP_PROTO(const struct rpc_task task, const struct rpc_wait_queue q),
	159
	160	TP_ARGS(task, q),
	161
	162	TP_FIELDS(
	163	ctf_integer(unsigned int, task_id, task->tk_pid)
	164	ctf_integer(int, client_id, lttng_get_clid(task))
	165	ctf_integer(unsigned long, timeout, task->tk_timeout)
	166	ctf_integer(unsigned long, runstate, task->tk_runstate)
	167	ctf_integer(int, status, task->tk_status)
	168	ctf_integer(unsigned short, flags, task->tk_flags)
	169	ctf_string(q_name, rpc_qname(q))
	170	)
	171	)
	172
	173	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_sleep,
	174
	175	TP_PROTO(const struct rpc_task task, const struct rpc_wait_queue q),
	176
	177	TP_ARGS(task, q)
	178	)
	179
	180	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_wakeup,
	181
	182	TP_PROTO(const struct rpc_task task, const struct rpc_wait_queue q),
	183
	184	TP_ARGS(task, q)
	185	)
	186
	187	#else
	188	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_running,
	189
	190	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	191
	192	TP_ARGS(clnt, task, action),
	193
	194	TP_FIELDS(
	195	ctf_integer(unsigned int, task_id, task->tk_pid)
	196	ctf_integer(int, client_id, lttng_get_clid(task))
	197	ctf_integer_hex(const void *, action, action)
	198	ctf_integer(unsigned long, runstate, task->tk_runstate)
	199	ctf_integer(int, status, task->tk_status)
	200	ctf_integer(unsigned short, flags, task->tk_flags)
	201	)
	202	)
	203
	204	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_begin,
	205
	206	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	207
	208	TP_ARGS(clnt, task, action)
	209	)
	210
	211	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_run_action,
	212
	213	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	214
	215	TP_ARGS(clnt, task, action)
	216	)
	217
	218	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_complete,
	219
	220	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	221
	222	TP_ARGS(clnt, task, action)
	223	)
	224
	225	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_queued,
	226
	227	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const struct rpc_wait_queue *q),
	228
	229	TP_ARGS(clnt, task, q),
	230
	231	TP_FIELDS(
	232	ctf_integer(unsigned int, task_id, task->tk_pid)
	233	ctf_integer(int, client_id, lttng_get_clid(task))
	234	ctf_integer(unsigned long, timeout, task->tk_timeout)
	235	ctf_integer(unsigned long, runstate, task->tk_runstate)
	236	ctf_integer(int, status, task->tk_status)
	237	ctf_integer(unsigned short, flags, task->tk_flags)
	238	ctf_string(q_name, rpc_qname(q))
	239	)
	240	)
	241
	242	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_sleep,
	243
	244	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const struct rpc_wait_queue *q),
	245
	246	TP_ARGS(clnt, task, q)
	247	)
	248
	249	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_wakeup,
	250
	251	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const struct rpc_wait_queue *q),
	252
	253	TP_ARGS(clnt, task, q)
	254	)
	255	#endif
	256
	257	#endif /* LTTNG_TRACE_RPC_H */
	258
	259	#include <lttng/define_trace.h>