Orange Pi5 kernel

^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  1) // SPDX-License-Identifier: GPL-2.0
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  2) /* Refer to samples/bpf/tcp_bpf.readme for the instructions on
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  3)  * how to run this sample program.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  4)  */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  5) #include <linux/bpf.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  6) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  7) #include <bpf/bpf_helpers.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  8) #include <bpf/bpf_endian.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300  9) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #define INTERVAL			1000000000ULL
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) int _version SEC("version") = 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) char _license[] SEC("license") = "GPL";
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) struct {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) 	__u32 type;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) 	__u32 map_flags;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18) 	int *key;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) 	__u64 *value;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) } bpf_next_dump SEC(".maps") = {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) 	.type = BPF_MAP_TYPE_SK_STORAGE,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) 	.map_flags = BPF_F_NO_PREALLOC,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) SEC("sockops")
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) int _sockops(struct bpf_sock_ops *ctx)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28) 	struct bpf_tcp_sock *tcp_sk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) 	struct bpf_sock *sk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) 	__u64 *next_dump;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) 	__u64 now;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) 	switch (ctx->op) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) 	case BPF_SOCK_OPS_TCP_CONNECT_CB:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) 		bpf_sock_ops_cb_flags_set(ctx, BPF_SOCK_OPS_RTT_CB_FLAG);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) 		return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) 	case BPF_SOCK_OPS_RTT_CB:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) 		break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) 	default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) 		return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41) 	}
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) 	sk = ctx->sk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) 	if (!sk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) 		return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47) 	next_dump = bpf_sk_storage_get(&bpf_next_dump, sk, 0,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) 				       BPF_SK_STORAGE_GET_F_CREATE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) 	if (!next_dump)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) 		return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) 	now = bpf_ktime_get_ns();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) 	if (now < *next_dump)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) 		return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) 	tcp_sk = bpf_tcp_sock(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) 	if (!tcp_sk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) 		return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) 	*next_dump = now + INTERVAL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) 	bpf_printk("dsack_dups=%u delivered=%u\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) 		   tcp_sk->dsack_dups, tcp_sk->delivered);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) 	bpf_printk("delivered_ce=%u icsk_retransmits=%u\n",
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) 		   tcp_sk->delivered_ce, tcp_sk->icsk_retransmits);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) 
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) 	return 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) }