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
 18TRACE_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;
 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 = 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
 65DECLARE_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
120DEFINE_EVENT(mptcp_dump_mpext, mptcp_sendmsg_frag,
121	TP_PROTO(struct mptcp_ext *mpext),
122	TP_ARGS(mpext));
123
124DEFINE_EVENT(mptcp_dump_mpext, get_mapping_status,
125	TP_PROTO(struct mptcp_ext *mpext),
126	TP_ARGS(mpext));
127
128TRACE_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
160TRACE_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>