2 #define TRACE_SYSTEM sunrpc
4 #if !defined(_TRACE_SUNRPC_H) || defined(TRACE_HEADER_MULTI_READ)
5 #define _TRACE_SUNRPC_H
7 #include <linux/sunrpc/sched.h>
8 #include <linux/sunrpc/clnt.h>
9 #include <linux/sunrpc/svc.h>
10 #include <linux/sunrpc/xprtsock.h>
11 #include <net/tcp_states.h>
12 #include <linux/net.h>
13 #include <linux/tracepoint.h>
15 DECLARE_EVENT_CLASS(rpc_task_status,
17 TP_PROTO(struct rpc_task *task),
22 __field(unsigned int, task_id)
23 __field(unsigned int, client_id)
28 __entry->task_id = task->tk_pid;
29 __entry->client_id = task->tk_client->cl_clid;
30 __entry->status = task->tk_status;
33 TP_printk("task:%u@%u, status %d",
34 __entry->task_id, __entry->client_id,
38 DEFINE_EVENT(rpc_task_status, rpc_call_status,
39 TP_PROTO(struct rpc_task *task),
44 DEFINE_EVENT(rpc_task_status, rpc_bind_status,
45 TP_PROTO(struct rpc_task *task),
50 TRACE_EVENT(rpc_connect_status,
51 TP_PROTO(struct rpc_task *task, int status),
53 TP_ARGS(task, status),
56 __field(unsigned int, task_id)
57 __field(unsigned int, client_id)
62 __entry->task_id = task->tk_pid;
63 __entry->client_id = task->tk_client->cl_clid;
64 __entry->status = status;
67 TP_printk("task:%u@%u, status %d",
68 __entry->task_id, __entry->client_id,
72 DECLARE_EVENT_CLASS(rpc_task_running,
74 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),
76 TP_ARGS(clnt, task, action),
79 __field(unsigned int, task_id)
80 __field(unsigned int, client_id)
81 __field(const void *, action)
82 __field(unsigned long, runstate)
84 __field(unsigned short, flags)
88 __entry->client_id = clnt ? clnt->cl_clid : -1;
89 __entry->task_id = task->tk_pid;
90 __entry->action = action;
91 __entry->runstate = task->tk_runstate;
92 __entry->status = task->tk_status;
93 __entry->flags = task->tk_flags;
96 TP_printk("task:%u@%d flags=%4.4x state=%4.4lx status=%d action=%pf",
97 __entry->task_id, __entry->client_id,
105 DEFINE_EVENT(rpc_task_running, rpc_task_begin,
107 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),
109 TP_ARGS(clnt, task, action)
113 DEFINE_EVENT(rpc_task_running, rpc_task_run_action,
115 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),
117 TP_ARGS(clnt, task, action)
121 DEFINE_EVENT(rpc_task_running, rpc_task_complete,
123 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),
125 TP_ARGS(clnt, task, action)
129 DECLARE_EVENT_CLASS(rpc_task_queued,
131 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),
133 TP_ARGS(clnt, task, q),
136 __field(unsigned int, task_id)
137 __field(unsigned int, client_id)
138 __field(unsigned long, timeout)
139 __field(unsigned long, runstate)
141 __field(unsigned short, flags)
142 __string(q_name, rpc_qname(q))
146 __entry->client_id = clnt->cl_clid;
147 __entry->task_id = task->tk_pid;
148 __entry->timeout = task->tk_timeout;
149 __entry->runstate = task->tk_runstate;
150 __entry->status = task->tk_status;
151 __entry->flags = task->tk_flags;
152 __assign_str(q_name, rpc_qname(q));
155 TP_printk("task:%u@%u flags=%4.4x state=%4.4lx status=%d timeout=%lu queue=%s",
156 __entry->task_id, __entry->client_id,
165 DEFINE_EVENT(rpc_task_queued, rpc_task_sleep,
167 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),
169 TP_ARGS(clnt, task, q)
173 DEFINE_EVENT(rpc_task_queued, rpc_task_wakeup,
175 TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),
177 TP_ARGS(clnt, task, q)
181 #define rpc_show_socket_state(state) \
182 __print_symbolic(state, \
183 { SS_FREE, "FREE" }, \
184 { SS_UNCONNECTED, "UNCONNECTED" }, \
185 { SS_CONNECTING, "CONNECTING," }, \
186 { SS_CONNECTED, "CONNECTED," }, \
187 { SS_DISCONNECTING, "DISCONNECTING" })
189 #define rpc_show_sock_state(state) \
190 __print_symbolic(state, \
191 { TCP_ESTABLISHED, "ESTABLISHED" }, \
192 { TCP_SYN_SENT, "SYN_SENT" }, \
193 { TCP_SYN_RECV, "SYN_RECV" }, \
194 { TCP_FIN_WAIT1, "FIN_WAIT1" }, \
195 { TCP_FIN_WAIT2, "FIN_WAIT2" }, \
196 { TCP_TIME_WAIT, "TIME_WAIT" }, \
197 { TCP_CLOSE, "CLOSE" }, \
198 { TCP_CLOSE_WAIT, "CLOSE_WAIT" }, \
199 { TCP_LAST_ACK, "LAST_ACK" }, \
200 { TCP_LISTEN, "LISTEN" }, \
201 { TCP_CLOSING, "CLOSING" })
203 DECLARE_EVENT_CLASS(xs_socket_event,
206 struct rpc_xprt *xprt,
207 struct socket *socket
210 TP_ARGS(xprt, socket),
213 __field(unsigned int, socket_state)
214 __field(unsigned int, sock_state)
215 __field(unsigned long long, ino)
217 xprt->address_strings[RPC_DISPLAY_ADDR])
219 xprt->address_strings[RPC_DISPLAY_PORT])
223 struct inode *inode = SOCK_INODE(socket);
224 __entry->socket_state = socket->state;
225 __entry->sock_state = socket->sk->sk_state;
226 __entry->ino = (unsigned long long)inode->i_ino;
227 __assign_str(dstaddr,
228 xprt->address_strings[RPC_DISPLAY_ADDR]);
229 __assign_str(dstport,
230 xprt->address_strings[RPC_DISPLAY_PORT]);
234 "socket:[%llu] dstaddr=%s/%s "
235 "state=%u (%s) sk_state=%u (%s)",
236 __entry->ino, __get_str(dstaddr), __get_str(dstport),
237 __entry->socket_state,
238 rpc_show_socket_state(__entry->socket_state),
240 rpc_show_sock_state(__entry->sock_state)
243 #define DEFINE_RPC_SOCKET_EVENT(name) \
244 DEFINE_EVENT(xs_socket_event, name, \
246 struct rpc_xprt *xprt, \
247 struct socket *socket \
249 TP_ARGS(xprt, socket))
251 DECLARE_EVENT_CLASS(xs_socket_event_done,
254 struct rpc_xprt *xprt,
255 struct socket *socket,
259 TP_ARGS(xprt, socket, error),
263 __field(unsigned int, socket_state)
264 __field(unsigned int, sock_state)
265 __field(unsigned long long, ino)
267 xprt->address_strings[RPC_DISPLAY_ADDR])
269 xprt->address_strings[RPC_DISPLAY_PORT])
273 struct inode *inode = SOCK_INODE(socket);
274 __entry->socket_state = socket->state;
275 __entry->sock_state = socket->sk->sk_state;
276 __entry->ino = (unsigned long long)inode->i_ino;
277 __entry->error = error;
278 __assign_str(dstaddr,
279 xprt->address_strings[RPC_DISPLAY_ADDR]);
280 __assign_str(dstport,
281 xprt->address_strings[RPC_DISPLAY_PORT]);
285 "error=%d socket:[%llu] dstaddr=%s/%s "
286 "state=%u (%s) sk_state=%u (%s)",
288 __entry->ino, __get_str(dstaddr), __get_str(dstport),
289 __entry->socket_state,
290 rpc_show_socket_state(__entry->socket_state),
292 rpc_show_sock_state(__entry->sock_state)
295 #define DEFINE_RPC_SOCKET_EVENT_DONE(name) \
296 DEFINE_EVENT(xs_socket_event_done, name, \
298 struct rpc_xprt *xprt, \
299 struct socket *socket, \
302 TP_ARGS(xprt, socket, error))
304 DEFINE_RPC_SOCKET_EVENT(rpc_socket_state_change);
305 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_connect);
306 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_error);
307 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_reset_connection);
308 DEFINE_RPC_SOCKET_EVENT(rpc_socket_close);
309 DEFINE_RPC_SOCKET_EVENT(rpc_socket_shutdown);
311 DECLARE_EVENT_CLASS(rpc_xprt_event,
312 TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
314 TP_ARGS(xprt, xid, status),
319 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
320 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
325 __entry->status = status;
326 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]);
327 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]);
330 TP_printk("peer=[%s]:%s xid=0x%x status=%d", __get_str(addr),
331 __get_str(port), be32_to_cpu(__entry->xid),
335 DEFINE_EVENT(rpc_xprt_event, xprt_lookup_rqst,
336 TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
337 TP_ARGS(xprt, xid, status));
339 DEFINE_EVENT(rpc_xprt_event, xprt_transmit,
340 TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
341 TP_ARGS(xprt, xid, status));
343 DEFINE_EVENT(rpc_xprt_event, xprt_complete_rqst,
344 TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
345 TP_ARGS(xprt, xid, status));
347 TRACE_EVENT(xs_tcp_data_ready,
348 TP_PROTO(struct rpc_xprt *xprt, int err, unsigned int total),
350 TP_ARGS(xprt, err, total),
354 __field(unsigned int, total)
355 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
357 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
363 __entry->total = total;
364 __assign_str(addr, xprt ?
365 xprt->address_strings[RPC_DISPLAY_ADDR] : "(null)");
366 __assign_str(port, xprt ?
367 xprt->address_strings[RPC_DISPLAY_PORT] : "(null)");
370 TP_printk("peer=[%s]:%s err=%d total=%u", __get_str(addr),
371 __get_str(port), __entry->err, __entry->total)
374 #define rpc_show_sock_xprt_flags(flags) \
375 __print_flags(flags, "|", \
376 { TCP_RCV_LAST_FRAG, "TCP_RCV_LAST_FRAG" }, \
377 { TCP_RCV_COPY_FRAGHDR, "TCP_RCV_COPY_FRAGHDR" }, \
378 { TCP_RCV_COPY_XID, "TCP_RCV_COPY_XID" }, \
379 { TCP_RCV_COPY_DATA, "TCP_RCV_COPY_DATA" }, \
380 { TCP_RCV_READ_CALLDIR, "TCP_RCV_READ_CALLDIR" }, \
381 { TCP_RCV_COPY_CALLDIR, "TCP_RCV_COPY_CALLDIR" }, \
382 { TCP_RPC_REPLY, "TCP_RPC_REPLY" })
384 TRACE_EVENT(xs_tcp_data_recv,
385 TP_PROTO(struct sock_xprt *xs),
390 __string(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR])
391 __string(port, xs->xprt.address_strings[RPC_DISPLAY_PORT])
393 __field(unsigned long, flags)
394 __field(unsigned long, copied)
395 __field(unsigned int, reclen)
396 __field(unsigned long, offset)
400 __assign_str(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR]);
401 __assign_str(port, xs->xprt.address_strings[RPC_DISPLAY_PORT]);
402 __entry->xid = xs->tcp_xid;
403 __entry->flags = xs->tcp_flags;
404 __entry->copied = xs->tcp_copied;
405 __entry->reclen = xs->tcp_reclen;
406 __entry->offset = xs->tcp_offset;
409 TP_printk("peer=[%s]:%s xid=0x%x flags=%s copied=%lu reclen=%u offset=%lu",
410 __get_str(addr), __get_str(port), be32_to_cpu(__entry->xid),
411 rpc_show_sock_xprt_flags(__entry->flags),
412 __entry->copied, __entry->reclen, __entry->offset)
415 TRACE_EVENT(svc_recv,
416 TP_PROTO(struct svc_rqst *rqst, int status),
418 TP_ARGS(rqst, status),
421 __field(struct sockaddr *, addr)
427 __entry->addr = (struct sockaddr *)&rqst->rq_addr;
428 __entry->xid = status > 0 ? rqst->rq_xid : 0;
429 __entry->status = status;
432 TP_printk("addr=%pIScp xid=0x%x status=%d", __entry->addr,
433 be32_to_cpu(__entry->xid), __entry->status)
436 DECLARE_EVENT_CLASS(svc_rqst_status,
438 TP_PROTO(struct svc_rqst *rqst, int status),
440 TP_ARGS(rqst, status),
443 __field(struct sockaddr *, addr)
450 __entry->addr = (struct sockaddr *)&rqst->rq_addr;
451 __entry->xid = rqst->rq_xid;
452 __entry->dropme = (int)rqst->rq_dropme;
453 __entry->status = status;
456 TP_printk("addr=%pIScp rq_xid=0x%x dropme=%d status=%d",
457 __entry->addr, be32_to_cpu(__entry->xid), __entry->dropme,
461 DEFINE_EVENT(svc_rqst_status, svc_process,
462 TP_PROTO(struct svc_rqst *rqst, int status),
463 TP_ARGS(rqst, status));
465 DEFINE_EVENT(svc_rqst_status, svc_send,
466 TP_PROTO(struct svc_rqst *rqst, int status),
467 TP_ARGS(rqst, status));
469 #endif /* _TRACE_SUNRPC_H */
471 #include <trace/define_trace.h>