This patch tests a bpf prog that parses/writes a max_delack_ms bpf header option and also bpf_setsockopt its TCP_BPF_DELACK_MAX/TCP_BPF_RTO_MIN accordingly. Signed-off-by: Martin KaFai Lau <kafai@xxxxxx> --- .../bpf/prog_tests/tcp_hdr_options.c | 6 ++-- .../bpf/progs/test_tcp_hdr_options.c | 34 +++++++++++++++++++ 2 files changed, 38 insertions(+), 2 deletions(-) diff --git a/tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c b/tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c index f8daf36783f3..5a58f60d2889 100644 --- a/tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c +++ b/tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c @@ -447,11 +447,13 @@ static void simple_estab(void) struct bpf_link *link; struct sk_fds sk_fds; - exp_passive_estab_in.flags = OPTION_F_MAGIC; + exp_passive_estab_in.flags = OPTION_F_MAGIC | OPTION_F_MAX_DELACK_MS; exp_passive_estab_in.magic = 0xfa; + exp_passive_estab_in.max_delack_ms = 11; - exp_active_estab_in.flags = OPTION_F_MAGIC; + exp_active_estab_in.flags = OPTION_F_MAGIC | OPTION_F_MAX_DELACK_MS; exp_active_estab_in.magic = 0xce; + exp_active_estab_in.max_delack_ms = 22; prepare_out(); diff --git a/tools/testing/selftests/bpf/progs/test_tcp_hdr_options.c b/tools/testing/selftests/bpf/progs/test_tcp_hdr_options.c index 631181bfb4cc..eb3b3c2a21f9 100644 --- a/tools/testing/selftests/bpf/progs/test_tcp_hdr_options.c +++ b/tools/testing/selftests/bpf/progs/test_tcp_hdr_options.c @@ -465,6 +465,24 @@ static __always_inline int handle_write_hdr_opt(struct bpf_sock_ops *skops) return write_nodata_opt(skops); } +static __always_inline int set_delack_max(struct bpf_sock_ops *skops, + __u8 max_delack_ms) +{ + __u32 max_delack_us = max_delack_ms * 1000; + + return bpf_setsockopt(skops, SOL_TCP, TCP_BPF_DELACK_MAX, + &max_delack_us, sizeof(max_delack_us)); +} + +static __always_inline int set_rto_min(struct bpf_sock_ops *skops, + __u8 peer_max_delack_ms) +{ + __u32 min_rto_us = peer_max_delack_ms * 1000; + + return bpf_setsockopt(skops, SOL_TCP, TCP_BPF_RTO_MIN, &min_rto_us, + sizeof(min_rto_us)); +} + static __always_inline int handle_active_estab(struct bpf_sock_ops *skops) { __u8 bpf_hdr_opt_off = skops->skb_bpf_hdr_opt_off; @@ -505,6 +523,14 @@ static __always_inline int handle_active_estab(struct bpf_sock_ops *skops) /* No options will be written from now */ clear_hdr_cb_flags(skops); + if (active_syn_out.max_delack_ms && + set_delack_max(skops, active_syn_out.max_delack_ms)) + RET_CG_ERR(skops); + + if (active_estab_in.max_delack_ms && + set_rto_min(skops, active_estab_in.max_delack_ms)) + RET_CG_ERR(skops); + return CG_OK; } @@ -590,6 +616,14 @@ static __always_inline int handle_passive_estab(struct bpf_sock_ops *skops) /* No options will be written from now */ clear_hdr_cb_flags(skops); + if (passive_synack_out.max_delack_ms && + set_delack_max(skops, passive_synack_out.max_delack_ms)) + RET_CG_ERR(skops); + + if (passive_estab_in.max_delack_ms && + set_rto_min(skops, passive_estab_in.max_delack_ms)) + RET_CG_ERR(skops); + return CG_OK; } -- 2.24.1