1 /* AF_RXRPC tracepoints
3 * Copyright (C) 2016 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public Licence
8 * as published by the Free Software Foundation; either version
9 * 2 of the Licence, or (at your option) any later version.
12 #define TRACE_SYSTEM rxrpc
14 #if !defined(_TRACE_RXRPC_H) || defined(TRACE_HEADER_MULTI_READ)
15 #define _TRACE_RXRPC_H
17 #include <linux/tracepoint.h>
20 * Define enums for tracing information.
22 * These should all be kept sorted, making it easier to match the string
23 * mapping tables further on.
25 #ifndef __RXRPC_DECLARE_TRACE_ENUMS_ONCE_ONLY
26 #define __RXRPC_DECLARE_TRACE_ENUMS_ONCE_ONLY
28 enum rxrpc_skb_trace
{
34 rxrpc_skb_rx_received
,
45 enum rxrpc_conn_trace
{
47 rxrpc_conn_new_client
,
48 rxrpc_conn_new_service
,
49 rxrpc_conn_put_client
,
50 rxrpc_conn_put_service
,
52 rxrpc_conn_reap_service
,
56 enum rxrpc_client_trace
{
57 rxrpc_client_activate_chans
,
59 rxrpc_client_chan_activate
,
60 rxrpc_client_chan_disconnect
,
61 rxrpc_client_chan_pass
,
62 rxrpc_client_chan_unstarted
,
66 rxrpc_client_duplicate
,
69 rxrpc_client_to_active
,
70 rxrpc_client_to_culled
,
72 rxrpc_client_to_inactive
,
73 rxrpc_client_to_upgrade
,
74 rxrpc_client_to_waiting
,
78 enum rxrpc_call_trace
{
82 rxrpc_call_got_kernel
,
83 rxrpc_call_got_userid
,
84 rxrpc_call_new_client
,
85 rxrpc_call_new_service
,
87 rxrpc_call_put_kernel
,
88 rxrpc_call_put_noqueue
,
89 rxrpc_call_put_userid
,
91 rxrpc_call_queued_ref
,
96 enum rxrpc_transmit_trace
{
97 rxrpc_transmit_await_reply
,
100 rxrpc_transmit_queue_last
,
101 rxrpc_transmit_rotate
,
102 rxrpc_transmit_rotate_last
,
106 enum rxrpc_receive_trace
{
109 rxrpc_receive_incoming
,
111 rxrpc_receive_queue_last
,
112 rxrpc_receive_rotate
,
115 enum rxrpc_recvmsg_trace
{
117 rxrpc_recvmsg_data_return
,
118 rxrpc_recvmsg_dequeue
,
123 rxrpc_recvmsg_requeue
,
124 rxrpc_recvmsg_return
,
125 rxrpc_recvmsg_terminal
,
126 rxrpc_recvmsg_to_be_accepted
,
130 enum rxrpc_rtt_tx_trace
{
135 enum rxrpc_rtt_rx_trace
{
136 rxrpc_rtt_rx_ping_response
,
137 rxrpc_rtt_rx_requested_ack
,
140 enum rxrpc_timer_trace
{
143 rxrpc_timer_exp_hard
,
144 rxrpc_timer_exp_idle
,
145 rxrpc_timer_exp_keepalive
,
146 rxrpc_timer_exp_lost_ack
,
147 rxrpc_timer_exp_normal
,
148 rxrpc_timer_exp_ping
,
149 rxrpc_timer_exp_resend
,
151 rxrpc_timer_init_for_reply
,
152 rxrpc_timer_init_for_send_reply
,
154 rxrpc_timer_set_for_ack
,
155 rxrpc_timer_set_for_hard
,
156 rxrpc_timer_set_for_idle
,
157 rxrpc_timer_set_for_keepalive
,
158 rxrpc_timer_set_for_lost_ack
,
159 rxrpc_timer_set_for_normal
,
160 rxrpc_timer_set_for_ping
,
161 rxrpc_timer_set_for_resend
,
162 rxrpc_timer_set_for_send
,
165 enum rxrpc_propose_ack_trace
{
166 rxrpc_propose_ack_client_tx_end
,
167 rxrpc_propose_ack_input_data
,
168 rxrpc_propose_ack_ping_for_keepalive
,
169 rxrpc_propose_ack_ping_for_lost_ack
,
170 rxrpc_propose_ack_ping_for_lost_reply
,
171 rxrpc_propose_ack_ping_for_params
,
172 rxrpc_propose_ack_processing_op
,
173 rxrpc_propose_ack_respond_to_ack
,
174 rxrpc_propose_ack_respond_to_ping
,
175 rxrpc_propose_ack_retry_tx
,
176 rxrpc_propose_ack_rotate_rx
,
177 rxrpc_propose_ack_terminal_ack
,
180 enum rxrpc_propose_ack_outcome
{
181 rxrpc_propose_ack_subsume
,
182 rxrpc_propose_ack_update
,
183 rxrpc_propose_ack_use
,
186 enum rxrpc_congest_change
{
187 rxrpc_cong_begin_retransmission
,
188 rxrpc_cong_cleared_nacks
,
189 rxrpc_cong_new_low_nack
,
190 rxrpc_cong_no_change
,
192 rxrpc_cong_retransmit_again
,
193 rxrpc_cong_rtt_window_end
,
197 #endif /* end __RXRPC_DECLARE_TRACE_ENUMS_ONCE_ONLY */
200 * Declare tracing information enums and their string mappings for display.
202 #define rxrpc_skb_traces \
203 EM(rxrpc_skb_rx_cleaned, "Rx CLN") \
204 EM(rxrpc_skb_rx_freed, "Rx FRE") \
205 EM(rxrpc_skb_rx_got, "Rx GOT") \
206 EM(rxrpc_skb_rx_lost, "Rx *L*") \
207 EM(rxrpc_skb_rx_purged, "Rx PUR") \
208 EM(rxrpc_skb_rx_received, "Rx RCV") \
209 EM(rxrpc_skb_rx_rotated, "Rx ROT") \
210 EM(rxrpc_skb_rx_seen, "Rx SEE") \
211 EM(rxrpc_skb_tx_cleaned, "Tx CLN") \
212 EM(rxrpc_skb_tx_freed, "Tx FRE") \
213 EM(rxrpc_skb_tx_got, "Tx GOT") \
214 EM(rxrpc_skb_tx_new, "Tx NEW") \
215 EM(rxrpc_skb_tx_rotated, "Tx ROT") \
216 E_(rxrpc_skb_tx_seen, "Tx SEE")
218 #define rxrpc_conn_traces \
219 EM(rxrpc_conn_got, "GOT") \
220 EM(rxrpc_conn_new_client, "NWc") \
221 EM(rxrpc_conn_new_service, "NWs") \
222 EM(rxrpc_conn_put_client, "PTc") \
223 EM(rxrpc_conn_put_service, "PTs") \
224 EM(rxrpc_conn_queued, "QUE") \
225 EM(rxrpc_conn_reap_service, "RPs") \
226 E_(rxrpc_conn_seen, "SEE")
228 #define rxrpc_client_traces \
229 EM(rxrpc_client_activate_chans, "Activa") \
230 EM(rxrpc_client_alloc, "Alloc ") \
231 EM(rxrpc_client_chan_activate, "ChActv") \
232 EM(rxrpc_client_chan_disconnect, "ChDisc") \
233 EM(rxrpc_client_chan_pass, "ChPass") \
234 EM(rxrpc_client_chan_unstarted, "ChUnst") \
235 EM(rxrpc_client_cleanup, "Clean ") \
236 EM(rxrpc_client_count, "Count ") \
237 EM(rxrpc_client_discard, "Discar") \
238 EM(rxrpc_client_duplicate, "Duplic") \
239 EM(rxrpc_client_exposed, "Expose") \
240 EM(rxrpc_client_replace, "Replac") \
241 EM(rxrpc_client_to_active, "->Actv") \
242 EM(rxrpc_client_to_culled, "->Cull") \
243 EM(rxrpc_client_to_idle, "->Idle") \
244 EM(rxrpc_client_to_inactive, "->Inac") \
245 EM(rxrpc_client_to_upgrade, "->Upgd") \
246 EM(rxrpc_client_to_waiting, "->Wait") \
247 E_(rxrpc_client_uncount, "Uncoun")
249 #define rxrpc_conn_cache_states \
250 EM(RXRPC_CONN_CLIENT_INACTIVE, "Inac") \
251 EM(RXRPC_CONN_CLIENT_WAITING, "Wait") \
252 EM(RXRPC_CONN_CLIENT_ACTIVE, "Actv") \
253 EM(RXRPC_CONN_CLIENT_UPGRADE, "Upgd") \
254 EM(RXRPC_CONN_CLIENT_CULLED, "Cull") \
255 E_(RXRPC_CONN_CLIENT_IDLE, "Idle") \
257 #define rxrpc_call_traces \
258 EM(rxrpc_call_connected, "CON") \
259 EM(rxrpc_call_error, "*E*") \
260 EM(rxrpc_call_got, "GOT") \
261 EM(rxrpc_call_got_kernel, "Gke") \
262 EM(rxrpc_call_got_userid, "Gus") \
263 EM(rxrpc_call_new_client, "NWc") \
264 EM(rxrpc_call_new_service, "NWs") \
265 EM(rxrpc_call_put, "PUT") \
266 EM(rxrpc_call_put_kernel, "Pke") \
267 EM(rxrpc_call_put_noqueue, "PNQ") \
268 EM(rxrpc_call_put_userid, "Pus") \
269 EM(rxrpc_call_queued, "QUE") \
270 EM(rxrpc_call_queued_ref, "QUR") \
271 EM(rxrpc_call_release, "RLS") \
272 E_(rxrpc_call_seen, "SEE")
274 #define rxrpc_transmit_traces \
275 EM(rxrpc_transmit_await_reply, "AWR") \
276 EM(rxrpc_transmit_end, "END") \
277 EM(rxrpc_transmit_queue, "QUE") \
278 EM(rxrpc_transmit_queue_last, "QLS") \
279 EM(rxrpc_transmit_rotate, "ROT") \
280 EM(rxrpc_transmit_rotate_last, "RLS") \
281 E_(rxrpc_transmit_wait, "WAI")
283 #define rxrpc_receive_traces \
284 EM(rxrpc_receive_end, "END") \
285 EM(rxrpc_receive_front, "FRN") \
286 EM(rxrpc_receive_incoming, "INC") \
287 EM(rxrpc_receive_queue, "QUE") \
288 EM(rxrpc_receive_queue_last, "QLS") \
289 E_(rxrpc_receive_rotate, "ROT")
291 #define rxrpc_recvmsg_traces \
292 EM(rxrpc_recvmsg_cont, "CONT") \
293 EM(rxrpc_recvmsg_data_return, "DATA") \
294 EM(rxrpc_recvmsg_dequeue, "DEQU") \
295 EM(rxrpc_recvmsg_enter, "ENTR") \
296 EM(rxrpc_recvmsg_full, "FULL") \
297 EM(rxrpc_recvmsg_hole, "HOLE") \
298 EM(rxrpc_recvmsg_next, "NEXT") \
299 EM(rxrpc_recvmsg_requeue, "REQU") \
300 EM(rxrpc_recvmsg_return, "RETN") \
301 EM(rxrpc_recvmsg_terminal, "TERM") \
302 EM(rxrpc_recvmsg_to_be_accepted, "TBAC") \
303 E_(rxrpc_recvmsg_wait, "WAIT")
305 #define rxrpc_rtt_tx_traces \
306 EM(rxrpc_rtt_tx_data, "DATA") \
307 E_(rxrpc_rtt_tx_ping, "PING")
309 #define rxrpc_rtt_rx_traces \
310 EM(rxrpc_rtt_rx_ping_response, "PONG") \
311 E_(rxrpc_rtt_rx_requested_ack, "RACK")
313 #define rxrpc_timer_traces \
314 EM(rxrpc_timer_begin, "Begin ") \
315 EM(rxrpc_timer_expired, "*EXPR*") \
316 EM(rxrpc_timer_exp_ack, "ExpAck") \
317 EM(rxrpc_timer_exp_hard, "ExpHrd") \
318 EM(rxrpc_timer_exp_idle, "ExpIdl") \
319 EM(rxrpc_timer_exp_keepalive, "ExpKA ") \
320 EM(rxrpc_timer_exp_lost_ack, "ExpLoA") \
321 EM(rxrpc_timer_exp_normal, "ExpNml") \
322 EM(rxrpc_timer_exp_ping, "ExpPng") \
323 EM(rxrpc_timer_exp_resend, "ExpRsn") \
324 EM(rxrpc_timer_init_for_reply, "IniRpl") \
325 EM(rxrpc_timer_init_for_send_reply, "SndRpl") \
326 EM(rxrpc_timer_restart, "Restrt") \
327 EM(rxrpc_timer_set_for_ack, "SetAck") \
328 EM(rxrpc_timer_set_for_hard, "SetHrd") \
329 EM(rxrpc_timer_set_for_idle, "SetIdl") \
330 EM(rxrpc_timer_set_for_keepalive, "KeepAl") \
331 EM(rxrpc_timer_set_for_lost_ack, "SetLoA") \
332 EM(rxrpc_timer_set_for_normal, "SetNml") \
333 EM(rxrpc_timer_set_for_ping, "SetPng") \
334 EM(rxrpc_timer_set_for_resend, "SetRTx") \
335 E_(rxrpc_timer_set_for_send, "SetSnd")
337 #define rxrpc_propose_ack_traces \
338 EM(rxrpc_propose_ack_client_tx_end, "ClTxEnd") \
339 EM(rxrpc_propose_ack_input_data, "DataIn ") \
340 EM(rxrpc_propose_ack_ping_for_keepalive, "KeepAlv") \
341 EM(rxrpc_propose_ack_ping_for_lost_ack, "LostAck") \
342 EM(rxrpc_propose_ack_ping_for_lost_reply, "LostRpl") \
343 EM(rxrpc_propose_ack_ping_for_params, "Params ") \
344 EM(rxrpc_propose_ack_processing_op, "ProcOp ") \
345 EM(rxrpc_propose_ack_respond_to_ack, "Rsp2Ack") \
346 EM(rxrpc_propose_ack_respond_to_ping, "Rsp2Png") \
347 EM(rxrpc_propose_ack_retry_tx, "RetryTx") \
348 EM(rxrpc_propose_ack_rotate_rx, "RxAck ") \
349 E_(rxrpc_propose_ack_terminal_ack, "ClTerm ")
351 #define rxrpc_propose_ack_outcomes \
352 EM(rxrpc_propose_ack_subsume, " Subsume") \
353 EM(rxrpc_propose_ack_update, " Update") \
354 E_(rxrpc_propose_ack_use, "")
356 #define rxrpc_congest_modes \
357 EM(RXRPC_CALL_CONGEST_AVOIDANCE, "CongAvoid") \
358 EM(RXRPC_CALL_FAST_RETRANSMIT, "FastReTx ") \
359 EM(RXRPC_CALL_PACKET_LOSS, "PktLoss ") \
360 E_(RXRPC_CALL_SLOW_START, "SlowStart")
362 #define rxrpc_congest_changes \
363 EM(rxrpc_cong_begin_retransmission, " Retrans") \
364 EM(rxrpc_cong_cleared_nacks, " Cleared") \
365 EM(rxrpc_cong_new_low_nack, " NewLowN") \
366 EM(rxrpc_cong_no_change, "") \
367 EM(rxrpc_cong_progress, " Progres") \
368 EM(rxrpc_cong_retransmit_again, " ReTxAgn") \
369 EM(rxrpc_cong_rtt_window_end, " RttWinE") \
370 E_(rxrpc_cong_saw_nack, " SawNack")
374 EM(RXRPC_PACKET_TYPE_DATA, "DATA") \
375 EM(RXRPC_PACKET_TYPE_ACK, "ACK") \
376 EM(RXRPC_PACKET_TYPE_BUSY, "BUSY") \
377 EM(RXRPC_PACKET_TYPE_ABORT, "ABORT") \
378 EM(RXRPC_PACKET_TYPE_ACKALL, "ACKALL") \
379 EM(RXRPC_PACKET_TYPE_CHALLENGE, "CHALL") \
380 EM(RXRPC_PACKET_TYPE_RESPONSE, "RESP") \
381 EM(RXRPC_PACKET_TYPE_DEBUG, "DEBUG") \
386 EM(RXRPC_PACKET_TYPE_VERSION, "VERSION") \
390 #define rxrpc_ack_names \
392 EM(RXRPC_ACK_REQUESTED, "REQ") \
393 EM(RXRPC_ACK_DUPLICATE, "DUP") \
394 EM(RXRPC_ACK_OUT_OF_SEQUENCE, "OOS") \
395 EM(RXRPC_ACK_EXCEEDS_WINDOW, "WIN") \
396 EM(RXRPC_ACK_NOSPACE, "MEM") \
397 EM(RXRPC_ACK_PING, "PNG") \
398 EM(RXRPC_ACK_PING_RESPONSE, "PNR") \
399 EM(RXRPC_ACK_DELAY, "DLY") \
400 EM(RXRPC_ACK_IDLE, "IDL") \
401 E_(RXRPC_ACK__INVALID, "-?-")
404 * Export enum symbols via userspace.
408 #define EM(a, b) TRACE_DEFINE_ENUM(a);
409 #define E_(a, b) TRACE_DEFINE_ENUM(a);
415 rxrpc_transmit_traces
;
416 rxrpc_receive_traces
;
417 rxrpc_recvmsg_traces
;
421 rxrpc_propose_ack_traces
;
422 rxrpc_propose_ack_outcomes
;
423 rxrpc_congest_changes
;
426 * Now redefine the EM() and E_() macros to map the enums to the strings that
427 * will be printed in the output.
431 #define EM(a, b) { a, b },
432 #define E_(a, b) { a, b }
434 TRACE_EVENT(rxrpc_conn
,
435 TP_PROTO(struct rxrpc_connection
*conn
, enum rxrpc_conn_trace op
,
436 int usage
, const void *where
),
438 TP_ARGS(conn
, op
, usage
, where
),
441 __field(struct rxrpc_connection
*, conn
)
444 __field(const void *, where
)
448 __entry
->conn
= conn
;
450 __entry
->usage
= usage
;
451 __entry
->where
= where
;
454 TP_printk("C=%p %s u=%d sp=%pSR",
456 __print_symbolic(__entry
->op
, rxrpc_conn_traces
),
461 TRACE_EVENT(rxrpc_client
,
462 TP_PROTO(struct rxrpc_connection
*conn
, int channel
,
463 enum rxrpc_client_trace op
),
465 TP_ARGS(conn
, channel
, op
),
468 __field(struct rxrpc_connection
*, conn
)
470 __field(int, channel
)
472 __field(enum rxrpc_client_trace
, op
)
473 __field(enum rxrpc_conn_cache_state
, cs
)
477 __entry
->conn
= conn
;
478 __entry
->channel
= channel
;
479 __entry
->usage
= atomic_read(&conn
->usage
);
481 __entry
->cid
= conn
->proto
.cid
;
482 __entry
->cs
= conn
->cache_state
;
485 TP_printk("C=%p h=%2d %s %s i=%08x u=%d",
488 __print_symbolic(__entry
->op
, rxrpc_client_traces
),
489 __print_symbolic(__entry
->cs
, rxrpc_conn_cache_states
),
494 TRACE_EVENT(rxrpc_call
,
495 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_call_trace op
,
496 int usage
, const void *where
, const void *aux
),
498 TP_ARGS(call
, op
, usage
, where
, aux
),
501 __field(struct rxrpc_call
*, call
)
504 __field(const void *, where
)
505 __field(const void *, aux
)
509 __entry
->call
= call
;
511 __entry
->usage
= usage
;
512 __entry
->where
= where
;
516 TP_printk("c=%p %s u=%d sp=%pSR a=%p",
518 __print_symbolic(__entry
->op
, rxrpc_call_traces
),
524 TRACE_EVENT(rxrpc_skb
,
525 TP_PROTO(struct sk_buff
*skb
, enum rxrpc_skb_trace op
,
526 int usage
, int mod_count
, const void *where
),
528 TP_ARGS(skb
, op
, usage
, mod_count
, where
),
531 __field(struct sk_buff
*, skb
)
532 __field(enum rxrpc_skb_trace
, op
)
534 __field(int, mod_count
)
535 __field(const void *, where
)
541 __entry
->usage
= usage
;
542 __entry
->mod_count
= mod_count
;
543 __entry
->where
= where
;
546 TP_printk("s=%p %s u=%d m=%d p=%pSR",
548 __print_symbolic(__entry
->op
, rxrpc_skb_traces
),
554 TRACE_EVENT(rxrpc_rx_packet
,
555 TP_PROTO(struct rxrpc_skb_priv
*sp
),
560 __field_struct(struct rxrpc_host_header
, hdr
)
564 memcpy(&__entry
->hdr
, &sp
->hdr
, sizeof(__entry
->hdr
));
567 TP_printk("%08x:%08x:%08x:%04x %08x %08x %02x %02x %s",
568 __entry
->hdr
.epoch
, __entry
->hdr
.cid
,
569 __entry
->hdr
.callNumber
, __entry
->hdr
.serviceId
,
570 __entry
->hdr
.serial
, __entry
->hdr
.seq
,
571 __entry
->hdr
.type
, __entry
->hdr
.flags
,
572 __entry
->hdr
.type
<= 15 ?
573 __print_symbolic(__entry
->hdr
.type
, rxrpc_pkts
) : "?UNK")
576 TRACE_EVENT(rxrpc_rx_done
,
577 TP_PROTO(int result
, int abort_code
),
579 TP_ARGS(result
, abort_code
),
582 __field(int, result
)
583 __field(int, abort_code
)
587 __entry
->result
= result
;
588 __entry
->abort_code
= abort_code
;
591 TP_printk("r=%d a=%d", __entry
->result
, __entry
->abort_code
)
594 TRACE_EVENT(rxrpc_abort
,
595 TP_PROTO(const char *why
, u32 cid
, u32 call_id
, rxrpc_seq_t seq
,
596 int abort_code
, int error
),
598 TP_ARGS(why
, cid
, call_id
, seq
, abort_code
, error
),
601 __array(char, why
, 4 )
603 __field(u32
, call_id
)
604 __field(rxrpc_seq_t
, seq
)
605 __field(int, abort_code
)
610 memcpy(__entry
->why
, why
, 4);
612 __entry
->call_id
= call_id
;
613 __entry
->abort_code
= abort_code
;
614 __entry
->error
= error
;
618 TP_printk("%08x:%08x s=%u a=%d e=%d %s",
619 __entry
->cid
, __entry
->call_id
, __entry
->seq
,
620 __entry
->abort_code
, __entry
->error
, __entry
->why
)
623 TRACE_EVENT(rxrpc_transmit
,
624 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_transmit_trace why
),
629 __field(struct rxrpc_call
*, call
)
630 __field(enum rxrpc_transmit_trace
, why
)
631 __field(rxrpc_seq_t
, tx_hard_ack
)
632 __field(rxrpc_seq_t
, tx_top
)
633 __field(int, tx_winsize
)
637 __entry
->call
= call
;
639 __entry
->tx_hard_ack
= call
->tx_hard_ack
;
640 __entry
->tx_top
= call
->tx_top
;
641 __entry
->tx_winsize
= call
->tx_winsize
;
644 TP_printk("c=%p %s f=%08x n=%u/%u",
646 __print_symbolic(__entry
->why
, rxrpc_transmit_traces
),
647 __entry
->tx_hard_ack
+ 1,
648 __entry
->tx_top
- __entry
->tx_hard_ack
,
652 TRACE_EVENT(rxrpc_rx_data
,
653 TP_PROTO(struct rxrpc_call
*call
, rxrpc_seq_t seq
,
654 rxrpc_serial_t serial
, u8 flags
, u8 anno
),
656 TP_ARGS(call
, seq
, serial
, flags
, anno
),
659 __field(struct rxrpc_call
*, call
)
660 __field(rxrpc_seq_t
, seq
)
661 __field(rxrpc_serial_t
, serial
)
667 __entry
->call
= call
;
669 __entry
->serial
= serial
;
670 __entry
->flags
= flags
;
671 __entry
->anno
= anno
;
674 TP_printk("c=%p DATA %08x q=%08x fl=%02x a=%02x",
682 TRACE_EVENT(rxrpc_rx_ack
,
683 TP_PROTO(struct rxrpc_call
*call
,
684 rxrpc_serial_t serial
, rxrpc_serial_t ack_serial
,
685 rxrpc_seq_t first
, rxrpc_seq_t prev
, u8 reason
, u8 n_acks
),
687 TP_ARGS(call
, serial
, ack_serial
, first
, prev
, reason
, n_acks
),
690 __field(struct rxrpc_call
*, call
)
691 __field(rxrpc_serial_t
, serial
)
692 __field(rxrpc_serial_t
, ack_serial
)
693 __field(rxrpc_seq_t
, first
)
694 __field(rxrpc_seq_t
, prev
)
700 __entry
->call
= call
;
701 __entry
->serial
= serial
;
702 __entry
->ack_serial
= ack_serial
;
703 __entry
->first
= first
;
704 __entry
->prev
= prev
;
705 __entry
->reason
= reason
;
706 __entry
->n_acks
= n_acks
;
709 TP_printk("c=%p %08x %s r=%08x f=%08x p=%08x n=%u",
712 __print_symbolic(__entry
->reason
, rxrpc_ack_names
),
719 TRACE_EVENT(rxrpc_rx_abort
,
720 TP_PROTO(struct rxrpc_call
*call
, rxrpc_serial_t serial
,
723 TP_ARGS(call
, serial
, abort_code
),
726 __field(struct rxrpc_call
*, call
)
727 __field(rxrpc_serial_t
, serial
)
728 __field(u32
, abort_code
)
732 __entry
->call
= call
;
733 __entry
->serial
= serial
;
734 __entry
->abort_code
= abort_code
;
737 TP_printk("c=%p ABORT %08x ac=%d",
743 TRACE_EVENT(rxrpc_rx_rwind_change
,
744 TP_PROTO(struct rxrpc_call
*call
, rxrpc_serial_t serial
,
745 u32 rwind
, bool wake
),
747 TP_ARGS(call
, serial
, rwind
, wake
),
750 __field(struct rxrpc_call
*, call
)
751 __field(rxrpc_serial_t
, serial
)
757 __entry
->call
= call
;
758 __entry
->serial
= serial
;
759 __entry
->rwind
= rwind
;
760 __entry
->wake
= wake
;
763 TP_printk("c=%p %08x rw=%u%s",
767 __entry
->wake
? " wake" : "")
770 TRACE_EVENT(rxrpc_tx_data
,
771 TP_PROTO(struct rxrpc_call
*call
, rxrpc_seq_t seq
,
772 rxrpc_serial_t serial
, u8 flags
, bool retrans
, bool lose
),
774 TP_ARGS(call
, seq
, serial
, flags
, retrans
, lose
),
777 __field(struct rxrpc_call
*, call
)
778 __field(rxrpc_seq_t
, seq
)
779 __field(rxrpc_serial_t
, serial
)
781 __field(bool, retrans
)
786 __entry
->call
= call
;
788 __entry
->serial
= serial
;
789 __entry
->flags
= flags
;
790 __entry
->retrans
= retrans
;
791 __entry
->lose
= lose
;
794 TP_printk("c=%p DATA %08x q=%08x fl=%02x%s%s",
799 __entry
->retrans
? " *RETRANS*" : "",
800 __entry
->lose
? " *LOSE*" : "")
803 TRACE_EVENT(rxrpc_tx_ack
,
804 TP_PROTO(struct rxrpc_call
*call
, rxrpc_serial_t serial
,
805 rxrpc_seq_t ack_first
, rxrpc_serial_t ack_serial
,
806 u8 reason
, u8 n_acks
),
808 TP_ARGS(call
, serial
, ack_first
, ack_serial
, reason
, n_acks
),
811 __field(struct rxrpc_call
*, call
)
812 __field(rxrpc_serial_t
, serial
)
813 __field(rxrpc_seq_t
, ack_first
)
814 __field(rxrpc_serial_t
, ack_serial
)
820 __entry
->call
= call
;
821 __entry
->serial
= serial
;
822 __entry
->ack_first
= ack_first
;
823 __entry
->ack_serial
= ack_serial
;
824 __entry
->reason
= reason
;
825 __entry
->n_acks
= n_acks
;
828 TP_printk(" c=%p ACK %08x %s f=%08x r=%08x n=%u",
831 __print_symbolic(__entry
->reason
, rxrpc_ack_names
),
837 TRACE_EVENT(rxrpc_receive
,
838 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_receive_trace why
,
839 rxrpc_serial_t serial
, rxrpc_seq_t seq
),
841 TP_ARGS(call
, why
, serial
, seq
),
844 __field(struct rxrpc_call
*, call
)
845 __field(enum rxrpc_receive_trace
, why
)
846 __field(rxrpc_serial_t
, serial
)
847 __field(rxrpc_seq_t
, seq
)
848 __field(rxrpc_seq_t
, hard_ack
)
849 __field(rxrpc_seq_t
, top
)
853 __entry
->call
= call
;
855 __entry
->serial
= serial
;
857 __entry
->hard_ack
= call
->rx_hard_ack
;
858 __entry
->top
= call
->rx_top
;
861 TP_printk("c=%p %s r=%08x q=%08x w=%08x-%08x",
863 __print_symbolic(__entry
->why
, rxrpc_receive_traces
),
870 TRACE_EVENT(rxrpc_recvmsg
,
871 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_recvmsg_trace why
,
872 rxrpc_seq_t seq
, unsigned int offset
, unsigned int len
,
875 TP_ARGS(call
, why
, seq
, offset
, len
, ret
),
878 __field(struct rxrpc_call
*, call
)
879 __field(enum rxrpc_recvmsg_trace
, why
)
880 __field(rxrpc_seq_t
, seq
)
881 __field(unsigned int, offset
)
882 __field(unsigned int, len
)
887 __entry
->call
= call
;
890 __entry
->offset
= offset
;
895 TP_printk("c=%p %s q=%08x o=%u l=%u ret=%d",
897 __print_symbolic(__entry
->why
, rxrpc_recvmsg_traces
),
904 TRACE_EVENT(rxrpc_rtt_tx
,
905 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_rtt_tx_trace why
,
906 rxrpc_serial_t send_serial
),
908 TP_ARGS(call
, why
, send_serial
),
911 __field(struct rxrpc_call
*, call
)
912 __field(enum rxrpc_rtt_tx_trace
, why
)
913 __field(rxrpc_serial_t
, send_serial
)
917 __entry
->call
= call
;
919 __entry
->send_serial
= send_serial
;
922 TP_printk("c=%p %s sr=%08x",
924 __print_symbolic(__entry
->why
, rxrpc_rtt_tx_traces
),
925 __entry
->send_serial
)
928 TRACE_EVENT(rxrpc_rtt_rx
,
929 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_rtt_rx_trace why
,
930 rxrpc_serial_t send_serial
, rxrpc_serial_t resp_serial
,
931 s64 rtt
, u8 nr
, s64 avg
),
933 TP_ARGS(call
, why
, send_serial
, resp_serial
, rtt
, nr
, avg
),
936 __field(struct rxrpc_call
*, call
)
937 __field(enum rxrpc_rtt_rx_trace
, why
)
939 __field(rxrpc_serial_t
, send_serial
)
940 __field(rxrpc_serial_t
, resp_serial
)
946 __entry
->call
= call
;
948 __entry
->send_serial
= send_serial
;
949 __entry
->resp_serial
= resp_serial
;
955 TP_printk("c=%p %s sr=%08x rr=%08x rtt=%lld nr=%u avg=%lld",
957 __print_symbolic(__entry
->why
, rxrpc_rtt_rx_traces
),
958 __entry
->send_serial
,
959 __entry
->resp_serial
,
965 TRACE_EVENT(rxrpc_timer
,
966 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_timer_trace why
,
969 TP_ARGS(call
, why
, now
),
972 __field(struct rxrpc_call
*, call
)
973 __field(enum rxrpc_timer_trace
, why
)
975 __field(long, ack_at
)
976 __field(long, ack_lost_at
)
977 __field(long, resend_at
)
978 __field(long, ping_at
)
979 __field(long, expect_rx_by
)
980 __field(long, expect_req_by
)
981 __field(long, expect_term_by
)
982 __field(long, timer
)
986 __entry
->call
= call
;
989 __entry
->ack_at
= call
->ack_at
;
990 __entry
->ack_lost_at
= call
->ack_lost_at
;
991 __entry
->resend_at
= call
->resend_at
;
992 __entry
->expect_rx_by
= call
->expect_rx_by
;
993 __entry
->expect_req_by
= call
->expect_req_by
;
994 __entry
->expect_term_by
= call
->expect_term_by
;
995 __entry
->timer
= call
->timer
.expires
;
998 TP_printk("c=%p %s a=%ld la=%ld r=%ld xr=%ld xq=%ld xt=%ld t=%ld",
1000 __print_symbolic(__entry
->why
, rxrpc_timer_traces
),
1001 __entry
->ack_at
- __entry
->now
,
1002 __entry
->ack_lost_at
- __entry
->now
,
1003 __entry
->resend_at
- __entry
->now
,
1004 __entry
->expect_rx_by
- __entry
->now
,
1005 __entry
->expect_req_by
- __entry
->now
,
1006 __entry
->expect_term_by
- __entry
->now
,
1007 __entry
->timer
- __entry
->now
)
1010 TRACE_EVENT(rxrpc_rx_lose
,
1011 TP_PROTO(struct rxrpc_skb_priv
*sp
),
1016 __field_struct(struct rxrpc_host_header
, hdr
)
1020 memcpy(&__entry
->hdr
, &sp
->hdr
, sizeof(__entry
->hdr
));
1023 TP_printk("%08x:%08x:%08x:%04x %08x %08x %02x %02x %s *LOSE*",
1024 __entry
->hdr
.epoch
, __entry
->hdr
.cid
,
1025 __entry
->hdr
.callNumber
, __entry
->hdr
.serviceId
,
1026 __entry
->hdr
.serial
, __entry
->hdr
.seq
,
1027 __entry
->hdr
.type
, __entry
->hdr
.flags
,
1028 __entry
->hdr
.type
<= 15 ?
1029 __print_symbolic(__entry
->hdr
.type
, rxrpc_pkts
) : "?UNK")
1032 TRACE_EVENT(rxrpc_propose_ack
,
1033 TP_PROTO(struct rxrpc_call
*call
, enum rxrpc_propose_ack_trace why
,
1034 u8 ack_reason
, rxrpc_serial_t serial
, bool immediate
,
1035 bool background
, enum rxrpc_propose_ack_outcome outcome
),
1037 TP_ARGS(call
, why
, ack_reason
, serial
, immediate
, background
,
1041 __field(struct rxrpc_call
*, call
)
1042 __field(enum rxrpc_propose_ack_trace
, why
)
1043 __field(rxrpc_serial_t
, serial
)
1044 __field(u8
, ack_reason
)
1045 __field(bool, immediate
)
1046 __field(bool, background
)
1047 __field(enum rxrpc_propose_ack_outcome
, outcome
)
1051 __entry
->call
= call
;
1053 __entry
->serial
= serial
;
1054 __entry
->ack_reason
= ack_reason
;
1055 __entry
->immediate
= immediate
;
1056 __entry
->background
= background
;
1057 __entry
->outcome
= outcome
;
1060 TP_printk("c=%p %s %s r=%08x i=%u b=%u%s",
1062 __print_symbolic(__entry
->why
, rxrpc_propose_ack_traces
),
1063 __print_symbolic(__entry
->ack_reason
, rxrpc_ack_names
),
1066 __entry
->background
,
1067 __print_symbolic(__entry
->outcome
, rxrpc_propose_ack_outcomes
))
1070 TRACE_EVENT(rxrpc_retransmit
,
1071 TP_PROTO(struct rxrpc_call
*call
, rxrpc_seq_t seq
, u8 annotation
,
1074 TP_ARGS(call
, seq
, annotation
, expiry
),
1077 __field(struct rxrpc_call
*, call
)
1078 __field(rxrpc_seq_t
, seq
)
1079 __field(u8
, annotation
)
1080 __field(s64
, expiry
)
1084 __entry
->call
= call
;
1086 __entry
->annotation
= annotation
;
1087 __entry
->expiry
= expiry
;
1090 TP_printk("c=%p q=%x a=%02x xp=%lld",
1093 __entry
->annotation
,
1097 TRACE_EVENT(rxrpc_congest
,
1098 TP_PROTO(struct rxrpc_call
*call
, struct rxrpc_ack_summary
*summary
,
1099 rxrpc_serial_t ack_serial
, enum rxrpc_congest_change change
),
1101 TP_ARGS(call
, summary
, ack_serial
, change
),
1104 __field(struct rxrpc_call
*, call
)
1105 __field(enum rxrpc_congest_change
, change
)
1106 __field(rxrpc_seq_t
, hard_ack
)
1107 __field(rxrpc_seq_t
, top
)
1108 __field(rxrpc_seq_t
, lowest_nak
)
1109 __field(rxrpc_serial_t
, ack_serial
)
1110 __field_struct(struct rxrpc_ack_summary
, sum
)
1114 __entry
->call
= call
;
1115 __entry
->change
= change
;
1116 __entry
->hard_ack
= call
->tx_hard_ack
;
1117 __entry
->top
= call
->tx_top
;
1118 __entry
->lowest_nak
= call
->acks_lowest_nak
;
1119 __entry
->ack_serial
= ack_serial
;
1120 memcpy(&__entry
->sum
, summary
, sizeof(__entry
->sum
));
1123 TP_printk("c=%p r=%08x %s q=%08x %s cw=%u ss=%u nr=%u,%u nw=%u,%u r=%u b=%u u=%u d=%u l=%x%s%s%s",
1125 __entry
->ack_serial
,
1126 __print_symbolic(__entry
->sum
.ack_reason
, rxrpc_ack_names
),
1128 __print_symbolic(__entry
->sum
.mode
, rxrpc_congest_modes
),
1130 __entry
->sum
.ssthresh
,
1131 __entry
->sum
.nr_acks
, __entry
->sum
.nr_nacks
,
1132 __entry
->sum
.nr_new_acks
, __entry
->sum
.nr_new_nacks
,
1133 __entry
->sum
.nr_rot_new_acks
,
1134 __entry
->top
- __entry
->hard_ack
,
1135 __entry
->sum
.cumulative_acks
,
1136 __entry
->sum
.dup_acks
,
1137 __entry
->lowest_nak
, __entry
->sum
.new_low_nack
? "!" : "",
1138 __print_symbolic(__entry
->change
, rxrpc_congest_changes
),
1139 __entry
->sum
.retrans_timeo
? " rTxTo" : "")
1142 TRACE_EVENT(rxrpc_disconnect_call
,
1143 TP_PROTO(struct rxrpc_call
*call
),
1148 __field(struct rxrpc_call
*, call
)
1149 __field(u32
, abort_code
)
1153 __entry
->call
= call
;
1154 __entry
->abort_code
= call
->abort_code
;
1157 TP_printk("c=%p ab=%08x",
1159 __entry
->abort_code
)
1162 TRACE_EVENT(rxrpc_improper_term
,
1163 TP_PROTO(struct rxrpc_call
*call
),
1168 __field(struct rxrpc_call
*, call
)
1169 __field(u32
, abort_code
)
1173 __entry
->call
= call
;
1174 __entry
->abort_code
= call
->abort_code
;
1177 TP_printk("c=%p ab=%08x",
1179 __entry
->abort_code
)
1182 TRACE_EVENT(rxrpc_rx_eproto
,
1183 TP_PROTO(struct rxrpc_call
*call
, rxrpc_serial_t serial
,
1186 TP_ARGS(call
, serial
, why
),
1189 __field(struct rxrpc_call
*, call
)
1190 __field(rxrpc_serial_t
, serial
)
1191 __field(const char *, why
)
1195 __entry
->call
= call
;
1196 __entry
->serial
= serial
;
1200 TP_printk("c=%p EPROTO %08x %s",
1206 TRACE_EVENT(rxrpc_connect_call
,
1207 TP_PROTO(struct rxrpc_call
*call
),
1212 __field(struct rxrpc_call
*, call
)
1213 __field(unsigned long, user_call_ID
)
1215 __field(u32
, call_id
)
1219 __entry
->call
= call
;
1220 __entry
->user_call_ID
= call
->user_call_ID
;
1221 __entry
->cid
= call
->cid
;
1222 __entry
->call_id
= call
->call_id
;
1225 TP_printk("c=%p u=%p %08x:%08x",
1227 (void *)__entry
->user_call_ID
,
1232 #endif /* _TRACE_RXRPC_H */
1234 /* This part must be outside protection */
1235 #include <trace/define_trace.h>