Lines Matching +full:wakeup +full:- +full:rtt +full:- +full:timer
1 /* SPDX-License-Identifier: GPL-2.0 */
73 __entry->task_id = task->tk_pid;
74 __entry->client_id = task->tk_client ?
75 task->tk_client->cl_clid : -1;
76 __entry->head_base = xdr->head[0].iov_base;
77 __entry->head_len = xdr->head[0].iov_len;
78 __entry->tail_base = xdr->tail[0].iov_base;
79 __entry->tail_len = xdr->tail[0].iov_len;
80 __entry->page_base = xdr->page_base;
81 __entry->page_len = xdr->page_len;
82 __entry->msg_len = xdr->len;
87 __entry->task_id, __entry->client_id,
88 __entry->head_base, __entry->head_len,
89 __entry->page_len, __entry->page_base,
90 __entry->tail_base, __entry->tail_len,
91 __entry->msg_len
121 __entry->client_id = clnt->cl_clid;
124 TP_printk("client=" SUNRPC_TRACE_CLID_SPECIFIER, __entry->client_id)
148 { RPC_XPRTSEC_TLS_ANON, "tls-anon" }, \
149 { RPC_XPRTSEC_TLS_X509, "tls-x509" })
181 __string(program, clnt->cl_program->name)
182 __string(server, xprt->servername)
183 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
184 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
188 __entry->client_id = clnt->cl_clid;
189 __entry->xprtsec = args->xprtsec.policy;
190 __entry->flags = args->flags;
199 __entry->client_id, __get_str(addr), __get_str(port),
201 rpc_show_xprtsec_policy(__entry->xprtsec),
202 rpc_show_create_flags(__entry->flags)
222 __entry->error = error;
228 __get_str(program), __get_str(server), __entry->error)
245 __entry->client_id = clnt->cl_clid;
246 __entry->error = error;
250 __entry->client_id, __entry->error)
287 __entry->task_id = task->tk_pid;
288 __entry->client_id = task->tk_client->cl_clid;
289 __entry->status = task->tk_status;
293 __entry->task_id, __entry->client_id,
294 __entry->status)
319 __string(progname, task->tk_client->cl_program->name)
324 __entry->task_id = task->tk_pid;
325 __entry->client_id = task->tk_client->cl_clid;
326 __entry->version = task->tk_client->cl_vers;
327 __entry->async = RPC_IS_ASYNC(task);
333 __entry->task_id, __entry->client_id,
334 __get_str(progname), __entry->version,
335 __get_str(procname), __entry->async ? "a": ""
382 __entry->client_id = task->tk_client ?
383 task->tk_client->cl_clid : -1;
384 __entry->task_id = task->tk_pid;
385 __entry->action = action;
386 __entry->runstate = task->tk_runstate;
387 __entry->status = task->tk_status;
388 __entry->flags = task->tk_flags;
393 __entry->task_id, __entry->client_id,
394 rpc_show_task_flags(__entry->flags),
395 rpc_show_runstate(__entry->runstate),
396 __entry->status,
397 __entry->action
435 __entry->client_id = task->tk_client ?
436 task->tk_client->cl_clid : -1;
437 __entry->task_id = task->tk_pid;
438 __entry->timeout = rpc_task_timeout(task);
439 __entry->runstate = task->tk_runstate;
440 __entry->status = task->tk_status;
441 __entry->flags = task->tk_flags;
447 __entry->task_id, __entry->client_id,
448 rpc_show_task_flags(__entry->flags),
449 rpc_show_runstate(__entry->runstate),
450 __entry->status,
451 __entry->timeout,
464 DEFINE_RPC_QUEUED_EVENT(wakeup);
478 __entry->task_id = task->tk_pid;
479 __entry->client_id = task->tk_client->cl_clid;
483 __entry->task_id, __entry->client_id)
508 __string(progname, task->tk_client->cl_program->name)
511 __string(servername, task->tk_xprt->servername)
515 __entry->task_id = task->tk_pid;
516 __entry->client_id = task->tk_client->cl_clid;
517 __entry->xid = be32_to_cpu(task->tk_rqstp->rq_xid);
519 __entry->version = task->tk_client->cl_vers;
526 __entry->task_id, __entry->client_id, __get_str(servername),
527 __entry->xid, __get_str(progname), __entry->version,
578 __entry->task_id = task->tk_pid;
579 __entry->client_id = task->tk_client->cl_clid;
580 __entry->callsize = task->tk_rqstp->rq_callsize;
581 __entry->recvsize = task->tk_rqstp->rq_rcvsize;
582 __entry->status = status;
587 __entry->task_id, __entry->client_id,
588 __entry->callsize, __entry->recvsize, __entry->status
609 __entry->client_id = task->tk_client->cl_clid;
610 __entry->task_id = task->tk_pid;
611 __entry->tk_status = tk_status;
612 __entry->rpc_status = rpc_status;
617 __entry->task_id, __entry->client_id,
618 __entry->tk_status, __entry->rpc_status)
626 ktime_t rtt,
630 TP_ARGS(task, backlog, rtt, execute),
637 __string(progname, task->tk_client->cl_program->name)
640 __field(unsigned long, rtt)
646 __entry->client_id = task->tk_client->cl_clid;
647 __entry->task_id = task->tk_pid;
648 __entry->xid = be32_to_cpu(task->tk_rqstp->rq_xid);
649 __entry->version = task->tk_client->cl_vers;
652 __entry->backlog = ktime_to_us(backlog);
653 __entry->rtt = ktime_to_us(rtt);
654 __entry->execute = ktime_to_us(execute);
655 __entry->xprt_id = task->tk_xprt->id;
659 " xid=0x%08x %sv%d %s backlog=%lu rtt=%lu execute=%lu"
661 __entry->task_id, __entry->client_id, __entry->xid,
662 __get_str(progname), __entry->version, __get_str(procname),
663 __entry->backlog, __entry->rtt, __entry->execute,
664 __entry->xprt_id)
688 __string(progname, xdr->rqst ?
689 xdr->rqst->rq_task->tk_client->cl_program->name : "unknown")
690 __string(procedure, xdr->rqst ?
691 xdr->rqst->rq_task->tk_msg.rpc_proc->p_name : "unknown")
695 if (xdr->rqst) {
696 const struct rpc_task *task = xdr->rqst->rq_task;
698 __entry->task_id = task->tk_pid;
699 __entry->client_id = task->tk_client->cl_clid;
701 __entry->version = task->tk_client->cl_vers;
704 __entry->task_id = -1;
705 __entry->client_id = -1;
707 __entry->version = 0;
710 __entry->requested = requested;
711 __entry->end = xdr->end;
712 __entry->p = xdr->p;
713 __entry->head_base = xdr->buf->head[0].iov_base,
714 __entry->head_len = xdr->buf->head[0].iov_len,
715 __entry->page_len = xdr->buf->page_len,
716 __entry->tail_base = xdr->buf->tail[0].iov_base,
717 __entry->tail_len = xdr->buf->tail[0].iov_len,
718 __entry->len = xdr->buf->len;
723 __entry->task_id, __entry->client_id,
724 __get_str(progname), __entry->version, __get_str(procedure),
725 __entry->requested, __entry->p, __entry->end,
726 __entry->head_base, __entry->head_len,
727 __entry->page_len,
728 __entry->tail_base, __entry->tail_len,
729 __entry->len
755 xdr->rqst->rq_task->tk_client->cl_program->name)
757 xdr->rqst->rq_task->tk_msg.rpc_proc->p_name)
761 const struct rpc_task *task = xdr->rqst->rq_task;
763 __entry->task_id = task->tk_pid;
764 __entry->client_id = task->tk_client->cl_clid;
766 __entry->version = task->tk_client->cl_vers;
769 __entry->offset = offset;
770 __entry->copied = copied;
771 __entry->head_base = xdr->buf->head[0].iov_base,
772 __entry->head_len = xdr->buf->head[0].iov_len,
773 __entry->page_len = xdr->buf->page_len,
774 __entry->tail_base = xdr->buf->tail[0].iov_base,
775 __entry->tail_len = xdr->buf->tail[0].iov_len,
776 __entry->len = xdr->buf->len;
781 __entry->task_id, __entry->client_id,
782 __get_str(progname), __entry->version, __get_str(procedure),
783 __entry->offset, __entry->copied,
784 __entry->head_base, __entry->head_len,
785 __entry->page_len,
786 __entry->tail_base, __entry->tail_len,
787 __entry->len
861 const struct sock *sk = socket->sk;
864 memset(__entry->saddr, 0, sizeof(struct sockaddr_in6));
865 memset(__entry->daddr, 0, sizeof(struct sockaddr_in6));
869 __entry->socket_state = socket->state;
870 __entry->sock_state = socket->sk->sk_state;
871 __entry->ino = (unsigned long long)inode->i_ino;
878 __entry->ino,
879 __entry->saddr,
880 __entry->daddr,
881 __entry->socket_state,
882 rpc_show_socket_state(__entry->socket_state),
883 __entry->sock_state,
884 rpc_show_sock_state(__entry->sock_state)
916 const struct sock *sk = socket->sk;
919 memset(__entry->saddr, 0, sizeof(struct sockaddr_in6));
920 memset(__entry->daddr, 0, sizeof(struct sockaddr_in6));
924 __entry->socket_state = socket->state;
925 __entry->sock_state = socket->sk->sk_state;
926 __entry->ino = (unsigned long long)inode->i_ino;
927 __entry->error = error;
933 __entry->error,
934 __entry->ino,
935 __entry->saddr,
936 __entry->daddr,
937 __entry->socket_state,
938 rpc_show_socket_state(__entry->socket_state),
939 __entry->sock_state,
940 rpc_show_sock_state(__entry->sock_state)
975 __entry->task_id = rqst->rq_task->tk_pid;
976 __entry->client_id = rqst->rq_task->tk_client->cl_clid;
977 __entry->total = rqst->rq_slen;
978 __entry->remaining = rqst->rq_slen - transport->xmit.offset;
983 __entry->task_id, __entry->client_id,
984 __entry->total, __entry->remaining
1013 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
1014 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
1018 __entry->state = xprt->state;
1025 rpc_show_xprt_state(__entry->state))
1055 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
1056 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
1060 __entry->xid = be32_to_cpu(xid);
1061 __entry->status = status;
1067 __get_str(port), __entry->xid,
1068 __entry->status)
1079 DEFINE_RPC_XPRT_EVENT(timer);
1099 __entry->task_id = rqst->rq_task->tk_pid;
1100 __entry->client_id = rqst->rq_task->tk_client ?
1101 rqst->rq_task->tk_client->cl_clid : -1;
1102 __entry->xid = be32_to_cpu(rqst->rq_xid);
1103 __entry->seqno = rqst->rq_seqno;
1104 __entry->status = status;
1109 __entry->task_id, __entry->client_id, __entry->xid,
1110 __entry->seqno, __entry->status)
1128 rqst->rq_task->tk_client->cl_program->name)
1129 __string(procname, rpc_proc_name(rqst->rq_task))
1133 struct rpc_task *task = rqst->rq_task;
1135 __entry->task_id = task->tk_pid;
1136 __entry->client_id = task->tk_client ?
1137 task->tk_client->cl_clid : -1;
1138 __entry->xid = be32_to_cpu(rqst->rq_xid);
1139 __entry->ntrans = rqst->rq_ntrans;
1140 __entry->timeout = task->tk_timeout;
1142 __entry->version = task->tk_client->cl_vers;
1148 __entry->task_id, __entry->client_id, __entry->xid,
1149 __get_str(progname), __entry->version, __get_str(procname),
1150 __entry->ntrans, __entry->timeout
1161 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
1162 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
1166 __entry->status = status;
1172 __get_str(addr), __get_str(port), __entry->status)
1190 __entry->task_id = task->tk_pid;
1191 __entry->client_id = task->tk_client ?
1192 task->tk_client->cl_clid : -1;
1194 __entry->task_id = -1;
1195 __entry->client_id = -1;
1197 if (xprt->snd_task &&
1198 !test_bit(XPRT_SND_IS_COOKIE, &xprt->state))
1199 __entry->snd_task_id = xprt->snd_task->tk_pid;
1201 __entry->snd_task_id = -1;
1206 __entry->task_id, __entry->client_id,
1207 __entry->snd_task_id)
1239 __entry->task_id = task->tk_pid;
1240 __entry->client_id = task->tk_client ?
1241 task->tk_client->cl_clid : -1;
1243 __entry->task_id = -1;
1244 __entry->client_id = -1;
1246 if (xprt->snd_task &&
1247 !test_bit(XPRT_SND_IS_COOKIE, &xprt->state))
1248 __entry->snd_task_id = xprt->snd_task->tk_pid;
1250 __entry->snd_task_id = -1;
1252 __entry->cong = xprt->cong;
1253 __entry->cwnd = xprt->cwnd;
1254 __entry->wait = test_bit(XPRT_CWND_WAIT, &xprt->state);
1260 __entry->task_id, __entry->client_id,
1261 __entry->snd_task_id, __entry->cong, __entry->cwnd,
1262 __entry->wait ? " (wait)" : "")
1292 __entry->task_id = rqst->rq_task->tk_pid;
1293 __entry->client_id = rqst->rq_task->tk_client->cl_clid;
1294 __entry->xid = be32_to_cpu(rqst->rq_xid);
1298 __entry->task_id, __entry->client_id, __entry->xid
1310 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
1311 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
1330 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
1332 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
1337 __entry->err = err;
1338 __entry->total = total;
1344 __get_str(port), __entry->err, __entry->total)
1353 __string(addr, xs->xprt.address_strings[RPC_DISPLAY_ADDR])
1354 __string(port, xs->xprt.address_strings[RPC_DISPLAY_PORT])
1364 __entry->xid = be32_to_cpu(xs->recv.xid);
1365 __entry->copied = xs->recv.copied;
1366 __entry->reclen = xs->recv.len;
1367 __entry->offset = xs->recv.offset;
1371 __get_str(addr), __get_str(port), __entry->xid,
1372 __entry->copied, __entry->reclen, __entry->offset)
1391 __string(servername, task->tk_xprt->servername)
1395 __entry->task_id = task->tk_pid;
1396 __entry->client_id = clnt->cl_clid;
1397 __entry->program = clnt->cl_prog;
1398 __entry->version = clnt->cl_vers;
1399 __entry->protocol = task->tk_xprt->prot;
1400 __entry->bind_version = bind_version;
1406 __entry->task_id, __entry->client_id, __get_str(servername),
1407 __entry->program, __entry->version, __entry->protocol,
1408 __entry->bind_version
1429 __entry->task_id = task->tk_pid;
1430 __entry->client_id = task->tk_client->cl_clid;
1431 __entry->status = status;
1432 __entry->port = port;
1436 __entry->task_id, __entry->client_id,
1437 __entry->status, __entry->port
1459 __entry->program = program;
1460 __entry->version = version;
1461 __entry->protocol = protocol;
1462 __entry->port = port;
1466 __entry->program, __entry->version,
1467 __entry->protocol, __entry->port
1489 __entry->program = program;
1490 __entry->version = version;
1496 __entry->program, __entry->version,
1517 __entry->program = program;
1518 __entry->version = version;
1523 __entry->program, __entry->version, __get_str(netid)
1528 ** RPC-over-TLS tracepoints
1542 __string(servername, xprt->servername)
1543 __string(progname, clnt->cl_program->name)
1547 __entry->requested_policy = clnt->cl_xprtsec.policy;
1548 __entry->version = clnt->cl_vers;
1554 __get_str(servername), __get_str(progname), __entry->version,
1555 rpc_show_xprtsec_policy(__entry->requested_policy)
1571 /* Record an xdr_buf containing a fully-formed RPC message */
1590 __be32 *p = (__be32 *)xdr->head[0].iov_base;
1592 __entry->xid = be32_to_cpu(*p);
1593 __entry->head_base = p;
1594 __entry->head_len = xdr->head[0].iov_len;
1595 __entry->tail_base = xdr->tail[0].iov_base;
1596 __entry->tail_len = xdr->tail[0].iov_len;
1597 __entry->page_len = xdr->page_len;
1598 __entry->msg_len = xdr->len;
1602 __entry->xid,
1603 __entry->head_base, __entry->head_len, __entry->page_len,
1604 __entry->tail_base, __entry->tail_len, __entry->msg_len
1639 __entry->xid = be32_to_cpu(xid);
1640 __entry->head_base = xdr->head[0].iov_base;
1641 __entry->head_len = xdr->head[0].iov_len;
1642 __entry->tail_base = xdr->tail[0].iov_base;
1643 __entry->tail_len = xdr->tail[0].iov_len;
1644 __entry->page_base = xdr->page_base;
1645 __entry->page_len = xdr->page_len;
1646 __entry->msg_len = xdr->len;
1650 __entry->xid,
1651 __entry->head_base, __entry->head_len,
1652 __entry->page_len, __entry->page_base,
1653 __entry->tail_base, __entry->tail_len,
1654 __entry->msg_len
1720 __sockaddr(server, (r)->rq_xprt->xpt_locallen) \
1721 __sockaddr(client, (r)->rq_xprt->xpt_remotelen) \
1727 struct svc_xprt *xprt = (r)->rq_xprt; \
1728 __assign_sockaddr(server, &xprt->xpt_local, \
1729 xprt->xpt_locallen); \
1730 __assign_sockaddr(client, &xprt->xpt_remote, \
1731 xprt->xpt_remotelen); \
1732 __entry->netns_ino = xprt->xpt_net->ns.inum; \
1733 __entry->xid = be32_to_cpu((r)->rq_xid); \
1740 __entry->xid, __get_sockaddr(server), __get_sockaddr(client)
1762 __entry->svc_status = auth_res;
1763 __entry->auth_stat = be32_to_cpu(rqst->rq_auth_stat);
1769 show_svc_auth_status(__entry->svc_status),
1770 rpc_show_auth_stat(__entry->auth_stat))
1784 __string(addr, rqst->rq_xprt ?
1785 rqst->rq_xprt->xpt_remotebuf : EVENT_NULL_STR)
1789 __entry->xid = be32_to_cpu(rqst->rq_xid);
1790 __entry->vers = rqst->rq_vers;
1791 __entry->proc = rqst->rq_proc;
1798 __get_str(addr), __entry->xid,
1799 __get_str(service), __entry->vers,
1820 __entry->flags = rqst->rq_flags;
1825 show_rqstp_flags(__entry->flags))
1855 __entry->status = status;
1856 __entry->flags = rqst->rq_flags;
1861 __entry->status, show_rqstp_flags(__entry->flags))
1883 __entry->begin = rqst->rq_pages;
1884 __entry->respages = rqst->rq_respages;
1885 __entry->nextpage = rqst->rq_next_page;
1890 __entry->begin, __entry->respages, __entry->nextpage)
1910 __entry->execute = ktime_to_us(ktime_sub(ktime_get(),
1911 rqst->rq_stime));
1915 TP_printk(SVC_RQST_ENDPOINT_FORMAT " proc=%s execute-us=%lu",
1917 __get_str(procedure), __entry->execute)
1976 __entry->error = PTR_ERR(xprt);
1984 __entry->error)
1988 __sockaddr(server, (x)->xpt_locallen) \
1989 __sockaddr(client, (x)->xpt_remotelen) \
1995 __assign_sockaddr(server, &(x)->xpt_local, \
1996 (x)->xpt_locallen); \
1997 __assign_sockaddr(client, &(x)->xpt_remote, \
1998 (x)->xpt_remotelen); \
1999 __entry->flags = (x)->xpt_flags; \
2000 __entry->netns_ino = (x)->xpt_net->ns.inum; \
2008 show_svc_xprt_flags(__entry->flags)
2023 __assign_sockaddr(server, &xprt->xpt_local,
2024 xprt->xpt_locallen);
2025 __assign_sockaddr(client, &xprt->xpt_remote,
2026 xprt->xpt_remotelen);
2027 __entry->flags = flags;
2028 __entry->netns_ino = xprt->xpt_net->ns.inum;
2042 SVC_XPRT_ENDPOINT_FIELDS(rqst->rq_xprt)
2044 __field(unsigned long, wakeup)
2048 SVC_XPRT_ENDPOINT_ASSIGNMENTS(rqst->rq_xprt);
2050 __entry->wakeup = ktime_to_us(ktime_sub(ktime_get(),
2051 rqst->rq_qtime));
2054 TP_printk(SVC_XPRT_ENDPOINT_FORMAT " wakeup-us=%lu",
2055 SVC_XPRT_ENDPOINT_VARARGS, __entry->wakeup)
2110 __string(protocol, xprt->xpt_class->xcl_name)
2137 __entry->pid = pid;
2140 TP_printk("pid=%d", __entry->pid)
2157 __entry->requested = requested;
2158 __entry->allocated = allocated;
2162 __entry->requested, __entry->allocated)
2175 __sockaddr(addr, dr->addrlen)
2179 __entry->dr = dr;
2180 __entry->xid = be32_to_cpu(*(__be32 *)dr->args);
2181 __assign_sockaddr(addr, &dr->addr, dr->addrlen);
2185 __entry->dr, __entry->xid)
2214 struct sock *sk = socket->sk;
2216 __entry->netns_ino = sock_net(sk)->ns.inum;
2217 __entry->svsk = svsk;
2218 __entry->sk = sk;
2219 __entry->type = socket->type;
2220 __entry->family = sk->sk_family;
2221 __entry->state = sk->sk_state;
2224 __entry->svsk, show_socket_type(__entry->type),
2225 rpc_show_address_family(__entry->family),
2226 __entry->state == TCP_LISTEN ? " (listener)" : ""
2251 __string(addr, xprt->xpt_remotebuf)
2255 __entry->length = be32_to_cpu(marker) & RPC_FRAGMENT_SIZE_MASK;
2256 __entry->last = be32_to_cpu(marker) & RPC_LAST_STREAM_FRAGMENT;
2261 __entry->length, __entry->last ? " (last)" : "")
2275 __string(addr, xprt->xpt_remotebuf)
2279 __entry->result = result;
2280 __entry->flags = xprt->xpt_flags;
2285 __entry->result, show_svc_xprt_flags(__entry->flags)
2320 __string(addr, xprt->xpt_remotebuf)
2324 __entry->expected = expected;
2325 __entry->received = received;
2326 __entry->flags = xprt->xpt_flags;
2331 __get_str(addr), show_svc_xprt_flags(__entry->flags),
2332 __entry->expected, __entry->received
2348 __string(addr, xprt->xpt_remotebuf)
2352 __entry->socket_state = socket->state;
2353 __entry->sock_state = socket->sk->sk_state;
2354 __entry->flags = xprt->xpt_flags;
2359 rpc_show_socket_state(__entry->socket_state),
2360 rpc_show_sock_state(__entry->sock_state),
2361 show_svc_xprt_flags(__entry->flags)
2381 __entry->status = status;
2383 __entry->netns_ino = xprt->xpt_net->ns.inum;
2387 __get_str(service), __entry->status
2413 __string(name, cd->name)
2417 __entry->h = h;
2421 TP_printk("cache=%s entry=%p", __get_str(name), __entry->h)
2458 __entry->version = version;
2459 __entry->family = family;
2460 __entry->protocol = protocol;
2461 __entry->port = port;
2462 __entry->error = error;
2467 __get_str(program), __entry->version,
2468 __entry->protocol == IPPROTO_UDP ? "udp" : "tcp",
2469 __entry->port, rpc_show_address_family(__entry->family),
2470 __entry->error
2506 __entry->version = version;
2507 __entry->error = error;
2512 __get_str(program), __entry->version, __entry->error