[lttng-modules.git] / instrumentation / events / lttng-module / sunrpc.h

#undef TRACE_SYSTEM
#define TRACE_SYSTEM sunrpc

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

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

LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_status,

	TP_PROTO(struct rpc_task *task),

	TP_ARGS(task),

	TP_STRUCT__entry(
		__field(const struct rpc_task *, task)
		__field(const struct rpc_clnt *, clnt)
		__field(int, status)
	),

	TP_fast_assign(
		tp_assign(task, task)
		tp_assign(clnt, task->tk_client)
		tp_assign(status, task->tk_status)
	),

	TP_printk("task:%p@%p, status %d",__entry->task, __entry->clnt, __entry->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)
)

LTTNG_TRACEPOINT_EVENT(rpc_connect_status,
	TP_PROTO(struct rpc_task *task, int status),

	TP_ARGS(task, status),

	TP_STRUCT__entry(
		__field(const struct rpc_task *, task)
		__field(const struct rpc_clnt *, clnt)
		__field(int, status)
	),

	TP_fast_assign(
		tp_assign(task, task)
		tp_assign(clnt, task->tk_client)
		tp_assign(status, status)
	),

	TP_printk("task:%p@%p, status %d",__entry->task, __entry->clnt, __entry->status)
)

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_STRUCT__entry(
		__field(const struct rpc_clnt *, clnt)
		__field(const struct rpc_task *, task)
		__field(const void *, action)
		__field(unsigned long, runstate)
		__field(int, status)
		__field(unsigned short, flags)
		),

	TP_fast_assign(
		tp_assign(clnt, clnt)
		tp_assign(task, task)
		tp_assign(action, action)
		tp_assign(runstate, task->tk_runstate)
		tp_assign(status, task->tk_status)
		tp_assign(flags, task->tk_flags)
		),

	TP_printk("task:%p@%p flags=%4.4x state=%4.4lx status=%d action=%pf",
		__entry->task,
		__entry->clnt,
		__entry->flags,
		__entry->runstate,
		__entry->status,
		__entry->action
		)
)

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_STRUCT__entry(
		__field(const struct rpc_clnt *, clnt)
		__field(const struct rpc_task *, task)
		__field(unsigned long, timeout)
		__field(unsigned long, runstate)
		__field(int, status)
		__field(unsigned short, flags)
		__string(q_name, rpc_qname(q))
		),

	TP_fast_assign(
		tp_assign(clnt, clnt)
		tp_assign(task, task)
		tp_assign(timeout, task->tk_timeout)
		tp_assign(runstate, task->tk_runstate)
		tp_assign(status, task->tk_status)
		tp_assign(flags, task->tk_flags)
		tp_strcpy(q_name, rpc_qname(q))
		),

	TP_printk("task:%p@%p flags=%4.4x state=%4.4lx status=%d timeout=%lu queue=%s",
		__entry->task,
		__entry->clnt,
		__entry->flags,
		__entry->runstate,
		__entry->status,
		__entry->timeout,
		__get_str(q_name)
		)
)

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 /* LTTNG_TRACE_SUNRPC_H */

#include "../../../probes/define_trace.h"
Commit	Line	Data
b87700e3 AG	1	#undef TRACE_SYSTEM
	2	#define TRACE_SYSTEM sunrpc
	3
3bc29f0a MD	4	#if !defined(LTTNG_TRACE_SUNRPC_H) \|\| defined(TRACE_HEADER_MULTI_READ)
3bc29f0a MD	5	#define LTTNG_TRACE_SUNRPC_H
b87700e3	6
3bc29f0a	7	#include "../../../probes/lttng-tracepoint-event.h"
b87700e3 AG	8	#include <linux/sunrpc/sched.h>
b87700e3 AG	9	#include <linux/sunrpc/clnt.h>
b87700e3	10
3bc29f0a	11	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_status,
b87700e3 AG	12
	13	TP_PROTO(struct rpc_task *task),
	14
	15	TP_ARGS(task),
	16
	17	TP_STRUCT__entry(
	18	__field(const struct rpc_task *, task)
	19	__field(const struct rpc_clnt *, clnt)
	20	__field(int, status)
	21	),
	22
	23	TP_fast_assign(
	24	tp_assign(task, task)
	25	tp_assign(clnt, task->tk_client)
	26	tp_assign(status, task->tk_status)
	27	),
	28
	29	TP_printk("task:%p@%p, status %d",__entry->task, __entry->clnt, __entry->status)
	30	)
	31
3bc29f0a	32	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_call_status,
b87700e3 AG	33	TP_PROTO(struct rpc_task *task),
	34
	35	TP_ARGS(task)
	36	)
	37
