[mirror_ubuntu-jammy-kernel.git] / include / trace / events / mptcp.h

/* SPDX-License-Identifier: GPL-2.0 */
#undef TRACE_SYSTEM
#define TRACE_SYSTEM mptcp

#if !defined(_TRACE_MPTCP_H) || defined(TRACE_HEADER_MULTI_READ)
#define _TRACE_MPTCP_H

#include <linux/tracepoint.h>

TRACE_EVENT(mptcp_subflow_get_send,

	TP_PROTO(struct mptcp_subflow_context *subflow),

	TP_ARGS(subflow),

	TP_STRUCT__entry(
		__field(bool, active)
		__field(bool, free)
		__field(u32, snd_wnd)
		__field(u32, pace)
		__field(u8, backup)
		__field(u64, ratio)
	),

	TP_fast_assign(
		struct sock *ssk;

		__entry->active = mptcp_subflow_active(subflow);
		__entry->backup = subflow->backup;

		if (subflow->tcp_sock && sk_fullsock(subflow->tcp_sock))
			__entry->free = sk_stream_memory_free(subflow->tcp_sock);
		else
			__entry->free = 0;

		ssk = mptcp_subflow_tcp_sock(subflow);
		if (ssk && sk_fullsock(ssk)) {
			__entry->snd_wnd = tcp_sk(ssk)->snd_wnd;
			__entry->pace = ssk->sk_pacing_rate;
		} else {
			__entry->snd_wnd = 0;
			__entry->pace = 0;
		}

		if (ssk && sk_fullsock(ssk) && __entry->pace)
			__entry->ratio = div_u64((u64)ssk->sk_wmem_queued << 32, __entry->pace);
		else
			__entry->ratio = 0;
	),

	TP_printk("active=%d free=%d snd_wnd=%u pace=%u backup=%u ratio=%llu",
		  __entry->active, __entry->free,
		  __entry->snd_wnd, __entry->pace,
		  __entry->backup, __entry->ratio)
);

DECLARE_EVENT_CLASS(mptcp_dump_mpext,

	TP_PROTO(struct mptcp_ext *mpext),

	TP_ARGS(mpext),

	TP_STRUCT__entry(
		__field(u64, data_ack)
		__field(u64, data_seq)
		__field(u32, subflow_seq)
		__field(u16, data_len)
		__field(u8, use_map)
		__field(u8, dsn64)
		__field(u8, data_fin)
		__field(u8, use_ack)
		__field(u8, ack64)
		__field(u8, mpc_map)
		__field(u8, frozen)
		__field(u8, reset_transient)
		__field(u8, reset_reason)
	),

	TP_fast_assign(
		__entry->data_ack = mpext->ack64 ? mpext->data_ack : mpext->data_ack32;
		__entry->data_seq = mpext->data_seq;
		__entry->subflow_seq = mpext->subflow_seq;
		__entry->data_len = mpext->data_len;
		__entry->use_map = mpext->use_map;
		__entry->dsn64 = mpext->dsn64;
		__entry->data_fin = mpext->data_fin;
		__entry->use_ack = mpext->use_ack;
		__entry->ack64 = mpext->ack64;
		__entry->mpc_map = mpext->mpc_map;
		__entry->frozen = mpext->frozen;
		__entry->reset_transient = mpext->reset_transient;
		__entry->reset_reason = mpext->reset_reason;
	),

	TP_printk("data_ack=%llu data_seq=%llu subflow_seq=%u data_len=%u use_map=%u dsn64=%u data_fin=%u use_ack=%u ack64=%u mpc_map=%u frozen=%u reset_transient=%u reset_reason=%u",
		  __entry->data_ack, __entry->data_seq,
		  __entry->subflow_seq, __entry->data_len,
		  __entry->use_map, __entry->dsn64,
		  __entry->data_fin, __entry->use_ack,
		  __entry->ack64, __entry->mpc_map,
		  __entry->frozen, __entry->reset_transient,
		  __entry->reset_reason)
);

DEFINE_EVENT(mptcp_dump_mpext, get_mapping_status,
	TP_PROTO(struct mptcp_ext *mpext),
	TP_ARGS(mpext));

#endif /* _TRACE_MPTCP_H */

