Merge tag 'ext4_for_linus_stable' of git://git.kernel.org/pub/scm/linux/kernel/git...
[firefly-linux-kernel-4.4.55.git] / include / trace / events / sunrpc.h
1 #undef TRACE_SYSTEM
2 #define TRACE_SYSTEM sunrpc
3
4 #if !defined(_TRACE_SUNRPC_H) || defined(TRACE_HEADER_MULTI_READ)
5 #define _TRACE_SUNRPC_H
6
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 <linux/sunrpc/svc_xprt.h>
12 #include <net/tcp_states.h>
13 #include <linux/net.h>
14 #include <linux/tracepoint.h>
15
16 DECLARE_EVENT_CLASS(rpc_task_status,
17
18         TP_PROTO(struct rpc_task *task),
19
20         TP_ARGS(task),
21
22         TP_STRUCT__entry(
23                 __field(unsigned int, task_id)
24                 __field(unsigned int, client_id)
25                 __field(int, status)
26         ),
27
28         TP_fast_assign(
29                 __entry->task_id = task->tk_pid;
30                 __entry->client_id = task->tk_client->cl_clid;
31                 __entry->status = task->tk_status;
32         ),
33
34         TP_printk("task:%u@%u, status %d",
35                 __entry->task_id, __entry->client_id,
36                 __entry->status)
37 );
38
39 DEFINE_EVENT(rpc_task_status, rpc_call_status,
40         TP_PROTO(struct rpc_task *task),
41
42         TP_ARGS(task)
43 );
44
45 DEFINE_EVENT(rpc_task_status, rpc_bind_status,
46         TP_PROTO(struct rpc_task *task),
47
48         TP_ARGS(task)
49 );
50
51 TRACE_EVENT(rpc_connect_status,
52         TP_PROTO(struct rpc_task *task, int status),
53
54         TP_ARGS(task, status),
55
56         TP_STRUCT__entry(
57                 __field(unsigned int, task_id)
58                 __field(unsigned int, client_id)
59                 __field(int, status)
60         ),
61
62         TP_fast_assign(
63                 __entry->task_id = task->tk_pid;
64                 __entry->client_id = task->tk_client->cl_clid;
65                 __entry->status = status;
66         ),
67
68         TP_printk("task:%u@%u, status %d",
69                 __entry->task_id, __entry->client_id,
70                 __entry->status)
71 );
72
73 DECLARE_EVENT_CLASS(rpc_task_running,
74
75         TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),
76
77         TP_ARGS(clnt, task, action),
78
79         TP_STRUCT__entry(
80                 __field(unsigned int, task_id)
81                 __field(unsigned int, client_id)
82                 __field(const void *, action)
83                 __field(unsigned long, runstate)
84                 __field(int, status)
85                 __field(unsigned short, flags)
86                 ),
87
88         TP_fast_assign(
89                 __entry->client_id = clnt ? clnt->cl_clid : -1;
90                 __entry->task_id = task->tk_pid;
91                 __entry->action = action;
92                 __entry->runstate = task->tk_runstate;
93                 __entry->status = task->tk_status;
94                 __entry->flags = task->tk_flags;
95                 ),
96
97         TP_printk("task:%u@%d flags=%4.4x state=%4.4lx status=%d action=%pf",
98                 __entry->task_id, __entry->client_id,
99                 __entry->flags,
100                 __entry->runstate,
101                 __entry->status,
102                 __entry->action
103                 )
104 );
105
106 DEFINE_EVENT(rpc_task_running, rpc_task_begin,
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
114 DEFINE_EVENT(rpc_task_running, rpc_task_run_action,
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
122 DEFINE_EVENT(rpc_task_running, rpc_task_complete,
123
124         TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const void *action),
125
126         TP_ARGS(clnt, task, action)
127
128 );
129
130 DECLARE_EVENT_CLASS(rpc_task_queued,
131
132         TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),
133
134         TP_ARGS(clnt, task, q),
135
136         TP_STRUCT__entry(
137                 __field(unsigned int, task_id)
138                 __field(unsigned int, client_id)
139                 __field(unsigned long, timeout)
140                 __field(unsigned long, runstate)
141                 __field(int, status)
142                 __field(unsigned short, flags)
143                 __string(q_name, rpc_qname(q))
144                 ),
145
146         TP_fast_assign(
147                 __entry->client_id = clnt->cl_clid;
148                 __entry->task_id = task->tk_pid;
149                 __entry->timeout = task->tk_timeout;
150                 __entry->runstate = task->tk_runstate;
151                 __entry->status = task->tk_status;
152                 __entry->flags = task->tk_flags;
153                 __assign_str(q_name, rpc_qname(q));
154                 ),
155
156         TP_printk("task:%u@%u flags=%4.4x state=%4.4lx status=%d timeout=%lu queue=%s",
157                 __entry->task_id, __entry->client_id,
158                 __entry->flags,
159                 __entry->runstate,
160                 __entry->status,
161                 __entry->timeout,
162                 __get_str(q_name)
163                 )
164 );
165
166 DEFINE_EVENT(rpc_task_queued, rpc_task_sleep,
167
168         TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),
169
170         TP_ARGS(clnt, task, q)
171
172 );
173
174 DEFINE_EVENT(rpc_task_queued, rpc_task_wakeup,
175
176         TP_PROTO(const struct rpc_clnt *clnt, const struct rpc_task *task, const struct rpc_wait_queue *q),
177
178         TP_ARGS(clnt, task, q)
179
180 );
181
182 #define rpc_show_socket_state(state) \
183         __print_symbolic(state, \
184                 { SS_FREE, "FREE" }, \
185                 { SS_UNCONNECTED, "UNCONNECTED" }, \
186                 { SS_CONNECTING, "CONNECTING," }, \
187                 { SS_CONNECTED, "CONNECTED," }, \
188                 { SS_DISCONNECTING, "DISCONNECTING" })
189
190 #define rpc_show_sock_state(state) \
191         __print_symbolic(state, \
192                 { TCP_ESTABLISHED, "ESTABLISHED" }, \
193                 { TCP_SYN_SENT, "SYN_SENT" }, \
194                 { TCP_SYN_RECV, "SYN_RECV" }, \
195                 { TCP_FIN_WAIT1, "FIN_WAIT1" }, \
196                 { TCP_FIN_WAIT2, "FIN_WAIT2" }, \
197                 { TCP_TIME_WAIT, "TIME_WAIT" }, \
198                 { TCP_CLOSE, "CLOSE" }, \
199                 { TCP_CLOSE_WAIT, "CLOSE_WAIT" }, \
200                 { TCP_LAST_ACK, "LAST_ACK" }, \
201                 { TCP_LISTEN, "LISTEN" }, \
202                 { TCP_CLOSING, "CLOSING" })
203
204 DECLARE_EVENT_CLASS(xs_socket_event,
205
206                 TP_PROTO(
207                         struct rpc_xprt *xprt,
208                         struct socket *socket
209                 ),
210
211                 TP_ARGS(xprt, socket),
212
213                 TP_STRUCT__entry(
214                         __field(unsigned int, socket_state)
215                         __field(unsigned int, sock_state)
216                         __field(unsigned long long, ino)
217                         __string(dstaddr,
218                                 xprt->address_strings[RPC_DISPLAY_ADDR])
219                         __string(dstport,
220                                 xprt->address_strings[RPC_DISPLAY_PORT])
221                 ),
222
223                 TP_fast_assign(
224                         struct inode *inode = SOCK_INODE(socket);
225                         __entry->socket_state = socket->state;
226                         __entry->sock_state = socket->sk->sk_state;
227                         __entry->ino = (unsigned long long)inode->i_ino;
228                         __assign_str(dstaddr,
229                                 xprt->address_strings[RPC_DISPLAY_ADDR]);
230                         __assign_str(dstport,
231                                 xprt->address_strings[RPC_DISPLAY_PORT]);
232                 ),
233
234                 TP_printk(
235                         "socket:[%llu] dstaddr=%s/%s "
236                         "state=%u (%s) sk_state=%u (%s)",
237                         __entry->ino, __get_str(dstaddr), __get_str(dstport),
238                         __entry->socket_state,
239                         rpc_show_socket_state(__entry->socket_state),
240                         __entry->sock_state,
241                         rpc_show_sock_state(__entry->sock_state)
242                 )
243 );
244 #define DEFINE_RPC_SOCKET_EVENT(name) \
245         DEFINE_EVENT(xs_socket_event, name, \
246                         TP_PROTO( \
247                                 struct rpc_xprt *xprt, \
248                                 struct socket *socket \
249                         ), \
250                         TP_ARGS(xprt, socket))
251
252 DECLARE_EVENT_CLASS(xs_socket_event_done,
253
254                 TP_PROTO(
255                         struct rpc_xprt *xprt,
256                         struct socket *socket,
257                         int error
258                 ),
259
260                 TP_ARGS(xprt, socket, error),
261
262                 TP_STRUCT__entry(
263                         __field(int, error)
264                         __field(unsigned int, socket_state)
265                         __field(unsigned int, sock_state)
266                         __field(unsigned long long, ino)
267                         __string(dstaddr,
268                                 xprt->address_strings[RPC_DISPLAY_ADDR])
269                         __string(dstport,
270                                 xprt->address_strings[RPC_DISPLAY_PORT])
271                 ),
272
273                 TP_fast_assign(
274                         struct inode *inode = SOCK_INODE(socket);
275                         __entry->socket_state = socket->state;
276                         __entry->sock_state = socket->sk->sk_state;
277                         __entry->ino = (unsigned long long)inode->i_ino;
278                         __entry->error = error;
279                         __assign_str(dstaddr,
280                                 xprt->address_strings[RPC_DISPLAY_ADDR]);
281                         __assign_str(dstport,
282                                 xprt->address_strings[RPC_DISPLAY_PORT]);
283                 ),
284
285                 TP_printk(
286                         "error=%d socket:[%llu] dstaddr=%s/%s "
287                         "state=%u (%s) sk_state=%u (%s)",
288                         __entry->error,
289                         __entry->ino, __get_str(dstaddr), __get_str(dstport),
290                         __entry->socket_state,
291                         rpc_show_socket_state(__entry->socket_state),
292                         __entry->sock_state,
293                         rpc_show_sock_state(__entry->sock_state)
294                 )
295 );
296 #define DEFINE_RPC_SOCKET_EVENT_DONE(name) \
297         DEFINE_EVENT(xs_socket_event_done, name, \
298                         TP_PROTO( \
299                                 struct rpc_xprt *xprt, \
300                                 struct socket *socket, \
301                                 int error \
302                         ), \
303                         TP_ARGS(xprt, socket, error))
304
305 DEFINE_RPC_SOCKET_EVENT(rpc_socket_state_change);
306 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_connect);
307 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_error);
308 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_reset_connection);
309 DEFINE_RPC_SOCKET_EVENT(rpc_socket_close);
310 DEFINE_RPC_SOCKET_EVENT(rpc_socket_shutdown);
311
312 DECLARE_EVENT_CLASS(rpc_xprt_event,
313         TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
314
315         TP_ARGS(xprt, xid, status),
316
317         TP_STRUCT__entry(
318                 __field(__be32, xid)
319                 __field(int, status)
320                 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
321                 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
322         ),
323
324         TP_fast_assign(
325                 __entry->xid = xid;
326                 __entry->status = status;
327                 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]);
328                 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]);
329         ),
330
331         TP_printk("peer=[%s]:%s xid=0x%x status=%d", __get_str(addr),
332                         __get_str(port), be32_to_cpu(__entry->xid),
333                         __entry->status)
334 );
335
336 DEFINE_EVENT(rpc_xprt_event, xprt_lookup_rqst,
337         TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
338         TP_ARGS(xprt, xid, status));
339
340 DEFINE_EVENT(rpc_xprt_event, xprt_transmit,
341         TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
342         TP_ARGS(xprt, xid, status));
343
344 DEFINE_EVENT(rpc_xprt_event, xprt_complete_rqst,
345         TP_PROTO(struct rpc_xprt *xprt, __be32 xid, int status),
346         TP_ARGS(xprt, xid, status));
347
348 TRACE_EVENT(xs_tcp_data_ready,
349         TP_PROTO(struct rpc_xprt *xprt, int err, unsigned int total),
350
351         TP_ARGS(xprt, err, total),
352
353         TP_STRUCT__entry(
354                 __field(int, err)
355                 __field(unsigned int, total)
356                 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
357                                 "(null)")
358                 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
359                                 "(null)")
360         ),
361
362         TP_fast_assign(
363                 __entry->err = err;
364                 __entry->total = total;
365                 __assign_str(addr, xprt ?
366                         xprt->address_strings[RPC_DISPLAY_ADDR] : "(null)");
367                 __assign_str(port, xprt ?
368                         xprt->address_strings[RPC_DISPLAY_PORT] : "(null)");
369         ),
370
371         TP_printk("peer=[%s]:%s err=%d total=%u", __get_str(addr),
372                         __get_str(port), __entry->err, __entry->total)
373 );
374
375 #define rpc_show_sock_xprt_flags(flags) \
376         __print_flags(flags, "|", \
377                 { TCP_RCV_LAST_FRAG, "TCP_RCV_LAST_FRAG" }, \
378                 { TCP_RCV_COPY_FRAGHDR, "TCP_RCV_COPY_FRAGHDR" }, \
379                 { TCP_RCV_COPY_XID, "TCP_RCV_COPY_XID" }, \
380                 { TCP_RCV_COPY_DATA, "TCP_RCV_COPY_DATA" }, \
381                 { TCP_RCV_READ_CALLDIR, "TCP_RCV_READ_CALLDIR" }, \
382                 { TCP_RCV_COPY_CALLDIR, "TCP_RCV_COPY_CALLDIR" }, \
383                 { TCP_RPC_REPLY, "TCP_RPC_REPLY" })
384
385 TRACE_EVENT(xs_tcp_data_recv,
386         TP_PROTO(struct sock_xprt *xs),
387
388         TP_ARGS(xs),
389
390         TP_STRUCT__entry(
391                 __string(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR])
392                 __string(port, xs->xprt.address_strings[RPC_DISPLAY_PORT])
393                 __field(__be32, xid)
394                 __field(unsigned long, flags)
395                 __field(unsigned long, copied)
396                 __field(unsigned int, reclen)
397                 __field(unsigned long, offset)
398         ),
399
400         TP_fast_assign(
401                 __assign_str(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR]);
402                 __assign_str(port, xs->xprt.address_strings[RPC_DISPLAY_PORT]);
403                 __entry->xid = xs->tcp_xid;
404                 __entry->flags = xs->tcp_flags;
405                 __entry->copied = xs->tcp_copied;
406                 __entry->reclen = xs->tcp_reclen;
407                 __entry->offset = xs->tcp_offset;
408         ),
409
410         TP_printk("peer=[%s]:%s xid=0x%x flags=%s copied=%lu reclen=%u offset=%lu",
411                         __get_str(addr), __get_str(port), be32_to_cpu(__entry->xid),
412                         rpc_show_sock_xprt_flags(__entry->flags),
413                         __entry->copied, __entry->reclen, __entry->offset)
414 );
415
416 #define show_rqstp_flags(flags)                                         \
417         __print_flags(flags, "|",                                       \
418                 { (1UL << RQ_SECURE),           "RQ_SECURE"},           \
419                 { (1UL << RQ_LOCAL),            "RQ_LOCAL"},            \
420                 { (1UL << RQ_USEDEFERRAL),      "RQ_USEDEFERRAL"},      \
421                 { (1UL << RQ_DROPME),           "RQ_DROPME"},           \
422                 { (1UL << RQ_SPLICE_OK),        "RQ_SPLICE_OK"},        \
423                 { (1UL << RQ_VICTIM),           "RQ_VICTIM"},           \
424                 { (1UL << RQ_BUSY),             "RQ_BUSY"})
425
426 TRACE_EVENT(svc_recv,
427         TP_PROTO(struct svc_rqst *rqst, int status),
428
429         TP_ARGS(rqst, status),
430
431         TP_STRUCT__entry(
432                 __field(struct sockaddr *, addr)
433                 __field(__be32, xid)
434                 __field(int, status)
435                 __field(unsigned long, flags)
436         ),
437
438         TP_fast_assign(
439                 __entry->addr = (struct sockaddr *)&rqst->rq_addr;
440                 __entry->xid = status > 0 ? rqst->rq_xid : 0;
441                 __entry->status = status;
442                 __entry->flags = rqst->rq_flags;
443         ),
444
445         TP_printk("addr=%pIScp xid=0x%x status=%d flags=%s", __entry->addr,
446                         be32_to_cpu(__entry->xid), __entry->status,
447                         show_rqstp_flags(__entry->flags))
448 );
449
450 DECLARE_EVENT_CLASS(svc_rqst_status,
451
452         TP_PROTO(struct svc_rqst *rqst, int status),
453
454         TP_ARGS(rqst, status),
455
456         TP_STRUCT__entry(
457                 __field(struct sockaddr *, addr)
458                 __field(__be32, xid)
459                 __field(int, dropme)
460                 __field(int, status)
461                 __field(unsigned long, flags)
462         ),
463
464         TP_fast_assign(
465                 __entry->addr = (struct sockaddr *)&rqst->rq_addr;
466                 __entry->xid = rqst->rq_xid;
467                 __entry->status = status;
468                 __entry->flags = rqst->rq_flags;
469         ),
470
471         TP_printk("addr=%pIScp rq_xid=0x%x status=%d flags=%s",
472                 __entry->addr, be32_to_cpu(__entry->xid),
473                 __entry->status, show_rqstp_flags(__entry->flags))
474 );
475
476 DEFINE_EVENT(svc_rqst_status, svc_process,
477         TP_PROTO(struct svc_rqst *rqst, int status),
478         TP_ARGS(rqst, status));
479
480 DEFINE_EVENT(svc_rqst_status, svc_send,
481         TP_PROTO(struct svc_rqst *rqst, int status),
482         TP_ARGS(rqst, status));
483
484 #define show_svc_xprt_flags(flags)                                      \
485         __print_flags(flags, "|",                                       \
486                 { (1UL << XPT_BUSY),            "XPT_BUSY"},            \
487                 { (1UL << XPT_CONN),            "XPT_CONN"},            \
488                 { (1UL << XPT_CLOSE),           "XPT_CLOSE"},           \
489                 { (1UL << XPT_DATA),            "XPT_DATA"},            \
490                 { (1UL << XPT_TEMP),            "XPT_TEMP"},            \
491                 { (1UL << XPT_DEAD),            "XPT_DEAD"},            \
492                 { (1UL << XPT_CHNGBUF),         "XPT_CHNGBUF"},         \
493                 { (1UL << XPT_DEFERRED),        "XPT_DEFERRED"},        \
494                 { (1UL << XPT_OLD),             "XPT_OLD"},             \
495                 { (1UL << XPT_LISTENER),        "XPT_LISTENER"},        \
496                 { (1UL << XPT_CACHE_AUTH),      "XPT_CACHE_AUTH"},      \
497                 { (1UL << XPT_LOCAL),           "XPT_LOCAL"})
498
499 TRACE_EVENT(svc_xprt_do_enqueue,
500         TP_PROTO(struct svc_xprt *xprt, struct svc_rqst *rqst),
501
502         TP_ARGS(xprt, rqst),
503
504         TP_STRUCT__entry(
505                 __field(struct svc_xprt *, xprt)
506                 __field(struct svc_rqst *, rqst)
507         ),
508
509         TP_fast_assign(
510                 __entry->xprt = xprt;
511                 __entry->rqst = rqst;
512         ),
513
514         TP_printk("xprt=0x%p addr=%pIScp pid=%d flags=%s", __entry->xprt,
515                 (struct sockaddr *)&__entry->xprt->xpt_remote,
516                 __entry->rqst ? __entry->rqst->rq_task->pid : 0,
517                 show_svc_xprt_flags(__entry->xprt->xpt_flags))
518 );
519
520 TRACE_EVENT(svc_xprt_dequeue,
521         TP_PROTO(struct svc_xprt *xprt),
522
523         TP_ARGS(xprt),
524
525         TP_STRUCT__entry(
526                 __field(struct svc_xprt *, xprt)
527                 __field_struct(struct sockaddr_storage, ss)
528                 __field(unsigned long, flags)
529         ),
530
531         TP_fast_assign(
532                 __entry->xprt = xprt,
533                 xprt ? memcpy(&__entry->ss, &xprt->xpt_remote, sizeof(__entry->ss)) : memset(&__entry->ss, 0, sizeof(__entry->ss));
534                 __entry->flags = xprt ? xprt->xpt_flags : 0;
535         ),
536
537         TP_printk("xprt=0x%p addr=%pIScp flags=%s", __entry->xprt,
538                 (struct sockaddr *)&__entry->ss,
539                 show_svc_xprt_flags(__entry->flags))
540 );
541
542 TRACE_EVENT(svc_wake_up,
543         TP_PROTO(int pid),
544
545         TP_ARGS(pid),
546
547         TP_STRUCT__entry(
548                 __field(int, pid)
549         ),
550
551         TP_fast_assign(
552                 __entry->pid = pid;
553         ),
554
555         TP_printk("pid=%d", __entry->pid)
556 );
557
558 TRACE_EVENT(svc_handle_xprt,
559         TP_PROTO(struct svc_xprt *xprt, int len),
560
561         TP_ARGS(xprt, len),
562
563         TP_STRUCT__entry(
564                 __field(struct svc_xprt *, xprt)
565                 __field(int, len)
566         ),
567
568         TP_fast_assign(
569                 __entry->xprt = xprt;
570                 __entry->len = len;
571         ),
572
573         TP_printk("xprt=0x%p addr=%pIScp len=%d flags=%s", __entry->xprt,
574                 (struct sockaddr *)&__entry->xprt->xpt_remote, __entry->len,
575                 show_svc_xprt_flags(__entry->xprt->xpt_flags))
576 );
577 #endif /* _TRACE_SUNRPC_H */
578
579 #include <trace/define_trace.h>