3bc29f0a	38	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_status, rpc_bind_status,
b87700e3 AG	39	TP_PROTO(struct rpc_task *task),
	40
	41	TP_ARGS(task)
	42	)
	43
3bc29f0a	44	LTTNG_TRACEPOINT_EVENT(rpc_connect_status,
b87700e3 AG	45	TP_PROTO(struct rpc_task *task, int status),
	46
	47	TP_ARGS(task, status),
	48
	49	TP_STRUCT__entry(
	50	__field(const struct rpc_task *, task)
	51	__field(const struct rpc_clnt *, clnt)
	52	__field(int, status)
	53	),
	54
	55	TP_fast_assign(
	56	tp_assign(task, task)
	57	tp_assign(clnt, task->tk_client)
	58	tp_assign(status, status)
	59	),
	60
	61	TP_printk("task:%p@%p, status %d",__entry->task, __entry->clnt, __entry->status)
	62	)
	63
3bc29f0a	64	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_running,
b87700e3 AG	65
	66	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	67
	68	TP_ARGS(clnt, task, action),
	69
	70	TP_STRUCT__entry(
	71	__field(const struct rpc_clnt *, clnt)
	72	__field(const struct rpc_task *, task)
	73	__field(const void *, action)
	74	__field(unsigned long, runstate)
	75	__field(int, status)
	76	__field(unsigned short, flags)
	77	),
	78
	79	TP_fast_assign(
	80	tp_assign(clnt, clnt)
	81	tp_assign(task, task)
	82	tp_assign(action, action)
	83	tp_assign(runstate, task->tk_runstate)
	84	tp_assign(status, task->tk_status)
	85	tp_assign(flags, task->tk_flags)
	86	),
	87
	88	TP_printk("task:%p@%p flags=%4.4x state=%4.4lx status=%d action=%pf",
	89	__entry->task,
	90	__entry->clnt,
	91	__entry->flags,
	92	__entry->runstate,
	93	__entry->status,
	94	__entry->action
	95	)
	96	)
	97
3bc29f0a	98	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_begin,
b87700e3 AG	99
	100	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	101
	102	TP_ARGS(clnt, task, action)
	103
	104	)
	105
3bc29f0a	106	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_run_action,
b87700e3 AG	107
	108	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	109
	110	TP_ARGS(clnt, task, action)
	111
	112	)
	113
3bc29f0a	114	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_running, rpc_task_complete,
b87700e3 AG	115
	116	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const void *action),
	117
	118	TP_ARGS(clnt, task, action)
	119
	120	)
	121
3bc29f0a	122	LTTNG_TRACEPOINT_EVENT_CLASS(rpc_task_queued,
b87700e3 AG	123
	124	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const struct rpc_wait_queue *q),
	125
	126	TP_ARGS(clnt, task, q),
	127
	128	TP_STRUCT__entry(
	129	__field(const struct rpc_clnt *, clnt)
	130	__field(const struct rpc_task *, task)
	131	__field(unsigned long, timeout)
	132	__field(unsigned long, runstate)
	133	__field(int, status)
	134	__field(unsigned short, flags)
	135	__string(q_name, rpc_qname(q))
	136	),
	137
	138	TP_fast_assign(
	139	tp_assign(clnt, clnt)
	140	tp_assign(task, task)
	141	tp_assign(timeout, task->tk_timeout)
	142	tp_assign(runstate, task->tk_runstate)
	143	tp_assign(status, task->tk_status)
	144	tp_assign(flags, task->tk_flags)
	145	tp_strcpy(q_name, rpc_qname(q))
	146	),
	147
	148	TP_printk("task:%p@%p flags=%4.4x state=%4.4lx status=%d timeout=%lu queue=%s",
	149	__entry->task,
	150	__entry->clnt,
	151	__entry->flags,
	152	__entry->runstate,
	153	__entry->status,
	154	__entry->timeout,
	155	__get_str(q_name)
	156	)
	157	)
	158
3bc29f0a	159	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_sleep,
b87700e3 AG	160
	161	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const struct rpc_wait_queue *q),
	162
	163	TP_ARGS(clnt, task, q)
	164
	165	)
	166
3bc29f0a	167	LTTNG_TRACEPOINT_EVENT_INSTANCE(rpc_task_queued, rpc_task_wakeup,
b87700e3 AG	168
	169	TP_PROTO(const struct rpc_clnt clnt, const struct rpc_task task, const struct rpc_wait_queue *q),
	170
	171	TP_ARGS(clnt, task, q)
	172
	173	)
	174
3bc29f0a	175	#endif /* LTTNG_TRACE_SUNRPC_H */
b87700e3 AG	176
b87700e3 AG	177	#include "../../../probes/define_trace.h"