/* This part must be outside protection */
#include <trace/define_trace.h>
Commit	Line	Data
e10a9892 GT	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	TRACE_EVENT(mptcp_subflow_get_send,
	11
	12	TP_PROTO(struct mptcp_subflow_context *subflow),
	13
	14	TP_ARGS(subflow),
	15
	16	TP_STRUCT__entry(
	17	__field(bool, active)
	18	__field(bool, free)
	19	__field(u32, snd_wnd)
	20	__field(u32, pace)
	21	__field(u8, backup)
	22	__field(u64, ratio)
	23	),
	24
	25	TP_fast_assign(
	26	struct sock *ssk;
	27
	28	__entry->active = mptcp_subflow_active(subflow);
	29	__entry->backup = subflow->backup;
	30
	31	if (subflow->tcp_sock && sk_fullsock(subflow->tcp_sock))
	32	__entry->free = sk_stream_memory_free(subflow->tcp_sock);
	33	else
	34	__entry->free = 0;
	35
	36	ssk = mptcp_subflow_tcp_sock(subflow);
	37	if (ssk && sk_fullsock(ssk)) {
	38	__entry->snd_wnd = tcp_sk(ssk)->snd_wnd;
	39	__entry->pace = ssk->sk_pacing_rate;
	40	} else {
	41	__entry->snd_wnd = 0;
	42	__entry->pace = 0;
	43	}
	44
	45	if (ssk && sk_fullsock(ssk) && __entry->pace)
	46	__entry->ratio = div_u64((u64)ssk->sk_wmem_queued << 32, __entry->pace);
	47	else
	48	__entry->ratio = 0;
	49	),
	50
	51	TP_printk("active=%d free=%d snd_wnd=%u pace=%u backup=%u ratio=%llu",
	52	__entry->active, __entry->free,
	53	__entry->snd_wnd, __entry->pace,
	54	__entry->backup, __entry->ratio)
	55	);
	56
0918e34b GT	57	DECLARE_EVENT_CLASS(mptcp_dump_mpext,
	58
	59	TP_PROTO(struct mptcp_ext *mpext),
	60
	61	TP_ARGS(mpext),
	62
	63	TP_STRUCT__entry(
	64	__field(u64, data_ack)
	65	__field(u64, data_seq)
	66	__field(u32, subflow_seq)
	67	__field(u16, data_len)
	68	__field(u8, use_map)
	69	__field(u8, dsn64)
	70	__field(u8, data_fin)
	71	__field(u8, use_ack)
	72	__field(u8, ack64)
	73	__field(u8, mpc_map)
	74	__field(u8, frozen)
	75	__field(u8, reset_transient)
	76	__field(u8, reset_reason)
	77	),
	78
	79	TP_fast_assign(
	80	__entry->data_ack = mpext->ack64 ? mpext->data_ack : mpext->data_ack32;
	81	__entry->data_seq = mpext->data_seq;
	82	__entry->subflow_seq = mpext->subflow_seq;
	83	__entry->data_len = mpext->data_len;
	84	__entry->use_map = mpext->use_map;
	85	__entry->dsn64 = mpext->dsn64;
	86	__entry->data_fin = mpext->data_fin;
	87	__entry->use_ack = mpext->use_ack;
	88	__entry->ack64 = mpext->ack64;
	89	__entry->mpc_map = mpext->mpc_map;
	90	__entry->frozen = mpext->frozen;
	91	__entry->reset_transient = mpext->reset_transient;
	92	__entry->reset_reason = mpext->reset_reason;
	93	),
	94
	95	TP_printk("data_ack=%llu data_seq=%llu subflow_seq=%u data_len=%u use_map=%u dsn64=%u data_fin=%u use_ack=%u ack64=%u mpc_map=%u frozen=%u reset_transient=%u reset_reason=%u",
	96	__entry->data_ack, __entry->data_seq,
	97	__entry->subflow_seq, __entry->data_len,
	98	__entry->use_map, __entry->dsn64,
	99	__entry->data_fin, __entry->use_ack,
	100	__entry->ack64, __entry->mpc_map,
	101	__entry->frozen, __entry->reset_transient,
	102	__entry->reset_reason)
	103	);
	104
	105	DEFINE_EVENT(mptcp_dump_mpext, get_mapping_status,
	106	TP_PROTO(struct mptcp_ext *mpext),
	107	TP_ARGS(mpext));
	108
e10a9892 GT	109	#endif /* _TRACE_MPTCP_H */
	110
	111	/* This part must be outside protection */
	112	#include <trace/define_trace.h>