1 /* SPDX-License-Identifier: GPL-2.0 */ 2 #undef TRACE_SYSTEM 3 #define TRACE_SYSTEM sunrpc 4 5 #if !defined(_TRACE_SUNRPC_H) || defined(TRACE_HEADER_MULTI_READ) 6 #define _TRACE_SUNRPC_H 7 8 #include <linux/sunrpc/sched.h> 9 #include <linux/sunrpc/clnt.h> 10 #include <linux/sunrpc/svc.h> 11 #include <linux/sunrpc/xprtsock.h> 12 #include <linux/sunrpc/svc_xprt.h> 13 #include <net/tcp_states.h> 14 #include <linux/net.h> 15 #include <linux/tracepoint.h> 16 17 TRACE_DEFINE_ENUM(SOCK_STREAM); 18 TRACE_DEFINE_ENUM(SOCK_DGRAM); 19 TRACE_DEFINE_ENUM(SOCK_RAW); 20 TRACE_DEFINE_ENUM(SOCK_RDM); 21 TRACE_DEFINE_ENUM(SOCK_SEQPACKET); 22 TRACE_DEFINE_ENUM(SOCK_DCCP); 23 TRACE_DEFINE_ENUM(SOCK_PACKET); 24 25 #define show_socket_type(type) \ 26 __print_symbolic(type, \ 27 { SOCK_STREAM, "STREAM" }, \ 28 { SOCK_DGRAM, "DGRAM" }, \ 29 { SOCK_RAW, "RAW" }, \ 30 { SOCK_RDM, "RDM" }, \ 31 { SOCK_SEQPACKET, "SEQPACKET" }, \ 32 { SOCK_DCCP, "DCCP" }, \ 33 { SOCK_PACKET, "PACKET" }) 34 35 /* This list is known to be incomplete, add new enums as needed. */ 36 TRACE_DEFINE_ENUM(AF_UNSPEC); 37 TRACE_DEFINE_ENUM(AF_UNIX); 38 TRACE_DEFINE_ENUM(AF_LOCAL); 39 TRACE_DEFINE_ENUM(AF_INET); 40 TRACE_DEFINE_ENUM(AF_INET6); 41 42 #define rpc_show_address_family(family) \ 43 __print_symbolic(family, \ 44 { AF_UNSPEC, "AF_UNSPEC" }, \ 45 { AF_UNIX, "AF_UNIX" }, \ 46 { AF_LOCAL, "AF_LOCAL" }, \ 47 { AF_INET, "AF_INET" }, \ 48 { AF_INET6, "AF_INET6" }) 49 50 DECLARE_EVENT_CLASS(rpc_xdr_buf_class, 51 TP_PROTO( 52 const struct rpc_task *task, 53 const struct xdr_buf *xdr 54 ), 55 56 TP_ARGS(task, xdr), 57 58 TP_STRUCT__entry( 59 __field(unsigned int, task_id) 60 __field(unsigned int, client_id) 61 __field(const void *, head_base) 62 __field(size_t, head_len) 63 __field(const void *, tail_base) 64 __field(size_t, tail_len) 65 __field(unsigned int, page_len) 66 __field(unsigned int, msg_len) 67 ), 68 69 TP_fast_assign( 70 __entry->task_id = task->tk_pid; 71 __entry->client_id = task->tk_client ? 72 task->tk_client->cl_clid : -1; 73 __entry->head_base = xdr->head[0].iov_base; 74 __entry->head_len = xdr->head[0].iov_len; 75 __entry->tail_base = xdr->tail[0].iov_base; 76 __entry->tail_len = xdr->tail[0].iov_len; 77 __entry->page_len = xdr->page_len; 78 __entry->msg_len = xdr->len; 79 ), 80 81 TP_printk("task:%u@%u head=[%p,%zu] page=%u tail=[%p,%zu] len=%u", 82 __entry->task_id, __entry->client_id, 83 __entry->head_base, __entry->head_len, __entry->page_len, 84 __entry->tail_base, __entry->tail_len, __entry->msg_len 85 ) 86 ); 87 88 #define DEFINE_RPCXDRBUF_EVENT(name) \ 89 DEFINE_EVENT(rpc_xdr_buf_class, \ 90 rpc_xdr_##name, \ 91 TP_PROTO( \ 92 const struct rpc_task *task, \ 93 const struct xdr_buf *xdr \ 94 ), \ 95 TP_ARGS(task, xdr)) 96 97 DEFINE_RPCXDRBUF_EVENT(sendto); 98 DEFINE_RPCXDRBUF_EVENT(recvfrom); 99 DEFINE_RPCXDRBUF_EVENT(reply_pages); 100 101 102 DECLARE_EVENT_CLASS(rpc_clnt_class, 103 TP_PROTO( 104 const struct rpc_clnt *clnt 105 ), 106 107 TP_ARGS(clnt), 108 109 TP_STRUCT__entry( 110 __field(unsigned int, client_id) 111 ), 112 113 TP_fast_assign( 114 __entry->client_id = clnt->cl_clid; 115 ), 116 117 TP_printk("clid=%u", __entry->client_id) 118 ); 119 120 #define DEFINE_RPC_CLNT_EVENT(name) \ 121 DEFINE_EVENT(rpc_clnt_class, \ 122 rpc_clnt_##name, \ 123 TP_PROTO( \ 124 const struct rpc_clnt *clnt \ 125 ), \ 126 TP_ARGS(clnt)) 127 128 DEFINE_RPC_CLNT_EVENT(free); 129 DEFINE_RPC_CLNT_EVENT(killall); 130 DEFINE_RPC_CLNT_EVENT(shutdown); 131 DEFINE_RPC_CLNT_EVENT(release); 132 DEFINE_RPC_CLNT_EVENT(replace_xprt); 133 DEFINE_RPC_CLNT_EVENT(replace_xprt_err); 134 135 TRACE_EVENT(rpc_clnt_new, 136 TP_PROTO( 137 const struct rpc_clnt *clnt, 138 const struct rpc_xprt *xprt, 139 const char *program, 140 const char *server 141 ), 142 143 TP_ARGS(clnt, xprt, program, server), 144 145 TP_STRUCT__entry( 146 __field(unsigned int, client_id) 147 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR]) 148 __string(port, xprt->address_strings[RPC_DISPLAY_PORT]) 149 __string(program, program) 150 __string(server, server) 151 ), 152 153 TP_fast_assign( 154 __entry->client_id = clnt->cl_clid; 155 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]); 156 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]); 157 __assign_str(program, program); 158 __assign_str(server, server); 159 ), 160 161 TP_printk("client=%u peer=[%s]:%s program=%s server=%s", 162 __entry->client_id, __get_str(addr), __get_str(port), 163 __get_str(program), __get_str(server)) 164 ); 165 166 TRACE_EVENT(rpc_clnt_new_err, 167 TP_PROTO( 168 const char *program, 169 const char *server, 170 int error 171 ), 172 173 TP_ARGS(program, server, error), 174 175 TP_STRUCT__entry( 176 __field(int, error) 177 __string(program, program) 178 __string(server, server) 179 ), 180 181 TP_fast_assign( 182 __entry->error = error; 183 __assign_str(program, program); 184 __assign_str(server, server); 185 ), 186 187 TP_printk("program=%s server=%s error=%d", 188 __get_str(program), __get_str(server), __entry->error) 189 ); 190 191 TRACE_EVENT(rpc_clnt_clone_err, 192 TP_PROTO( 193 const struct rpc_clnt *clnt, 194 int error 195 ), 196 197 TP_ARGS(clnt, error), 198 199 TP_STRUCT__entry( 200 __field(unsigned int, client_id) 201 __field(int, error) 202 ), 203 204 TP_fast_assign( 205 __entry->client_id = clnt->cl_clid; 206 __entry->error = error; 207 ), 208 209 TP_printk("client=%u error=%d", __entry->client_id, __entry->error) 210 ); 211 212 213 TRACE_DEFINE_ENUM(RPC_AUTH_OK); 214 TRACE_DEFINE_ENUM(RPC_AUTH_BADCRED); 215 TRACE_DEFINE_ENUM(RPC_AUTH_REJECTEDCRED); 216 TRACE_DEFINE_ENUM(RPC_AUTH_BADVERF); 217 TRACE_DEFINE_ENUM(RPC_AUTH_REJECTEDVERF); 218 TRACE_DEFINE_ENUM(RPC_AUTH_TOOWEAK); 219 TRACE_DEFINE_ENUM(RPCSEC_GSS_CREDPROBLEM); 220 TRACE_DEFINE_ENUM(RPCSEC_GSS_CTXPROBLEM); 221 222 #define rpc_show_auth_stat(status) \ 223 __print_symbolic(status, \ 224 { RPC_AUTH_OK, "AUTH_OK" }, \ 225 { RPC_AUTH_BADCRED, "BADCRED" }, \ 226 { RPC_AUTH_REJECTEDCRED, "REJECTEDCRED" }, \ 227 { RPC_AUTH_BADVERF, "BADVERF" }, \ 228 { RPC_AUTH_REJECTEDVERF, "REJECTEDVERF" }, \ 229 { RPC_AUTH_TOOWEAK, "TOOWEAK" }, \ 230 { RPCSEC_GSS_CREDPROBLEM, "GSS_CREDPROBLEM" }, \ 231 { RPCSEC_GSS_CTXPROBLEM, "GSS_CTXPROBLEM" }) \ 232 233 DECLARE_EVENT_CLASS(rpc_task_status, 234 235 TP_PROTO(const struct rpc_task *task), 236 237 TP_ARGS(task), 238 239 TP_STRUCT__entry( 240 __field(unsigned int, task_id) 241 __field(unsigned int, client_id) 242 __field(int, status) 243 ), 244 245 TP_fast_assign( 246 __entry->task_id = task->tk_pid; 247 __entry->client_id = task->tk_client->cl_clid; 248 __entry->status = task->tk_status; 249 ), 250 251 TP_printk("task:%u@%u status=%d", 252 __entry->task_id, __entry->client_id, 253 __entry->status) 254 ); 255 #define DEFINE_RPC_STATUS_EVENT(name) \ 256 DEFINE_EVENT(rpc_task_status, rpc_##name##_status, \ 257 TP_PROTO( \ 258 const struct rpc_task *task \ 259 ), \ 260 TP_ARGS(task)) 261 262 DEFINE_RPC_STATUS_EVENT(call); 263 DEFINE_RPC_STATUS_EVENT(connect); 264 DEFINE_RPC_STATUS_EVENT(timeout); 265 DEFINE_RPC_STATUS_EVENT(retry_refresh); 266 DEFINE_RPC_STATUS_EVENT(refresh); 267 268 TRACE_EVENT(rpc_request, 269 TP_PROTO(const struct rpc_task *task), 270 271 TP_ARGS(task), 272 273 TP_STRUCT__entry( 274 __field(unsigned int, task_id) 275 __field(unsigned int, client_id) 276 __field(int, version) 277 __field(bool, async) 278 __string(progname, task->tk_client->cl_program->name) 279 __string(procname, rpc_proc_name(task)) 280 ), 281 282 TP_fast_assign( 283 __entry->task_id = task->tk_pid; 284 __entry->client_id = task->tk_client->cl_clid; 285 __entry->version = task->tk_client->cl_vers; 286 __entry->async = RPC_IS_ASYNC(task); 287 __assign_str(progname, task->tk_client->cl_program->name); 288 __assign_str(procname, rpc_proc_name(task)); 289 ), 290 291 TP_printk("task:%u@%u %sv%d %s (%ssync)", 292 __entry->task_id, __entry->client_id, 293 __get_str(progname), __entry->version, 294 __get_str(procname), __entry->async ? "a": "" 295 ) 296 ); 297 298 #define rpc_show_task_flags(flags) \ 299 __print_flags(flags, "|", \ 300 { RPC_TASK_ASYNC, "ASYNC" }, \ 301 { RPC_TASK_SWAPPER, "SWAPPER" }, \ 302 { RPC_TASK_MOVEABLE, "MOVEABLE" }, \ 303 { RPC_TASK_NULLCREDS, "NULLCREDS" }, \ 304 { RPC_CALL_MAJORSEEN, "MAJORSEEN" }, \ 305 { RPC_TASK_ROOTCREDS, "ROOTCREDS" }, \ 306 { RPC_TASK_DYNAMIC, "DYNAMIC" }, \ 307 { RPC_TASK_NO_ROUND_ROBIN, "NO_ROUND_ROBIN" }, \ 308 { RPC_TASK_SOFT, "SOFT" }, \ 309 { RPC_TASK_SOFTCONN, "SOFTCONN" }, \ 310 { RPC_TASK_SENT, "SENT" }, \ 311 { RPC_TASK_TIMEOUT, "TIMEOUT" }, \ 312 { RPC_TASK_NOCONNECT, "NOCONNECT" }, \ 313 { RPC_TASK_NO_RETRANS_TIMEOUT, "NORTO" }, \ 314 { RPC_TASK_CRED_NOREF, "CRED_NOREF" }) 315 316 #define rpc_show_runstate(flags) \ 317 __print_flags(flags, "|", \ 318 { (1UL << RPC_TASK_RUNNING), "RUNNING" }, \ 319 { (1UL << RPC_TASK_QUEUED), "QUEUED" }, \ 320 { (1UL << RPC_TASK_ACTIVE), "ACTIVE" }, \ 321 { (1UL << RPC_TASK_NEED_XMIT), "NEED_XMIT" }, \ 322 { (1UL << RPC_TASK_NEED_RECV), "NEED_RECV" }, \ 323 { (1UL << RPC_TASK_MSG_PIN_WAIT), "MSG_PIN_WAIT" }, \ 324 { (1UL << RPC_TASK_SIGNALLED), "SIGNALLED" }) 325 326 DECLARE_EVENT_CLASS(rpc_task_running, 327 328 TP_PROTO(const struct rpc_task *task, const void *action), 329 330 TP_ARGS(task, action), 331 332 TP_STRUCT__entry( 333 __field(unsigned int, task_id) 334 __field(unsigned int, client_id) 335 __field(const void *, action) 336 __field(unsigned long, runstate) 337 __field(int, status) 338 __field(unsigned short, flags) 339 ), 340 341 TP_fast_assign( 342 __entry->client_id = task->tk_client ? 343 task->tk_client->cl_clid : -1; 344 __entry->task_id = task->tk_pid; 345 __entry->action = action; 346 __entry->runstate = task->tk_runstate; 347 __entry->status = task->tk_status; 348 __entry->flags = task->tk_flags; 349 ), 350 351 TP_printk("task:%u@%d flags=%s runstate=%s status=%d action=%ps", 352 __entry->task_id, __entry->client_id, 353 rpc_show_task_flags(__entry->flags), 354 rpc_show_runstate(__entry->runstate), 355 __entry->status, 356 __entry->action 357 ) 358 ); 359 #define DEFINE_RPC_RUNNING_EVENT(name) \ 360 DEFINE_EVENT(rpc_task_running, rpc_task_##name, \ 361 TP_PROTO( \ 362 const struct rpc_task *task, \ 363 const void *action \ 364 ), \ 365 TP_ARGS(task, action)) 366 367 DEFINE_RPC_RUNNING_EVENT(begin); 368 DEFINE_RPC_RUNNING_EVENT(run_action); 369 DEFINE_RPC_RUNNING_EVENT(sync_sleep); 370 DEFINE_RPC_RUNNING_EVENT(sync_wake); 371 DEFINE_RPC_RUNNING_EVENT(complete); 372 DEFINE_RPC_RUNNING_EVENT(timeout); 373 DEFINE_RPC_RUNNING_EVENT(signalled); 374 DEFINE_RPC_RUNNING_EVENT(end); 375 376 DECLARE_EVENT_CLASS(rpc_task_queued, 377 378 TP_PROTO(const struct rpc_task *task, const struct rpc_wait_queue *q), 379 380 TP_ARGS(task, q), 381 382 TP_STRUCT__entry( 383 __field(unsigned int, task_id) 384 __field(unsigned int, client_id) 385 __field(unsigned long, timeout) 386 __field(unsigned long, runstate) 387 __field(int, status) 388 __field(unsigned short, flags) 389 __string(q_name, rpc_qname(q)) 390 ), 391 392 TP_fast_assign( 393 __entry->client_id = task->tk_client ? 394 task->tk_client->cl_clid : -1; 395 __entry->task_id = task->tk_pid; 396 __entry->timeout = rpc_task_timeout(task); 397 __entry->runstate = task->tk_runstate; 398 __entry->status = task->tk_status; 399 __entry->flags = task->tk_flags; 400 __assign_str(q_name, rpc_qname(q)); 401 ), 402 403 TP_printk("task:%u@%d flags=%s runstate=%s status=%d timeout=%lu queue=%s", 404 __entry->task_id, __entry->client_id, 405 rpc_show_task_flags(__entry->flags), 406 rpc_show_runstate(__entry->runstate), 407 __entry->status, 408 __entry->timeout, 409 __get_str(q_name) 410 ) 411 ); 412 #define DEFINE_RPC_QUEUED_EVENT(name) \ 413 DEFINE_EVENT(rpc_task_queued, rpc_task_##name, \ 414 TP_PROTO( \ 415 const struct rpc_task *task, \ 416 const struct rpc_wait_queue *q \ 417 ), \ 418 TP_ARGS(task, q)) 419 420 DEFINE_RPC_QUEUED_EVENT(sleep); 421 DEFINE_RPC_QUEUED_EVENT(wakeup); 422 423 DECLARE_EVENT_CLASS(rpc_failure, 424 425 TP_PROTO(const struct rpc_task *task), 426 427 TP_ARGS(task), 428 429 TP_STRUCT__entry( 430 __field(unsigned int, task_id) 431 __field(unsigned int, client_id) 432 ), 433 434 TP_fast_assign( 435 __entry->task_id = task->tk_pid; 436 __entry->client_id = task->tk_client->cl_clid; 437 ), 438 439 TP_printk("task:%u@%u", 440 __entry->task_id, __entry->client_id) 441 ); 442 443 #define DEFINE_RPC_FAILURE(name) \ 444 DEFINE_EVENT(rpc_failure, rpc_bad_##name, \ 445 TP_PROTO( \ 446 const struct rpc_task *task \ 447 ), \ 448 TP_ARGS(task)) 449 450 DEFINE_RPC_FAILURE(callhdr); 451 DEFINE_RPC_FAILURE(verifier); 452 453 DECLARE_EVENT_CLASS(rpc_reply_event, 454 455 TP_PROTO( 456 const struct rpc_task *task 457 ), 458 459 TP_ARGS(task), 460 461 TP_STRUCT__entry( 462 __field(unsigned int, task_id) 463 __field(unsigned int, client_id) 464 __field(u32, xid) 465 __string(progname, task->tk_client->cl_program->name) 466 __field(u32, version) 467 __string(procname, rpc_proc_name(task)) 468 __string(servername, task->tk_xprt->servername) 469 ), 470 471 TP_fast_assign( 472 __entry->task_id = task->tk_pid; 473 __entry->client_id = task->tk_client->cl_clid; 474 __entry->xid = be32_to_cpu(task->tk_rqstp->rq_xid); 475 __assign_str(progname, task->tk_client->cl_program->name); 476 __entry->version = task->tk_client->cl_vers; 477 __assign_str(procname, rpc_proc_name(task)); 478 __assign_str(servername, task->tk_xprt->servername); 479 ), 480 481 TP_printk("task:%u@%d server=%s xid=0x%08x %sv%d %s", 482 __entry->task_id, __entry->client_id, __get_str(servername), 483 __entry->xid, __get_str(progname), __entry->version, 484 __get_str(procname)) 485 ) 486 487 #define DEFINE_RPC_REPLY_EVENT(name) \ 488 DEFINE_EVENT(rpc_reply_event, rpc__##name, \ 489 TP_PROTO( \ 490 const struct rpc_task *task \ 491 ), \ 492 TP_ARGS(task)) 493 494 DEFINE_RPC_REPLY_EVENT(prog_unavail); 495 DEFINE_RPC_REPLY_EVENT(prog_mismatch); 496 DEFINE_RPC_REPLY_EVENT(proc_unavail); 497 DEFINE_RPC_REPLY_EVENT(garbage_args); 498 DEFINE_RPC_REPLY_EVENT(unparsable); 499 DEFINE_RPC_REPLY_EVENT(mismatch); 500 DEFINE_RPC_REPLY_EVENT(stale_creds); 501 DEFINE_RPC_REPLY_EVENT(bad_creds); 502 DEFINE_RPC_REPLY_EVENT(auth_tooweak); 503 504 #define DEFINE_RPCB_ERROR_EVENT(name) \ 505 DEFINE_EVENT(rpc_reply_event, rpcb_##name##_err, \ 506 TP_PROTO( \ 507 const struct rpc_task *task \ 508 ), \ 509 TP_ARGS(task)) 510 511 DEFINE_RPCB_ERROR_EVENT(prog_unavail); 512 DEFINE_RPCB_ERROR_EVENT(timeout); 513 DEFINE_RPCB_ERROR_EVENT(bind_version); 514 DEFINE_RPCB_ERROR_EVENT(unreachable); 515 DEFINE_RPCB_ERROR_EVENT(unrecognized); 516 517 TRACE_EVENT(rpc_buf_alloc, 518 TP_PROTO( 519 const struct rpc_task *task, 520 int status 521 ), 522 523 TP_ARGS(task, status), 524 525 TP_STRUCT__entry( 526 __field(unsigned int, task_id) 527 __field(unsigned int, client_id) 528 __field(size_t, callsize) 529 __field(size_t, recvsize) 530 __field(int, status) 531 ), 532 533 TP_fast_assign( 534 __entry->task_id = task->tk_pid; 535 __entry->client_id = task->tk_client->cl_clid; 536 __entry->callsize = task->tk_rqstp->rq_callsize; 537 __entry->recvsize = task->tk_rqstp->rq_rcvsize; 538 __entry->status = status; 539 ), 540 541 TP_printk("task:%u@%u callsize=%zu recvsize=%zu status=%d", 542 __entry->task_id, __entry->client_id, 543 __entry->callsize, __entry->recvsize, __entry->status 544 ) 545 ); 546 547 TRACE_EVENT(rpc_call_rpcerror, 548 TP_PROTO( 549 const struct rpc_task *task, 550 int tk_status, 551 int rpc_status 552 ), 553 554 TP_ARGS(task, tk_status, rpc_status), 555 556 TP_STRUCT__entry( 557 __field(unsigned int, task_id) 558 __field(unsigned int, client_id) 559 __field(int, tk_status) 560 __field(int, rpc_status) 561 ), 562 563 TP_fast_assign( 564 __entry->client_id = task->tk_client->cl_clid; 565 __entry->task_id = task->tk_pid; 566 __entry->tk_status = tk_status; 567 __entry->rpc_status = rpc_status; 568 ), 569 570 TP_printk("task:%u@%u tk_status=%d rpc_status=%d", 571 __entry->task_id, __entry->client_id, 572 __entry->tk_status, __entry->rpc_status) 573 ); 574 575 TRACE_EVENT(rpc_stats_latency, 576 577 TP_PROTO( 578 const struct rpc_task *task, 579 ktime_t backlog, 580 ktime_t rtt, 581 ktime_t execute 582 ), 583 584 TP_ARGS(task, backlog, rtt, execute), 585 586 TP_STRUCT__entry( 587 __field(unsigned int, task_id) 588 __field(unsigned int, client_id) 589 __field(u32, xid) 590 __field(int, version) 591 __string(progname, task->tk_client->cl_program->name) 592 __string(procname, rpc_proc_name(task)) 593 __field(unsigned long, backlog) 594 __field(unsigned long, rtt) 595 __field(unsigned long, execute) 596 ), 597 598 TP_fast_assign( 599 __entry->client_id = task->tk_client->cl_clid; 600 __entry->task_id = task->tk_pid; 601 __entry->xid = be32_to_cpu(task->tk_rqstp->rq_xid); 602 __entry->version = task->tk_client->cl_vers; 603 __assign_str(progname, task->tk_client->cl_program->name); 604 __assign_str(procname, rpc_proc_name(task)); 605 __entry->backlog = ktime_to_us(backlog); 606 __entry->rtt = ktime_to_us(rtt); 607 __entry->execute = ktime_to_us(execute); 608 ), 609 610 TP_printk("task:%u@%d xid=0x%08x %sv%d %s backlog=%lu rtt=%lu execute=%lu", 611 __entry->task_id, __entry->client_id, __entry->xid, 612 __get_str(progname), __entry->version, __get_str(procname), 613 __entry->backlog, __entry->rtt, __entry->execute) 614 ); 615 616 TRACE_EVENT(rpc_xdr_overflow, 617 TP_PROTO( 618 const struct xdr_stream *xdr, 619 size_t requested 620 ), 621 622 TP_ARGS(xdr, requested), 623 624 TP_STRUCT__entry( 625 __field(unsigned int, task_id) 626 __field(unsigned int, client_id) 627 __field(int, version) 628 __field(size_t, requested) 629 __field(const void *, end) 630 __field(const void *, p) 631 __field(const void *, head_base) 632 __field(size_t, head_len) 633 __field(const void *, tail_base) 634 __field(size_t, tail_len) 635 __field(unsigned int, page_len) 636 __field(unsigned int, len) 637 __string(progname, xdr->rqst ? 638 xdr->rqst->rq_task->tk_client->cl_program->name : "unknown") 639 __string(procedure, xdr->rqst ? 640 xdr->rqst->rq_task->tk_msg.rpc_proc->p_name : "unknown") 641 ), 642 643 TP_fast_assign( 644 if (xdr->rqst) { 645 const struct rpc_task *task = xdr->rqst->rq_task; 646 647 __entry->task_id = task->tk_pid; 648 __entry->client_id = task->tk_client->cl_clid; 649 __assign_str(progname, 650 task->tk_client->cl_program->name); 651 __entry->version = task->tk_client->cl_vers; 652 __assign_str(procedure, task->tk_msg.rpc_proc->p_name); 653 } else { 654 __entry->task_id = 0; 655 __entry->client_id = 0; 656 __assign_str(progname, "unknown"); 657 __entry->version = 0; 658 __assign_str(procedure, "unknown"); 659 } 660 __entry->requested = requested; 661 __entry->end = xdr->end; 662 __entry->p = xdr->p; 663 __entry->head_base = xdr->buf->head[0].iov_base, 664 __entry->head_len = xdr->buf->head[0].iov_len, 665 __entry->page_len = xdr->buf->page_len, 666 __entry->tail_base = xdr->buf->tail[0].iov_base, 667 __entry->tail_len = xdr->buf->tail[0].iov_len, 668 __entry->len = xdr->buf->len; 669 ), 670 671 TP_printk( 672 "task:%u@%u %sv%d %s requested=%zu p=%p end=%p xdr=[%p,%zu]/%u/[%p,%zu]/%u\n", 673 __entry->task_id, __entry->client_id, 674 __get_str(progname), __entry->version, __get_str(procedure), 675 __entry->requested, __entry->p, __entry->end, 676 __entry->head_base, __entry->head_len, 677 __entry->page_len, 678 __entry->tail_base, __entry->tail_len, 679 __entry->len 680 ) 681 ); 682 683 TRACE_EVENT(rpc_xdr_alignment, 684 TP_PROTO( 685 const struct xdr_stream *xdr, 686 size_t offset, 687 unsigned int copied 688 ), 689 690 TP_ARGS(xdr, offset, copied), 691 692 TP_STRUCT__entry( 693 __field(unsigned int, task_id) 694 __field(unsigned int, client_id) 695 __field(int, version) 696 __field(size_t, offset) 697 __field(unsigned int, copied) 698 __field(const void *, head_base) 699 __field(size_t, head_len) 700 __field(const void *, tail_base) 701 __field(size_t, tail_len) 702 __field(unsigned int, page_len) 703 __field(unsigned int, len) 704 __string(progname, 705 xdr->rqst->rq_task->tk_client->cl_program->name) 706 __string(procedure, 707 xdr->rqst->rq_task->tk_msg.rpc_proc->p_name) 708 ), 709 710 TP_fast_assign( 711 const struct rpc_task *task = xdr->rqst->rq_task; 712 713 __entry->task_id = task->tk_pid; 714 __entry->client_id = task->tk_client->cl_clid; 715 __assign_str(progname, 716 task->tk_client->cl_program->name); 717 __entry->version = task->tk_client->cl_vers; 718 __assign_str(procedure, task->tk_msg.rpc_proc->p_name); 719 720 __entry->offset = offset; 721 __entry->copied = copied; 722 __entry->head_base = xdr->buf->head[0].iov_base, 723 __entry->head_len = xdr->buf->head[0].iov_len, 724 __entry->page_len = xdr->buf->page_len, 725 __entry->tail_base = xdr->buf->tail[0].iov_base, 726 __entry->tail_len = xdr->buf->tail[0].iov_len, 727 __entry->len = xdr->buf->len; 728 ), 729 730 TP_printk( 731 "task:%u@%u %sv%d %s offset=%zu copied=%u xdr=[%p,%zu]/%u/[%p,%zu]/%u\n", 732 __entry->task_id, __entry->client_id, 733 __get_str(progname), __entry->version, __get_str(procedure), 734 __entry->offset, __entry->copied, 735 __entry->head_base, __entry->head_len, 736 __entry->page_len, 737 __entry->tail_base, __entry->tail_len, 738 __entry->len 739 ) 740 ); 741 742 /* 743 * First define the enums in the below macros to be exported to userspace 744 * via TRACE_DEFINE_ENUM(). 745 */ 746 #undef EM 747 #undef EMe 748 #define EM(a, b) TRACE_DEFINE_ENUM(a); 749 #define EMe(a, b) TRACE_DEFINE_ENUM(a); 750 751 #define RPC_SHOW_SOCKET \ 752 EM( SS_FREE, "FREE" ) \ 753 EM( SS_UNCONNECTED, "UNCONNECTED" ) \ 754 EM( SS_CONNECTING, "CONNECTING" ) \ 755 EM( SS_CONNECTED, "CONNECTED" ) \ 756 EMe( SS_DISCONNECTING, "DISCONNECTING" ) 757 758 #define rpc_show_socket_state(state) \ 759 __print_symbolic(state, RPC_SHOW_SOCKET) 760 761 RPC_SHOW_SOCKET 762 763 #define RPC_SHOW_SOCK \ 764 EM( TCP_ESTABLISHED, "ESTABLISHED" ) \ 765 EM( TCP_SYN_SENT, "SYN_SENT" ) \ 766 EM( TCP_SYN_RECV, "SYN_RECV" ) \ 767 EM( TCP_FIN_WAIT1, "FIN_WAIT1" ) \ 768 EM( TCP_FIN_WAIT2, "FIN_WAIT2" ) \ 769 EM( TCP_TIME_WAIT, "TIME_WAIT" ) \ 770 EM( TCP_CLOSE, "CLOSE" ) \ 771 EM( TCP_CLOSE_WAIT, "CLOSE_WAIT" ) \ 772 EM( TCP_LAST_ACK, "LAST_ACK" ) \ 773 EM( TCP_LISTEN, "LISTEN" ) \ 774 EMe( TCP_CLOSING, "CLOSING" ) 775 776 #define rpc_show_sock_state(state) \ 777 __print_symbolic(state, RPC_SHOW_SOCK) 778 779 RPC_SHOW_SOCK 780 781 /* 782 * Now redefine the EM() and EMe() macros to map the enums to the strings 783 * that will be printed in the output. 784 */ 785 #undef EM 786 #undef EMe 787 #define EM(a, b) {a, b}, 788 #define EMe(a, b) {a, b} 789 790 DECLARE_EVENT_CLASS(xs_socket_event, 791 792 TP_PROTO( 793 struct rpc_xprt *xprt, 794 struct socket *socket 795 ), 796 797 TP_ARGS(xprt, socket), 798 799 TP_STRUCT__entry( 800 __field(unsigned int, socket_state) 801 __field(unsigned int, sock_state) 802 __field(unsigned long long, ino) 803 __string(dstaddr, 804 xprt->address_strings[RPC_DISPLAY_ADDR]) 805 __string(dstport, 806 xprt->address_strings[RPC_DISPLAY_PORT]) 807 ), 808 809 TP_fast_assign( 810 struct inode *inode = SOCK_INODE(socket); 811 __entry->socket_state = socket->state; 812 __entry->sock_state = socket->sk->sk_state; 813 __entry->ino = (unsigned long long)inode->i_ino; 814 __assign_str(dstaddr, 815 xprt->address_strings[RPC_DISPLAY_ADDR]); 816 __assign_str(dstport, 817 xprt->address_strings[RPC_DISPLAY_PORT]); 818 ), 819 820 TP_printk( 821 "socket:[%llu] dstaddr=%s/%s " 822 "state=%u (%s) sk_state=%u (%s)", 823 __entry->ino, __get_str(dstaddr), __get_str(dstport), 824 __entry->socket_state, 825 rpc_show_socket_state(__entry->socket_state), 826 __entry->sock_state, 827 rpc_show_sock_state(__entry->sock_state) 828 ) 829 ); 830 #define DEFINE_RPC_SOCKET_EVENT(name) \ 831 DEFINE_EVENT(xs_socket_event, name, \ 832 TP_PROTO( \ 833 struct rpc_xprt *xprt, \ 834 struct socket *socket \ 835 ), \ 836 TP_ARGS(xprt, socket)) 837 838 DECLARE_EVENT_CLASS(xs_socket_event_done, 839 840 TP_PROTO( 841 struct rpc_xprt *xprt, 842 struct socket *socket, 843 int error 844 ), 845 846 TP_ARGS(xprt, socket, error), 847 848 TP_STRUCT__entry( 849 __field(int, error) 850 __field(unsigned int, socket_state) 851 __field(unsigned int, sock_state) 852 __field(unsigned long long, ino) 853 __string(dstaddr, 854 xprt->address_strings[RPC_DISPLAY_ADDR]) 855 __string(dstport, 856 xprt->address_strings[RPC_DISPLAY_PORT]) 857 ), 858 859 TP_fast_assign( 860 struct inode *inode = SOCK_INODE(socket); 861 __entry->socket_state = socket->state; 862 __entry->sock_state = socket->sk->sk_state; 863 __entry->ino = (unsigned long long)inode->i_ino; 864 __entry->error = error; 865 __assign_str(dstaddr, 866 xprt->address_strings[RPC_DISPLAY_ADDR]); 867 __assign_str(dstport, 868 xprt->address_strings[RPC_DISPLAY_PORT]); 869 ), 870 871 TP_printk( 872 "error=%d socket:[%llu] dstaddr=%s/%s " 873 "state=%u (%s) sk_state=%u (%s)", 874 __entry->error, 875 __entry->ino, __get_str(dstaddr), __get_str(dstport), 876 __entry->socket_state, 877 rpc_show_socket_state(__entry->socket_state), 878 __entry->sock_state, 879 rpc_show_sock_state(__entry->sock_state) 880 ) 881 ); 882 #define DEFINE_RPC_SOCKET_EVENT_DONE(name) \ 883 DEFINE_EVENT(xs_socket_event_done, name, \ 884 TP_PROTO( \ 885 struct rpc_xprt *xprt, \ 886 struct socket *socket, \ 887 int error \ 888 ), \ 889 TP_ARGS(xprt, socket, error)) 890 891 DEFINE_RPC_SOCKET_EVENT(rpc_socket_state_change); 892 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_connect); 893 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_error); 894 DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_reset_connection); 895 DEFINE_RPC_SOCKET_EVENT(rpc_socket_close); 896 DEFINE_RPC_SOCKET_EVENT(rpc_socket_shutdown); 897 898 TRACE_EVENT(rpc_socket_nospace, 899 TP_PROTO( 900 const struct rpc_rqst *rqst, 901 const struct sock_xprt *transport 902 ), 903 904 TP_ARGS(rqst, transport), 905 906 TP_STRUCT__entry( 907 __field(unsigned int, task_id) 908 __field(unsigned int, client_id) 909 __field(unsigned int, total) 910 __field(unsigned int, remaining) 911 ), 912 913 TP_fast_assign( 914 __entry->task_id = rqst->rq_task->tk_pid; 915 __entry->client_id = rqst->rq_task->tk_client->cl_clid; 916 __entry->total = rqst->rq_slen; 917 __entry->remaining = rqst->rq_slen - transport->xmit.offset; 918 ), 919 920 TP_printk("task:%u@%u total=%u remaining=%u", 921 __entry->task_id, __entry->client_id, 922 __entry->total, __entry->remaining 923 ) 924 ); 925 926 #define rpc_show_xprt_state(x) \ 927 __print_flags(x, "|", \ 928 { BIT(XPRT_LOCKED), "LOCKED" }, \ 929 { BIT(XPRT_CONNECTED), "CONNECTED" }, \ 930 { BIT(XPRT_CONNECTING), "CONNECTING" }, \ 931 { BIT(XPRT_CLOSE_WAIT), "CLOSE_WAIT" }, \ 932 { BIT(XPRT_BOUND), "BOUND" }, \ 933 { BIT(XPRT_BINDING), "BINDING" }, \ 934 { BIT(XPRT_CLOSING), "CLOSING" }, \ 935 { BIT(XPRT_OFFLINE), "OFFLINE" }, \ 936 { BIT(XPRT_REMOVE), "REMOVE" }, \ 937 { BIT(XPRT_CONGESTED), "CONGESTED" }, \ 938 { BIT(XPRT_CWND_WAIT), "CWND_WAIT" }, \ 939 { BIT(XPRT_WRITE_SPACE), "WRITE_SPACE" }, \ 940 { BIT(XPRT_SND_IS_COOKIE), "SND_IS_COOKIE" }) 941 942 DECLARE_EVENT_CLASS(rpc_xprt_lifetime_class, 943 TP_PROTO( 944 const struct rpc_xprt *xprt 945 ), 946 947 TP_ARGS(xprt), 948 949 TP_STRUCT__entry( 950 __field(unsigned long, state) 951 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR]) 952 __string(port, xprt->address_strings[RPC_DISPLAY_PORT]) 953 ), 954 955 TP_fast_assign( 956 __entry->state = xprt->state; 957 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]); 958 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]); 959 ), 960 961 TP_printk("peer=[%s]:%s state=%s", 962 __get_str(addr), __get_str(port), 963 rpc_show_xprt_state(__entry->state)) 964 ); 965 966 #define DEFINE_RPC_XPRT_LIFETIME_EVENT(name) \ 967 DEFINE_EVENT(rpc_xprt_lifetime_class, \ 968 xprt_##name, \ 969 TP_PROTO( \ 970 const struct rpc_xprt *xprt \ 971 ), \ 972 TP_ARGS(xprt)) 973 974 DEFINE_RPC_XPRT_LIFETIME_EVENT(create); 975 DEFINE_RPC_XPRT_LIFETIME_EVENT(connect); 976 DEFINE_RPC_XPRT_LIFETIME_EVENT(disconnect_auto); 977 DEFINE_RPC_XPRT_LIFETIME_EVENT(disconnect_done); 978 DEFINE_RPC_XPRT_LIFETIME_EVENT(disconnect_force); 979 DEFINE_RPC_XPRT_LIFETIME_EVENT(destroy); 980 981 DECLARE_EVENT_CLASS(rpc_xprt_event, 982 TP_PROTO( 983 const struct rpc_xprt *xprt, 984 __be32 xid, 985 int status 986 ), 987 988 TP_ARGS(xprt, xid, status), 989 990 TP_STRUCT__entry( 991 __field(u32, xid) 992 __field(int, status) 993 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR]) 994 __string(port, xprt->address_strings[RPC_DISPLAY_PORT]) 995 ), 996 997 TP_fast_assign( 998 __entry->xid = be32_to_cpu(xid); 999 __entry->status = status; 1000 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]); 1001 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]); 1002 ), 1003 1004 TP_printk("peer=[%s]:%s xid=0x%08x status=%d", __get_str(addr), 1005 __get_str(port), __entry->xid, 1006 __entry->status) 1007 ); 1008 #define DEFINE_RPC_XPRT_EVENT(name) \ 1009 DEFINE_EVENT(rpc_xprt_event, xprt_##name, \ 1010 TP_PROTO( \ 1011 const struct rpc_xprt *xprt, \ 1012 __be32 xid, \ 1013 int status \ 1014 ), \ 1015 TP_ARGS(xprt, xid, status)) 1016 1017 DEFINE_RPC_XPRT_EVENT(timer); 1018 DEFINE_RPC_XPRT_EVENT(lookup_rqst); 1019 1020 TRACE_EVENT(xprt_transmit, 1021 TP_PROTO( 1022 const struct rpc_rqst *rqst, 1023 int status 1024 ), 1025 1026 TP_ARGS(rqst, status), 1027 1028 TP_STRUCT__entry( 1029 __field(unsigned int, task_id) 1030 __field(unsigned int, client_id) 1031 __field(u32, xid) 1032 __field(u32, seqno) 1033 __field(int, status) 1034 ), 1035 1036 TP_fast_assign( 1037 __entry->task_id = rqst->rq_task->tk_pid; 1038 __entry->client_id = rqst->rq_task->tk_client ? 1039 rqst->rq_task->tk_client->cl_clid : -1; 1040 __entry->xid = be32_to_cpu(rqst->rq_xid); 1041 __entry->seqno = rqst->rq_seqno; 1042 __entry->status = status; 1043 ), 1044 1045 TP_printk( 1046 "task:%u@%u xid=0x%08x seqno=%u status=%d", 1047 __entry->task_id, __entry->client_id, __entry->xid, 1048 __entry->seqno, __entry->status) 1049 ); 1050 1051 TRACE_EVENT(xprt_retransmit, 1052 TP_PROTO( 1053 const struct rpc_rqst *rqst 1054 ), 1055 1056 TP_ARGS(rqst), 1057 1058 TP_STRUCT__entry( 1059 __field(unsigned int, task_id) 1060 __field(unsigned int, client_id) 1061 __field(u32, xid) 1062 __field(int, ntrans) 1063 __field(int, version) 1064 __field(unsigned long, timeout) 1065 __string(progname, 1066 rqst->rq_task->tk_client->cl_program->name) 1067 __string(procname, rpc_proc_name(rqst->rq_task)) 1068 ), 1069 1070 TP_fast_assign( 1071 struct rpc_task *task = rqst->rq_task; 1072 1073 __entry->task_id = task->tk_pid; 1074 __entry->client_id = task->tk_client ? 1075 task->tk_client->cl_clid : -1; 1076 __entry->xid = be32_to_cpu(rqst->rq_xid); 1077 __entry->ntrans = rqst->rq_ntrans; 1078 __entry->timeout = task->tk_timeout; 1079 __assign_str(progname, 1080 task->tk_client->cl_program->name); 1081 __entry->version = task->tk_client->cl_vers; 1082 __assign_str(procname, rpc_proc_name(task)); 1083 ), 1084 1085 TP_printk( 1086 "task:%u@%u xid=0x%08x %sv%d %s ntrans=%d timeout=%lu", 1087 __entry->task_id, __entry->client_id, __entry->xid, 1088 __get_str(progname), __entry->version, __get_str(procname), 1089 __entry->ntrans, __entry->timeout 1090 ) 1091 ); 1092 1093 TRACE_EVENT(xprt_ping, 1094 TP_PROTO(const struct rpc_xprt *xprt, int status), 1095 1096 TP_ARGS(xprt, status), 1097 1098 TP_STRUCT__entry( 1099 __field(int, status) 1100 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR]) 1101 __string(port, xprt->address_strings[RPC_DISPLAY_PORT]) 1102 ), 1103 1104 TP_fast_assign( 1105 __entry->status = status; 1106 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]); 1107 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]); 1108 ), 1109 1110 TP_printk("peer=[%s]:%s status=%d", 1111 __get_str(addr), __get_str(port), __entry->status) 1112 ); 1113 1114 DECLARE_EVENT_CLASS(xprt_writelock_event, 1115 TP_PROTO( 1116 const struct rpc_xprt *xprt, const struct rpc_task *task 1117 ), 1118 1119 TP_ARGS(xprt, task), 1120 1121 TP_STRUCT__entry( 1122 __field(unsigned int, task_id) 1123 __field(unsigned int, client_id) 1124 __field(unsigned int, snd_task_id) 1125 ), 1126 1127 TP_fast_assign( 1128 if (task) { 1129 __entry->task_id = task->tk_pid; 1130 __entry->client_id = task->tk_client ? 1131 task->tk_client->cl_clid : -1; 1132 } else { 1133 __entry->task_id = -1; 1134 __entry->client_id = -1; 1135 } 1136 if (xprt->snd_task && 1137 !test_bit(XPRT_SND_IS_COOKIE, &xprt->state)) 1138 __entry->snd_task_id = xprt->snd_task->tk_pid; 1139 else 1140 __entry->snd_task_id = -1; 1141 ), 1142 1143 TP_printk("task:%u@%u snd_task:%u", 1144 __entry->task_id, __entry->client_id, 1145 __entry->snd_task_id) 1146 ); 1147 1148 #define DEFINE_WRITELOCK_EVENT(name) \ 1149 DEFINE_EVENT(xprt_writelock_event, xprt_##name, \ 1150 TP_PROTO( \ 1151 const struct rpc_xprt *xprt, \ 1152 const struct rpc_task *task \ 1153 ), \ 1154 TP_ARGS(xprt, task)) 1155 1156 DEFINE_WRITELOCK_EVENT(reserve_xprt); 1157 DEFINE_WRITELOCK_EVENT(release_xprt); 1158 1159 DECLARE_EVENT_CLASS(xprt_cong_event, 1160 TP_PROTO( 1161 const struct rpc_xprt *xprt, const struct rpc_task *task 1162 ), 1163 1164 TP_ARGS(xprt, task), 1165 1166 TP_STRUCT__entry( 1167 __field(unsigned int, task_id) 1168 __field(unsigned int, client_id) 1169 __field(unsigned int, snd_task_id) 1170 __field(unsigned long, cong) 1171 __field(unsigned long, cwnd) 1172 __field(bool, wait) 1173 ), 1174 1175 TP_fast_assign( 1176 if (task) { 1177 __entry->task_id = task->tk_pid; 1178 __entry->client_id = task->tk_client ? 1179 task->tk_client->cl_clid : -1; 1180 } else { 1181 __entry->task_id = -1; 1182 __entry->client_id = -1; 1183 } 1184 if (xprt->snd_task && 1185 !test_bit(XPRT_SND_IS_COOKIE, &xprt->state)) 1186 __entry->snd_task_id = xprt->snd_task->tk_pid; 1187 else 1188 __entry->snd_task_id = -1; 1189 1190 __entry->cong = xprt->cong; 1191 __entry->cwnd = xprt->cwnd; 1192 __entry->wait = test_bit(XPRT_CWND_WAIT, &xprt->state); 1193 ), 1194 1195 TP_printk("task:%u@%u snd_task:%u cong=%lu cwnd=%lu%s", 1196 __entry->task_id, __entry->client_id, 1197 __entry->snd_task_id, __entry->cong, __entry->cwnd, 1198 __entry->wait ? " (wait)" : "") 1199 ); 1200 1201 #define DEFINE_CONG_EVENT(name) \ 1202 DEFINE_EVENT(xprt_cong_event, xprt_##name, \ 1203 TP_PROTO( \ 1204 const struct rpc_xprt *xprt, \ 1205 const struct rpc_task *task \ 1206 ), \ 1207 TP_ARGS(xprt, task)) 1208 1209 DEFINE_CONG_EVENT(reserve_cong); 1210 DEFINE_CONG_EVENT(release_cong); 1211 DEFINE_CONG_EVENT(get_cong); 1212 DEFINE_CONG_EVENT(put_cong); 1213 1214 TRACE_EVENT(xprt_reserve, 1215 TP_PROTO( 1216 const struct rpc_rqst *rqst 1217 ), 1218 1219 TP_ARGS(rqst), 1220 1221 TP_STRUCT__entry( 1222 __field(unsigned int, task_id) 1223 __field(unsigned int, client_id) 1224 __field(u32, xid) 1225 ), 1226 1227 TP_fast_assign( 1228 __entry->task_id = rqst->rq_task->tk_pid; 1229 __entry->client_id = rqst->rq_task->tk_client->cl_clid; 1230 __entry->xid = be32_to_cpu(rqst->rq_xid); 1231 ), 1232 1233 TP_printk("task:%u@%u xid=0x%08x", 1234 __entry->task_id, __entry->client_id, __entry->xid 1235 ) 1236 ); 1237 1238 TRACE_EVENT(xs_stream_read_data, 1239 TP_PROTO(struct rpc_xprt *xprt, ssize_t err, size_t total), 1240 1241 TP_ARGS(xprt, err, total), 1242 1243 TP_STRUCT__entry( 1244 __field(ssize_t, err) 1245 __field(size_t, total) 1246 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] : 1247 "(null)") 1248 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] : 1249 "(null)") 1250 ), 1251 1252 TP_fast_assign( 1253 __entry->err = err; 1254 __entry->total = total; 1255 __assign_str(addr, xprt ? 1256 xprt->address_strings[RPC_DISPLAY_ADDR] : "(null)"); 1257 __assign_str(port, xprt ? 1258 xprt->address_strings[RPC_DISPLAY_PORT] : "(null)"); 1259 ), 1260 1261 TP_printk("peer=[%s]:%s err=%zd total=%zu", __get_str(addr), 1262 __get_str(port), __entry->err, __entry->total) 1263 ); 1264 1265 TRACE_EVENT(xs_stream_read_request, 1266 TP_PROTO(struct sock_xprt *xs), 1267 1268 TP_ARGS(xs), 1269 1270 TP_STRUCT__entry( 1271 __string(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR]) 1272 __string(port, xs->xprt.address_strings[RPC_DISPLAY_PORT]) 1273 __field(u32, xid) 1274 __field(unsigned long, copied) 1275 __field(unsigned int, reclen) 1276 __field(unsigned int, offset) 1277 ), 1278 1279 TP_fast_assign( 1280 __assign_str(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR]); 1281 __assign_str(port, xs->xprt.address_strings[RPC_DISPLAY_PORT]); 1282 __entry->xid = be32_to_cpu(xs->recv.xid); 1283 __entry->copied = xs->recv.copied; 1284 __entry->reclen = xs->recv.len; 1285 __entry->offset = xs->recv.offset; 1286 ), 1287 1288 TP_printk("peer=[%s]:%s xid=0x%08x copied=%lu reclen=%u offset=%u", 1289 __get_str(addr), __get_str(port), __entry->xid, 1290 __entry->copied, __entry->reclen, __entry->offset) 1291 ); 1292 1293 TRACE_EVENT(rpcb_getport, 1294 TP_PROTO( 1295 const struct rpc_clnt *clnt, 1296 const struct rpc_task *task, 1297 unsigned int bind_version 1298 ), 1299 1300 TP_ARGS(clnt, task, bind_version), 1301 1302 TP_STRUCT__entry( 1303 __field(unsigned int, task_id) 1304 __field(unsigned int, client_id) 1305 __field(unsigned int, program) 1306 __field(unsigned int, version) 1307 __field(int, protocol) 1308 __field(unsigned int, bind_version) 1309 __string(servername, task->tk_xprt->servername) 1310 ), 1311 1312 TP_fast_assign( 1313 __entry->task_id = task->tk_pid; 1314 __entry->client_id = clnt->cl_clid; 1315 __entry->program = clnt->cl_prog; 1316 __entry->version = clnt->cl_vers; 1317 __entry->protocol = task->tk_xprt->prot; 1318 __entry->bind_version = bind_version; 1319 __assign_str(servername, task->tk_xprt->servername); 1320 ), 1321 1322 TP_printk("task:%u@%u server=%s program=%u version=%u protocol=%d bind_version=%u", 1323 __entry->task_id, __entry->client_id, __get_str(servername), 1324 __entry->program, __entry->version, __entry->protocol, 1325 __entry->bind_version 1326 ) 1327 ); 1328 1329 TRACE_EVENT(rpcb_setport, 1330 TP_PROTO( 1331 const struct rpc_task *task, 1332 int status, 1333 unsigned short port 1334 ), 1335 1336 TP_ARGS(task, status, port), 1337 1338 TP_STRUCT__entry( 1339 __field(unsigned int, task_id) 1340 __field(unsigned int, client_id) 1341 __field(int, status) 1342 __field(unsigned short, port) 1343 ), 1344 1345 TP_fast_assign( 1346 __entry->task_id = task->tk_pid; 1347 __entry->client_id = task->tk_client->cl_clid; 1348 __entry->status = status; 1349 __entry->port = port; 1350 ), 1351 1352 TP_printk("task:%u@%u status=%d port=%u", 1353 __entry->task_id, __entry->client_id, 1354 __entry->status, __entry->port 1355 ) 1356 ); 1357 1358 TRACE_EVENT(pmap_register, 1359 TP_PROTO( 1360 u32 program, 1361 u32 version, 1362 int protocol, 1363 unsigned short port 1364 ), 1365 1366 TP_ARGS(program, version, protocol, port), 1367 1368 TP_STRUCT__entry( 1369 __field(unsigned int, program) 1370 __field(unsigned int, version) 1371 __field(int, protocol) 1372 __field(unsigned int, port) 1373 ), 1374 1375 TP_fast_assign( 1376 __entry->program = program; 1377 __entry->version = version; 1378 __entry->protocol = protocol; 1379 __entry->port = port; 1380 ), 1381 1382 TP_printk("program=%u version=%u protocol=%d port=%u", 1383 __entry->program, __entry->version, 1384 __entry->protocol, __entry->port 1385 ) 1386 ); 1387 1388 TRACE_EVENT(rpcb_register, 1389 TP_PROTO( 1390 u32 program, 1391 u32 version, 1392 const char *addr, 1393 const char *netid 1394 ), 1395 1396 TP_ARGS(program, version, addr, netid), 1397 1398 TP_STRUCT__entry( 1399 __field(unsigned int, program) 1400 __field(unsigned int, version) 1401 __string(addr, addr) 1402 __string(netid, netid) 1403 ), 1404 1405 TP_fast_assign( 1406 __entry->program = program; 1407 __entry->version = version; 1408 __assign_str(addr, addr); 1409 __assign_str(netid, netid); 1410 ), 1411 1412 TP_printk("program=%u version=%u addr=%s netid=%s", 1413 __entry->program, __entry->version, 1414 __get_str(addr), __get_str(netid) 1415 ) 1416 ); 1417 1418 TRACE_EVENT(rpcb_unregister, 1419 TP_PROTO( 1420 u32 program, 1421 u32 version, 1422 const char *netid 1423 ), 1424 1425 TP_ARGS(program, version, netid), 1426 1427 TP_STRUCT__entry( 1428 __field(unsigned int, program) 1429 __field(unsigned int, version) 1430 __string(netid, netid) 1431 ), 1432 1433 TP_fast_assign( 1434 __entry->program = program; 1435 __entry->version = version; 1436 __assign_str(netid, netid); 1437 ), 1438 1439 TP_printk("program=%u version=%u netid=%s", 1440 __entry->program, __entry->version, __get_str(netid) 1441 ) 1442 ); 1443 1444 /* Record an xdr_buf containing a fully-formed RPC message */ 1445 DECLARE_EVENT_CLASS(svc_xdr_msg_class, 1446 TP_PROTO( 1447 const struct xdr_buf *xdr 1448 ), 1449 1450 TP_ARGS(xdr), 1451 1452 TP_STRUCT__entry( 1453 __field(u32, xid) 1454 __field(const void *, head_base) 1455 __field(size_t, head_len) 1456 __field(const void *, tail_base) 1457 __field(size_t, tail_len) 1458 __field(unsigned int, page_len) 1459 __field(unsigned int, msg_len) 1460 ), 1461 1462 TP_fast_assign( 1463 __be32 *p = (__be32 *)xdr->head[0].iov_base; 1464 1465 __entry->xid = be32_to_cpu(*p); 1466 __entry->head_base = p; 1467 __entry->head_len = xdr->head[0].iov_len; 1468 __entry->tail_base = xdr->tail[0].iov_base; 1469 __entry->tail_len = xdr->tail[0].iov_len; 1470 __entry->page_len = xdr->page_len; 1471 __entry->msg_len = xdr->len; 1472 ), 1473 1474 TP_printk("xid=0x%08x head=[%p,%zu] page=%u tail=[%p,%zu] len=%u", 1475 __entry->xid, 1476 __entry->head_base, __entry->head_len, __entry->page_len, 1477 __entry->tail_base, __entry->tail_len, __entry->msg_len 1478 ) 1479 ); 1480 1481 #define DEFINE_SVCXDRMSG_EVENT(name) \ 1482 DEFINE_EVENT(svc_xdr_msg_class, \ 1483 svc_xdr_##name, \ 1484 TP_PROTO( \ 1485 const struct xdr_buf *xdr \ 1486 ), \ 1487 TP_ARGS(xdr)) 1488 1489 DEFINE_SVCXDRMSG_EVENT(recvfrom); 1490 1491 /* Record an xdr_buf containing arbitrary data, tagged with an XID */ 1492 DECLARE_EVENT_CLASS(svc_xdr_buf_class, 1493 TP_PROTO( 1494 __be32 xid, 1495 const struct xdr_buf *xdr 1496 ), 1497 1498 TP_ARGS(xid, xdr), 1499 1500 TP_STRUCT__entry( 1501 __field(u32, xid) 1502 __field(const void *, head_base) 1503 __field(size_t, head_len) 1504 __field(const void *, tail_base) 1505 __field(size_t, tail_len) 1506 __field(unsigned int, page_len) 1507 __field(unsigned int, msg_len) 1508 ), 1509 1510 TP_fast_assign( 1511 __entry->xid = be32_to_cpu(xid); 1512 __entry->head_base = xdr->head[0].iov_base; 1513 __entry->head_len = xdr->head[0].iov_len; 1514 __entry->tail_base = xdr->tail[0].iov_base; 1515 __entry->tail_len = xdr->tail[0].iov_len; 1516 __entry->page_len = xdr->page_len; 1517 __entry->msg_len = xdr->len; 1518 ), 1519 1520 TP_printk("xid=0x%08x head=[%p,%zu] page=%u tail=[%p,%zu] len=%u", 1521 __entry->xid, 1522 __entry->head_base, __entry->head_len, __entry->page_len, 1523 __entry->tail_base, __entry->tail_len, __entry->msg_len 1524 ) 1525 ); 1526 1527 #define DEFINE_SVCXDRBUF_EVENT(name) \ 1528 DEFINE_EVENT(svc_xdr_buf_class, \ 1529 svc_xdr_##name, \ 1530 TP_PROTO( \ 1531 __be32 xid, \ 1532 const struct xdr_buf *xdr \ 1533 ), \ 1534 TP_ARGS(xid, xdr)) 1535 1536 DEFINE_SVCXDRBUF_EVENT(sendto); 1537 1538 /* 1539 * from include/linux/sunrpc/svc.h 1540 */ 1541 #define SVC_RQST_FLAG_LIST \ 1542 svc_rqst_flag(SECURE) \ 1543 svc_rqst_flag(LOCAL) \ 1544 svc_rqst_flag(USEDEFERRAL) \ 1545 svc_rqst_flag(DROPME) \ 1546 svc_rqst_flag(SPLICE_OK) \ 1547 svc_rqst_flag(VICTIM) \ 1548 svc_rqst_flag(BUSY) \ 1549 svc_rqst_flag_end(DATA) 1550 1551 #undef svc_rqst_flag 1552 #undef svc_rqst_flag_end 1553 #define svc_rqst_flag(x) TRACE_DEFINE_ENUM(RQ_##x); 1554 #define svc_rqst_flag_end(x) TRACE_DEFINE_ENUM(RQ_##x); 1555 1556 SVC_RQST_FLAG_LIST 1557 1558 #undef svc_rqst_flag 1559 #undef svc_rqst_flag_end 1560 #define svc_rqst_flag(x) { BIT(RQ_##x), #x }, 1561 #define svc_rqst_flag_end(x) { BIT(RQ_##x), #x } 1562 1563 #define show_rqstp_flags(flags) \ 1564 __print_flags(flags, "|", SVC_RQST_FLAG_LIST) 1565 1566 TRACE_DEFINE_ENUM(SVC_GARBAGE); 1567 TRACE_DEFINE_ENUM(SVC_SYSERR); 1568 TRACE_DEFINE_ENUM(SVC_VALID); 1569 TRACE_DEFINE_ENUM(SVC_NEGATIVE); 1570 TRACE_DEFINE_ENUM(SVC_OK); 1571 TRACE_DEFINE_ENUM(SVC_DROP); 1572 TRACE_DEFINE_ENUM(SVC_CLOSE); 1573 TRACE_DEFINE_ENUM(SVC_DENIED); 1574 TRACE_DEFINE_ENUM(SVC_PENDING); 1575 TRACE_DEFINE_ENUM(SVC_COMPLETE); 1576 1577 #define svc_show_status(status) \ 1578 __print_symbolic(status, \ 1579 { SVC_GARBAGE, "SVC_GARBAGE" }, \ 1580 { SVC_SYSERR, "SVC_SYSERR" }, \ 1581 { SVC_VALID, "SVC_VALID" }, \ 1582 { SVC_NEGATIVE, "SVC_NEGATIVE" }, \ 1583 { SVC_OK, "SVC_OK" }, \ 1584 { SVC_DROP, "SVC_DROP" }, \ 1585 { SVC_CLOSE, "SVC_CLOSE" }, \ 1586 { SVC_DENIED, "SVC_DENIED" }, \ 1587 { SVC_PENDING, "SVC_PENDING" }, \ 1588 { SVC_COMPLETE, "SVC_COMPLETE" }) 1589 1590 TRACE_EVENT(svc_authenticate, 1591 TP_PROTO(const struct svc_rqst *rqst, int auth_res), 1592 1593 TP_ARGS(rqst, auth_res), 1594 1595 TP_STRUCT__entry( 1596 __field(u32, xid) 1597 __field(unsigned long, svc_status) 1598 __field(unsigned long, auth_stat) 1599 ), 1600 1601 TP_fast_assign( 1602 __entry->xid = be32_to_cpu(rqst->rq_xid); 1603 __entry->svc_status = auth_res; 1604 __entry->auth_stat = be32_to_cpu(rqst->rq_auth_stat); 1605 ), 1606 1607 TP_printk("xid=0x%08x auth_res=%s auth_stat=%s", 1608 __entry->xid, svc_show_status(__entry->svc_status), 1609 rpc_show_auth_stat(__entry->auth_stat)) 1610 ); 1611 1612 TRACE_EVENT(svc_process, 1613 TP_PROTO(const struct svc_rqst *rqst, const char *name), 1614 1615 TP_ARGS(rqst, name), 1616 1617 TP_STRUCT__entry( 1618 __field(u32, xid) 1619 __field(u32, vers) 1620 __field(u32, proc) 1621 __string(service, name) 1622 __string(procedure, svc_proc_name(rqst)) 1623 __string(addr, rqst->rq_xprt ? 1624 rqst->rq_xprt->xpt_remotebuf : "(null)") 1625 ), 1626 1627 TP_fast_assign( 1628 __entry->xid = be32_to_cpu(rqst->rq_xid); 1629 __entry->vers = rqst->rq_vers; 1630 __entry->proc = rqst->rq_proc; 1631 __assign_str(service, name); 1632 __assign_str(procedure, svc_proc_name(rqst)); 1633 __assign_str(addr, rqst->rq_xprt ? 1634 rqst->rq_xprt->xpt_remotebuf : "(null)"); 1635 ), 1636 1637 TP_printk("addr=%s xid=0x%08x service=%s vers=%u proc=%s", 1638 __get_str(addr), __entry->xid, 1639 __get_str(service), __entry->vers, 1640 __get_str(procedure) 1641 ) 1642 ); 1643 1644 DECLARE_EVENT_CLASS(svc_rqst_event, 1645 1646 TP_PROTO( 1647 const struct svc_rqst *rqst 1648 ), 1649 1650 TP_ARGS(rqst), 1651 1652 TP_STRUCT__entry( 1653 __field(u32, xid) 1654 __field(unsigned long, flags) 1655 __string(addr, rqst->rq_xprt->xpt_remotebuf) 1656 ), 1657 1658 TP_fast_assign( 1659 __entry->xid = be32_to_cpu(rqst->rq_xid); 1660 __entry->flags = rqst->rq_flags; 1661 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf); 1662 ), 1663 1664 TP_printk("addr=%s xid=0x%08x flags=%s", 1665 __get_str(addr), __entry->xid, 1666 show_rqstp_flags(__entry->flags)) 1667 ); 1668 #define DEFINE_SVC_RQST_EVENT(name) \ 1669 DEFINE_EVENT(svc_rqst_event, svc_##name, \ 1670 TP_PROTO( \ 1671 const struct svc_rqst *rqst \ 1672 ), \ 1673 TP_ARGS(rqst)) 1674 1675 DEFINE_SVC_RQST_EVENT(defer); 1676 DEFINE_SVC_RQST_EVENT(drop); 1677 1678 DECLARE_EVENT_CLASS(svc_rqst_status, 1679 1680 TP_PROTO(struct svc_rqst *rqst, int status), 1681 1682 TP_ARGS(rqst, status), 1683 1684 TP_STRUCT__entry( 1685 __field(u32, xid) 1686 __field(int, status) 1687 __field(unsigned long, flags) 1688 __string(addr, rqst->rq_xprt->xpt_remotebuf) 1689 ), 1690 1691 TP_fast_assign( 1692 __entry->xid = be32_to_cpu(rqst->rq_xid); 1693 __entry->status = status; 1694 __entry->flags = rqst->rq_flags; 1695 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf); 1696 ), 1697 1698 TP_printk("addr=%s xid=0x%08x status=%d flags=%s", 1699 __get_str(addr), __entry->xid, 1700 __entry->status, show_rqstp_flags(__entry->flags)) 1701 ); 1702 1703 DEFINE_EVENT(svc_rqst_status, svc_send, 1704 TP_PROTO(struct svc_rqst *rqst, int status), 1705 TP_ARGS(rqst, status)); 1706 1707 #define show_svc_xprt_flags(flags) \ 1708 __print_flags(flags, "|", \ 1709 { (1UL << XPT_BUSY), "XPT_BUSY"}, \ 1710 { (1UL << XPT_CONN), "XPT_CONN"}, \ 1711 { (1UL << XPT_CLOSE), "XPT_CLOSE"}, \ 1712 { (1UL << XPT_DATA), "XPT_DATA"}, \ 1713 { (1UL << XPT_TEMP), "XPT_TEMP"}, \ 1714 { (1UL << XPT_DEAD), "XPT_DEAD"}, \ 1715 { (1UL << XPT_CHNGBUF), "XPT_CHNGBUF"}, \ 1716 { (1UL << XPT_DEFERRED), "XPT_DEFERRED"}, \ 1717 { (1UL << XPT_OLD), "XPT_OLD"}, \ 1718 { (1UL << XPT_LISTENER), "XPT_LISTENER"}, \ 1719 { (1UL << XPT_CACHE_AUTH), "XPT_CACHE_AUTH"}, \ 1720 { (1UL << XPT_LOCAL), "XPT_LOCAL"}, \ 1721 { (1UL << XPT_KILL_TEMP), "XPT_KILL_TEMP"}, \ 1722 { (1UL << XPT_CONG_CTRL), "XPT_CONG_CTRL"}) 1723 1724 TRACE_EVENT(svc_xprt_create_err, 1725 TP_PROTO( 1726 const char *program, 1727 const char *protocol, 1728 struct sockaddr *sap, 1729 size_t salen, 1730 const struct svc_xprt *xprt 1731 ), 1732 1733 TP_ARGS(program, protocol, sap, salen, xprt), 1734 1735 TP_STRUCT__entry( 1736 __field(long, error) 1737 __string(program, program) 1738 __string(protocol, protocol) 1739 __array(unsigned char, addr, sizeof(struct sockaddr_in6)) 1740 ), 1741 1742 TP_fast_assign( 1743 __entry->error = PTR_ERR(xprt); 1744 __assign_str(program, program); 1745 __assign_str(protocol, protocol); 1746 memcpy(__entry->addr, sap, min(salen, sizeof(__entry->addr))); 1747 ), 1748 1749 TP_printk("addr=%pISpc program=%s protocol=%s error=%ld", 1750 __entry->addr, __get_str(program), __get_str(protocol), 1751 __entry->error) 1752 ); 1753 1754 TRACE_EVENT(svc_xprt_do_enqueue, 1755 TP_PROTO(struct svc_xprt *xprt, struct svc_rqst *rqst), 1756 1757 TP_ARGS(xprt, rqst), 1758 1759 TP_STRUCT__entry( 1760 __field(int, pid) 1761 __field(unsigned long, flags) 1762 __string(addr, xprt->xpt_remotebuf) 1763 ), 1764 1765 TP_fast_assign( 1766 __entry->pid = rqst? rqst->rq_task->pid : 0; 1767 __entry->flags = xprt->xpt_flags; 1768 __assign_str(addr, xprt->xpt_remotebuf); 1769 ), 1770 1771 TP_printk("addr=%s pid=%d flags=%s", __get_str(addr), 1772 __entry->pid, show_svc_xprt_flags(__entry->flags)) 1773 ); 1774 1775 DECLARE_EVENT_CLASS(svc_xprt_event, 1776 TP_PROTO(struct svc_xprt *xprt), 1777 1778 TP_ARGS(xprt), 1779 1780 TP_STRUCT__entry( 1781 __field(unsigned long, flags) 1782 __string(addr, xprt->xpt_remotebuf) 1783 ), 1784 1785 TP_fast_assign( 1786 __entry->flags = xprt->xpt_flags; 1787 __assign_str(addr, xprt->xpt_remotebuf); 1788 ), 1789 1790 TP_printk("addr=%s flags=%s", __get_str(addr), 1791 show_svc_xprt_flags(__entry->flags)) 1792 ); 1793 1794 #define DEFINE_SVC_XPRT_EVENT(name) \ 1795 DEFINE_EVENT(svc_xprt_event, svc_xprt_##name, \ 1796 TP_PROTO( \ 1797 struct svc_xprt *xprt \ 1798 ), \ 1799 TP_ARGS(xprt)) 1800 1801 DEFINE_SVC_XPRT_EVENT(received); 1802 DEFINE_SVC_XPRT_EVENT(no_write_space); 1803 DEFINE_SVC_XPRT_EVENT(close); 1804 DEFINE_SVC_XPRT_EVENT(detach); 1805 DEFINE_SVC_XPRT_EVENT(free); 1806 1807 TRACE_EVENT(svc_xprt_accept, 1808 TP_PROTO( 1809 const struct svc_xprt *xprt, 1810 const char *service 1811 ), 1812 1813 TP_ARGS(xprt, service), 1814 1815 TP_STRUCT__entry( 1816 __string(addr, xprt->xpt_remotebuf) 1817 __string(protocol, xprt->xpt_class->xcl_name) 1818 __string(service, service) 1819 ), 1820 1821 TP_fast_assign( 1822 __assign_str(addr, xprt->xpt_remotebuf); 1823 __assign_str(protocol, xprt->xpt_class->xcl_name); 1824 __assign_str(service, service); 1825 ), 1826 1827 TP_printk("addr=%s protocol=%s service=%s", 1828 __get_str(addr), __get_str(protocol), __get_str(service) 1829 ) 1830 ); 1831 1832 TRACE_EVENT(svc_xprt_dequeue, 1833 TP_PROTO(struct svc_rqst *rqst), 1834 1835 TP_ARGS(rqst), 1836 1837 TP_STRUCT__entry( 1838 __field(unsigned long, flags) 1839 __field(unsigned long, wakeup) 1840 __string(addr, rqst->rq_xprt->xpt_remotebuf) 1841 ), 1842 1843 TP_fast_assign( 1844 __entry->flags = rqst->rq_xprt->xpt_flags; 1845 __entry->wakeup = ktime_to_us(ktime_sub(ktime_get(), 1846 rqst->rq_qtime)); 1847 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf); 1848 ), 1849 1850 TP_printk("addr=%s flags=%s wakeup-us=%lu", __get_str(addr), 1851 show_svc_xprt_flags(__entry->flags), __entry->wakeup) 1852 ); 1853 1854 TRACE_EVENT(svc_wake_up, 1855 TP_PROTO(int pid), 1856 1857 TP_ARGS(pid), 1858 1859 TP_STRUCT__entry( 1860 __field(int, pid) 1861 ), 1862 1863 TP_fast_assign( 1864 __entry->pid = pid; 1865 ), 1866 1867 TP_printk("pid=%d", __entry->pid) 1868 ); 1869 1870 TRACE_EVENT(svc_handle_xprt, 1871 TP_PROTO(struct svc_xprt *xprt, int len), 1872 1873 TP_ARGS(xprt, len), 1874 1875 TP_STRUCT__entry( 1876 __field(int, len) 1877 __field(unsigned long, flags) 1878 __string(addr, xprt->xpt_remotebuf) 1879 ), 1880 1881 TP_fast_assign( 1882 __entry->len = len; 1883 __entry->flags = xprt->xpt_flags; 1884 __assign_str(addr, xprt->xpt_remotebuf); 1885 ), 1886 1887 TP_printk("addr=%s len=%d flags=%s", __get_str(addr), 1888 __entry->len, show_svc_xprt_flags(__entry->flags)) 1889 ); 1890 1891 TRACE_EVENT(svc_stats_latency, 1892 TP_PROTO(const struct svc_rqst *rqst), 1893 1894 TP_ARGS(rqst), 1895 1896 TP_STRUCT__entry( 1897 __field(u32, xid) 1898 __field(unsigned long, execute) 1899 __string(procedure, svc_proc_name(rqst)) 1900 __string(addr, rqst->rq_xprt->xpt_remotebuf) 1901 ), 1902 1903 TP_fast_assign( 1904 __entry->xid = be32_to_cpu(rqst->rq_xid); 1905 __entry->execute = ktime_to_us(ktime_sub(ktime_get(), 1906 rqst->rq_stime)); 1907 __assign_str(procedure, svc_proc_name(rqst)); 1908 __assign_str(addr, rqst->rq_xprt->xpt_remotebuf); 1909 ), 1910 1911 TP_printk("addr=%s xid=0x%08x proc=%s execute-us=%lu", 1912 __get_str(addr), __entry->xid, __get_str(procedure), 1913 __entry->execute) 1914 ); 1915 1916 DECLARE_EVENT_CLASS(svc_deferred_event, 1917 TP_PROTO( 1918 const struct svc_deferred_req *dr 1919 ), 1920 1921 TP_ARGS(dr), 1922 1923 TP_STRUCT__entry( 1924 __field(const void *, dr) 1925 __field(u32, xid) 1926 __sockaddr(addr, dr->addrlen) 1927 ), 1928 1929 TP_fast_assign( 1930 __entry->dr = dr; 1931 __entry->xid = be32_to_cpu(*(__be32 *)dr->args); 1932 __assign_sockaddr(addr, &dr->addr, dr->addrlen); 1933 ), 1934 1935 TP_printk("addr=%pISpc dr=%p xid=0x%08x", __get_sockaddr(addr), 1936 __entry->dr, __entry->xid) 1937 ); 1938 1939 #define DEFINE_SVC_DEFERRED_EVENT(name) \ 1940 DEFINE_EVENT(svc_deferred_event, svc_defer_##name, \ 1941 TP_PROTO( \ 1942 const struct svc_deferred_req *dr \ 1943 ), \ 1944 TP_ARGS(dr)) 1945 1946 DEFINE_SVC_DEFERRED_EVENT(drop); 1947 DEFINE_SVC_DEFERRED_EVENT(queue); 1948 DEFINE_SVC_DEFERRED_EVENT(recv); 1949 1950 TRACE_EVENT(svcsock_new_socket, 1951 TP_PROTO( 1952 const struct socket *socket 1953 ), 1954 1955 TP_ARGS(socket), 1956 1957 TP_STRUCT__entry( 1958 __field(unsigned long, type) 1959 __field(unsigned long, family) 1960 __field(bool, listener) 1961 ), 1962 1963 TP_fast_assign( 1964 __entry->type = socket->type; 1965 __entry->family = socket->sk->sk_family; 1966 __entry->listener = (socket->sk->sk_state == TCP_LISTEN); 1967 ), 1968 1969 TP_printk("type=%s family=%s%s", 1970 show_socket_type(__entry->type), 1971 rpc_show_address_family(__entry->family), 1972 __entry->listener ? " (listener)" : "" 1973 ) 1974 ); 1975 1976 TRACE_EVENT(svcsock_marker, 1977 TP_PROTO( 1978 const struct svc_xprt *xprt, 1979 __be32 marker 1980 ), 1981 1982 TP_ARGS(xprt, marker), 1983 1984 TP_STRUCT__entry( 1985 __field(unsigned int, length) 1986 __field(bool, last) 1987 __string(addr, xprt->xpt_remotebuf) 1988 ), 1989 1990 TP_fast_assign( 1991 __entry->length = be32_to_cpu(marker) & RPC_FRAGMENT_SIZE_MASK; 1992 __entry->last = be32_to_cpu(marker) & RPC_LAST_STREAM_FRAGMENT; 1993 __assign_str(addr, xprt->xpt_remotebuf); 1994 ), 1995 1996 TP_printk("addr=%s length=%u%s", __get_str(addr), 1997 __entry->length, __entry->last ? " (last)" : "") 1998 ); 1999 2000 DECLARE_EVENT_CLASS(svcsock_class, 2001 TP_PROTO( 2002 const struct svc_xprt *xprt, 2003 ssize_t result 2004 ), 2005 2006 TP_ARGS(xprt, result), 2007 2008 TP_STRUCT__entry( 2009 __field(ssize_t, result) 2010 __field(unsigned long, flags) 2011 __string(addr, xprt->xpt_remotebuf) 2012 ), 2013 2014 TP_fast_assign( 2015 __entry->result = result; 2016 __entry->flags = xprt->xpt_flags; 2017 __assign_str(addr, xprt->xpt_remotebuf); 2018 ), 2019 2020 TP_printk("addr=%s result=%zd flags=%s", __get_str(addr), 2021 __entry->result, show_svc_xprt_flags(__entry->flags) 2022 ) 2023 ); 2024 2025 #define DEFINE_SVCSOCK_EVENT(name) \ 2026 DEFINE_EVENT(svcsock_class, svcsock_##name, \ 2027 TP_PROTO( \ 2028 const struct svc_xprt *xprt, \ 2029 ssize_t result \ 2030 ), \ 2031 TP_ARGS(xprt, result)) 2032 2033 DEFINE_SVCSOCK_EVENT(udp_send); 2034 DEFINE_SVCSOCK_EVENT(udp_recv); 2035 DEFINE_SVCSOCK_EVENT(udp_recv_err); 2036 DEFINE_SVCSOCK_EVENT(tcp_send); 2037 DEFINE_SVCSOCK_EVENT(tcp_recv); 2038 DEFINE_SVCSOCK_EVENT(tcp_recv_eagain); 2039 DEFINE_SVCSOCK_EVENT(tcp_recv_err); 2040 DEFINE_SVCSOCK_EVENT(data_ready); 2041 DEFINE_SVCSOCK_EVENT(write_space); 2042 2043 TRACE_EVENT(svcsock_tcp_recv_short, 2044 TP_PROTO( 2045 const struct svc_xprt *xprt, 2046 u32 expected, 2047 u32 received 2048 ), 2049 2050 TP_ARGS(xprt, expected, received), 2051 2052 TP_STRUCT__entry( 2053 __field(u32, expected) 2054 __field(u32, received) 2055 __field(unsigned long, flags) 2056 __string(addr, xprt->xpt_remotebuf) 2057 ), 2058 2059 TP_fast_assign( 2060 __entry->expected = expected; 2061 __entry->received = received; 2062 __entry->flags = xprt->xpt_flags; 2063 __assign_str(addr, xprt->xpt_remotebuf); 2064 ), 2065 2066 TP_printk("addr=%s flags=%s expected=%u received=%u", 2067 __get_str(addr), show_svc_xprt_flags(__entry->flags), 2068 __entry->expected, __entry->received 2069 ) 2070 ); 2071 2072 TRACE_EVENT(svcsock_tcp_state, 2073 TP_PROTO( 2074 const struct svc_xprt *xprt, 2075 const struct socket *socket 2076 ), 2077 2078 TP_ARGS(xprt, socket), 2079 2080 TP_STRUCT__entry( 2081 __field(unsigned long, socket_state) 2082 __field(unsigned long, sock_state) 2083 __field(unsigned long, flags) 2084 __string(addr, xprt->xpt_remotebuf) 2085 ), 2086 2087 TP_fast_assign( 2088 __entry->socket_state = socket->state; 2089 __entry->sock_state = socket->sk->sk_state; 2090 __entry->flags = xprt->xpt_flags; 2091 __assign_str(addr, xprt->xpt_remotebuf); 2092 ), 2093 2094 TP_printk("addr=%s state=%s sk_state=%s flags=%s", __get_str(addr), 2095 rpc_show_socket_state(__entry->socket_state), 2096 rpc_show_sock_state(__entry->sock_state), 2097 show_svc_xprt_flags(__entry->flags) 2098 ) 2099 ); 2100 2101 DECLARE_EVENT_CLASS(svcsock_accept_class, 2102 TP_PROTO( 2103 const struct svc_xprt *xprt, 2104 const char *service, 2105 long status 2106 ), 2107 2108 TP_ARGS(xprt, service, status), 2109 2110 TP_STRUCT__entry( 2111 __field(long, status) 2112 __string(service, service) 2113 __field(unsigned int, netns_ino) 2114 ), 2115 2116 TP_fast_assign( 2117 __entry->status = status; 2118 __assign_str(service, service); 2119 __entry->netns_ino = xprt->xpt_net->ns.inum; 2120 ), 2121 2122 TP_printk("addr=listener service=%s status=%ld", 2123 __get_str(service), __entry->status 2124 ) 2125 ); 2126 2127 #define DEFINE_ACCEPT_EVENT(name) \ 2128 DEFINE_EVENT(svcsock_accept_class, svcsock_##name##_err, \ 2129 TP_PROTO( \ 2130 const struct svc_xprt *xprt, \ 2131 const char *service, \ 2132 long status \ 2133 ), \ 2134 TP_ARGS(xprt, service, status)) 2135 2136 DEFINE_ACCEPT_EVENT(accept); 2137 DEFINE_ACCEPT_EVENT(getpeername); 2138 2139 DECLARE_EVENT_CLASS(cache_event, 2140 TP_PROTO( 2141 const struct cache_detail *cd, 2142 const struct cache_head *h 2143 ), 2144 2145 TP_ARGS(cd, h), 2146 2147 TP_STRUCT__entry( 2148 __field(const struct cache_head *, h) 2149 __string(name, cd->name) 2150 ), 2151 2152 TP_fast_assign( 2153 __entry->h = h; 2154 __assign_str(name, cd->name); 2155 ), 2156 2157 TP_printk("cache=%s entry=%p", __get_str(name), __entry->h) 2158 ); 2159 #define DEFINE_CACHE_EVENT(name) \ 2160 DEFINE_EVENT(cache_event, name, \ 2161 TP_PROTO( \ 2162 const struct cache_detail *cd, \ 2163 const struct cache_head *h \ 2164 ), \ 2165 TP_ARGS(cd, h)) 2166 DEFINE_CACHE_EVENT(cache_entry_expired); 2167 DEFINE_CACHE_EVENT(cache_entry_upcall); 2168 DEFINE_CACHE_EVENT(cache_entry_update); 2169 DEFINE_CACHE_EVENT(cache_entry_make_negative); 2170 DEFINE_CACHE_EVENT(cache_entry_no_listener); 2171 2172 DECLARE_EVENT_CLASS(register_class, 2173 TP_PROTO( 2174 const char *program, 2175 const u32 version, 2176 const int family, 2177 const unsigned short protocol, 2178 const unsigned short port, 2179 int error 2180 ), 2181 2182 TP_ARGS(program, version, family, protocol, port, error), 2183 2184 TP_STRUCT__entry( 2185 __field(u32, version) 2186 __field(unsigned long, family) 2187 __field(unsigned short, protocol) 2188 __field(unsigned short, port) 2189 __field(int, error) 2190 __string(program, program) 2191 ), 2192 2193 TP_fast_assign( 2194 __entry->version = version; 2195 __entry->family = family; 2196 __entry->protocol = protocol; 2197 __entry->port = port; 2198 __entry->error = error; 2199 __assign_str(program, program); 2200 ), 2201 2202 TP_printk("program=%sv%u proto=%s port=%u family=%s error=%d", 2203 __get_str(program), __entry->version, 2204 __entry->protocol == IPPROTO_UDP ? "udp" : "tcp", 2205 __entry->port, rpc_show_address_family(__entry->family), 2206 __entry->error 2207 ) 2208 ); 2209 2210 #define DEFINE_REGISTER_EVENT(name) \ 2211 DEFINE_EVENT(register_class, svc_##name, \ 2212 TP_PROTO( \ 2213 const char *program, \ 2214 const u32 version, \ 2215 const int family, \ 2216 const unsigned short protocol, \ 2217 const unsigned short port, \ 2218 int error \ 2219 ), \ 2220 TP_ARGS(program, version, family, protocol, \ 2221 port, error)) 2222 2223 DEFINE_REGISTER_EVENT(register); 2224 DEFINE_REGISTER_EVENT(noregister); 2225 2226 TRACE_EVENT(svc_unregister, 2227 TP_PROTO( 2228 const char *program, 2229 const u32 version, 2230 int error 2231 ), 2232 2233 TP_ARGS(program, version, error), 2234 2235 TP_STRUCT__entry( 2236 __field(u32, version) 2237 __field(int, error) 2238 __string(program, program) 2239 ), 2240 2241 TP_fast_assign( 2242 __entry->version = version; 2243 __entry->error = error; 2244 __assign_str(program, program); 2245 ), 2246 2247 TP_printk("program=%sv%u error=%d", 2248 __get_str(program), __entry->version, __entry->error 2249 ) 2250 ); 2251 2252 #endif /* _TRACE_SUNRPC_H */ 2253 2254 #include <trace/define_trace.h> 2255