include/trace/events/mptcp.h

   1 /* SPDX-License-Identifier: GPL-2.0 */
   2 #undef TRACE_SYSTEM
   3 #define TRACE_SYSTEM mptcp
   4
   5 #if !defined(_TRACE_MPTCP_H) || defined(TRACE_HEADER_MULTI_READ)
   6 #define _TRACE_MPTCP_H
   7
   8 #include <linux/tracepoint.h>
   9
  10 #define show_mapping_status(status)                                     \
  11         __print_symbolic(status,                                        \
  12                 { 0, "MAPPING_OK" },                                    \
  13                 { 1, "MAPPING_INVALID" },                               \
  14                 { 2, "MAPPING_EMPTY" },                                 \
  15                 { 3, "MAPPING_DATA_FIN" },                              \
  16                 { 4, "MAPPING_DUMMY" })
  17
  18 TRACE_EVENT(mptcp_subflow_get_send,
  19
  20         TP_PROTO(struct mptcp_subflow_context *subflow),
  21
  22         TP_ARGS(subflow),
  23
  24         TP_STRUCT__entry(
  25                 __field(bool, active)
  26                 __field(bool, free)
  27                 __field(u32, snd_wnd)
  28                 __field(u32, pace)
  29                 __field(u8, backup)
  30                 __field(u64, ratio)
  31         ),
  32
  33         TP_fast_assign(
  34                 struct sock *ssk;
  35
  36                 __entry->active = mptcp_subflow_active(subflow);
  37                 __entry->backup = subflow->backup || subflow->request_bkup;
  38
  39                 if (subflow->tcp_sock && sk_fullsock(subflow->tcp_sock))
  40                         __entry->free = sk_stream_memory_free(subflow->tcp_sock);
  41                 else
  42                         __entry->free = 0;
  43
  44                 ssk = mptcp_subflow_tcp_sock(subflow);
  45                 if (ssk && sk_fullsock(ssk)) {
  46                         __entry->snd_wnd = tcp_sk(ssk)->snd_wnd;
  47                         __entry->pace = READ_ONCE(ssk->sk_pacing_rate);
  48                 } else {
  49                         __entry->snd_wnd = 0;
  50                         __entry->pace = 0;
  51                 }
  52
  53                 if (ssk && sk_fullsock(ssk) && __entry->pace)
  54                         __entry->ratio = div_u64((u64)ssk->sk_wmem_queued << 32, __entry->pace);
  55                 else
  56                         __entry->ratio = 0;
  57         ),
  58
  59         TP_printk("active=%d free=%d snd_wnd=%u pace=%u backup=%u ratio=%llu",
  60                   __entry->active, __entry->free,
  61                   __entry->snd_wnd, __entry->pace,
  62                   __entry->backup, __entry->ratio)
  63 );
  64
  65 DECLARE_EVENT_CLASS(mptcp_dump_mpext,
  66
  67         TP_PROTO(struct mptcp_ext *mpext),
  68
  69         TP_ARGS(mpext),
  70
  71         TP_STRUCT__entry(
  72                 __field(u64, data_ack)
  73                 __field(u64, data_seq)
  74                 __field(u32, subflow_seq)
  75                 __field(u16, data_len)
  76                 __field(u16, csum)
  77                 __field(u8, use_map)
  78                 __field(u8, dsn64)
  79                 __field(u8, data_fin)
  80                 __field(u8, use_ack)
  81                 __field(u8, ack64)
  82                 __field(u8, mpc_map)
  83                 __field(u8, frozen)
  84                 __field(u8, reset_transient)
  85                 __field(u8, reset_reason)
  86                 __field(u8, csum_reqd)
  87                 __field(u8, infinite_map)
  88         ),
  89
  90         TP_fast_assign(
  91                 __entry->data_ack = mpext->ack64 ? mpext->data_ack : mpext->data_ack32;
  92                 __entry->data_seq = mpext->data_seq;
  93                 __entry->subflow_seq = mpext->subflow_seq;
  94                 __entry->data_len = mpext->data_len;
  95                 __entry->csum = (__force u16)mpext->csum;
  96                 __entry->use_map = mpext->use_map;
  97                 __entry->dsn64 = mpext->dsn64;
  98                 __entry->data_fin = mpext->data_fin;
  99                 __entry->use_ack = mpext->use_ack;
 100                 __entry->ack64 = mpext->ack64;
 101                 __entry->mpc_map = mpext->mpc_map;
 102                 __entry->frozen = mpext->frozen;
 103                 __entry->reset_transient = mpext->reset_transient;
 104                 __entry->reset_reason = mpext->reset_reason;
 105                 __entry->csum_reqd = mpext->csum_reqd;
 106                 __entry->infinite_map = mpext->infinite_map;
 107         ),
 108
 109         TP_printk("data_ack=%llu data_seq=%llu subflow_seq=%u data_len=%u csum=%x use_map=%u dsn64=%u data_fin=%u use_ack=%u ack64=%u mpc_map=%u frozen=%u reset_transient=%u reset_reason=%u csum_reqd=%u infinite_map=%u",
 110                   __entry->data_ack, __entry->data_seq,
 111                   __entry->subflow_seq, __entry->data_len,
 112                   __entry->csum, __entry->use_map,
 113                   __entry->dsn64, __entry->data_fin,
 114                   __entry->use_ack, __entry->ack64,
 115                   __entry->mpc_map, __entry->frozen,
 116                   __entry->reset_transient, __entry->reset_reason,
 117                   __entry->csum_reqd, __entry->infinite_map)
 118 );
 119
 120 DEFINE_EVENT(mptcp_dump_mpext, mptcp_sendmsg_frag,
 121         TP_PROTO(struct mptcp_ext *mpext),
 122         TP_ARGS(mpext));
 123
 124 DEFINE_EVENT(mptcp_dump_mpext, get_mapping_status,
 125         TP_PROTO(struct mptcp_ext *mpext),
 126         TP_ARGS(mpext));
 127
 128 TRACE_EVENT(ack_update_msk,
 129
 130         TP_PROTO(u64 data_ack, u64 old_snd_una,
 131                  u64 new_snd_una, u64 new_wnd_end,
 132                  u64 msk_wnd_end),
 133
 134         TP_ARGS(data_ack, old_snd_una,
 135                 new_snd_una, new_wnd_end,
 136                 msk_wnd_end),
 137
 138         TP_STRUCT__entry(
 139                 __field(u64, data_ack)
 140                 __field(u64, old_snd_una)
 141                 __field(u64, new_snd_una)
 142                 __field(u64, new_wnd_end)
 143                 __field(u64, msk_wnd_end)
 144         ),
 145
 146         TP_fast_assign(
 147                 __entry->data_ack = data_ack;
 148                 __entry->old_snd_una = old_snd_una;
 149                 __entry->new_snd_una = new_snd_una;
 150                 __entry->new_wnd_end = new_wnd_end;
 151                 __entry->msk_wnd_end = msk_wnd_end;
 152         ),
 153
 154         TP_printk("data_ack=%llu old_snd_una=%llu new_snd_una=%llu new_wnd_end=%llu msk_wnd_end=%llu",
 155                   __entry->data_ack, __entry->old_snd_una,
 156                   __entry->new_snd_una, __entry->new_wnd_end,
 157                   __entry->msk_wnd_end)
 158 );
 159
 160 TRACE_EVENT(subflow_check_data_avail,
 161
 162         TP_PROTO(__u8 status, struct sk_buff *skb),
 163
 164         TP_ARGS(status, skb),
 165
 166         TP_STRUCT__entry(
 167                 __field(u8, status)
 168                 __field(const void *, skb)
 169         ),
 170
 171         TP_fast_assign(
 172                 __entry->status = status;
 173                 __entry->skb = skb;
 174         ),
 175
 176         TP_printk("mapping_status=%s, skb=%p",
 177                   show_mapping_status(__entry->status),
 178                   __entry->skb)
 179 );
 180
 181 #endif /* _TRACE_MPTCP_H */
 182
 183 /* This part must be outside protection */
 184 #include <trace/define_trace.h>