tools/testing/selftests/bpf/prog_tests/mptcp.c

   1 // SPDX-License-Identifier: GPL-2.0
   2 /* Copyright (c) 2020, Tessares SA. */
   3 /* Copyright (c) 2022, SUSE. */
   4
   5 #include <test_progs.h>
   6 #include "cgroup_helpers.h"
   7 #include "network_helpers.h"
   8 #include "mptcp_sock.skel.h"
   9
  10 struct mptcp_storage {
  11         __u32 invoked;
  12         __u32 is_mptcp;
  13 };
  14
  15 static int verify_sk(int map_fd, int client_fd, __u32 is_mptcp)
  16 {
  17         int err, cfd = client_fd;
  18         struct mptcp_storage val;
  19
  20         if (is_mptcp == 1)
  21                 return 0;
  22
  23         err = bpf_map_lookup_elem(map_fd, &cfd, &val);
  24         if (!ASSERT_OK(err, "bpf_map_lookup_elem"))
  25                 return err;
  26
  27         if (!ASSERT_EQ(val.invoked, 1, "unexpected invoked count"))
  28                 err++;
  29
  30         if (!ASSERT_EQ(val.is_mptcp, 0, "unexpected is_mptcp"))
  31                 err++;
  32
  33         return err;
  34 }
  35
  36 static int run_test(int cgroup_fd, int server_fd, bool is_mptcp)
  37 {
  38         int client_fd, prog_fd, map_fd, err;
  39         struct mptcp_sock *sock_skel;
  40
  41         sock_skel = mptcp_sock__open_and_load();
  42         if (!ASSERT_OK_PTR(sock_skel, "skel_open_load"))
  43                 return -EIO;
  44
  45         prog_fd = bpf_program__fd(sock_skel->progs._sockops);
  46         if (!ASSERT_GE(prog_fd, 0, "bpf_program__fd")) {
  47                 err = -EIO;
  48                 goto out;
  49         }
  50
  51         map_fd = bpf_map__fd(sock_skel->maps.socket_storage_map);
  52         if (!ASSERT_GE(map_fd, 0, "bpf_map__fd")) {
  53                 err = -EIO;
  54                 goto out;
  55         }
  56
  57         err = bpf_prog_attach(prog_fd, cgroup_fd, BPF_CGROUP_SOCK_OPS, 0);
  58         if (!ASSERT_OK(err, "bpf_prog_attach"))
  59                 goto out;
  60
  61         client_fd = connect_to_fd(server_fd, 0);
  62         if (!ASSERT_GE(client_fd, 0, "connect to fd")) {
  63                 err = -EIO;
  64                 goto out;
  65         }
  66
  67         err += is_mptcp ? verify_sk(map_fd, client_fd, 1) :
  68                           verify_sk(map_fd, client_fd, 0);
  69
  70         close(client_fd);
  71
  72 out:
  73         mptcp_sock__destroy(sock_skel);
  74         return err;
  75 }
  76
  77 static void test_base(void)
  78 {
  79         int server_fd, cgroup_fd;
  80
  81         cgroup_fd = test__join_cgroup("/mptcp");
  82         if (!ASSERT_GE(cgroup_fd, 0, "test__join_cgroup"))
  83                 return;
  84
  85         /* without MPTCP */
  86         server_fd = start_server(AF_INET, SOCK_STREAM, NULL, 0, 0);
  87         if (!ASSERT_GE(server_fd, 0, "start_server"))
  88                 goto with_mptcp;
  89
  90         ASSERT_OK(run_test(cgroup_fd, server_fd, false), "run_test tcp");
  91
  92         close(server_fd);
  93
  94 with_mptcp:
  95         /* with MPTCP */
  96         server_fd = start_mptcp_server(AF_INET, NULL, 0, 0);
  97         if (!ASSERT_GE(server_fd, 0, "start_mptcp_server"))
  98                 goto close_cgroup_fd;
  99
 100         ASSERT_OK(run_test(cgroup_fd, server_fd, true), "run_test mptcp");
 101
 102         close(server_fd);
 103
 104 close_cgroup_fd:
 105         close(cgroup_fd);
 106 }
 107
 108 void test_mptcp(void)
 109 {
 110         if (test__start_subtest("base"))
 111                 test_base();
 112 }