Add a test case to exercise kptrs behavior against sk_buff structs
stored in eBPF map.
Let us have two programs, one for store and other for retrieving
sk_buffs from pinned map. Load first prog and run as many times as size
of map so that second program will see the map full and will be able to
retrieve each of sk_buff that bpf_prog_test_run_skb() created for us.
Reason for running the progs MAX_ENTRIES times from user space instead
of utilizing @repeat argument of is that we would like to have unique
skbs handled in map. With @repeat usage it would result in storing the
same skb.
Signed-off-by: Maciej Fijalkowski <maciej.fijalkowski@xxxxxxxxx>
---
.../selftests/bpf/prog_tests/skb_map_kptrs.c | 75 ++++++++++++++++++
.../selftests/bpf/progs/skb_map_kptrs.c | 77 +++++++++++++++++++
2 files changed, 152 insertions(+)
create mode 100644 tools/testing/selftests/bpf/prog_tests/skb_map_kptrs.c
create mode 100644 tools/testing/selftests/bpf/progs/skb_map_kptrs.c
diff --git a/tools/testing/selftests/bpf/prog_tests/skb_map_kptrs.c b/tools/testing/selftests/bpf/prog_tests/skb_map_kptrs.c
new file mode 100644
index 000000000000..993beac6c344
--- /dev/null
+++ b/tools/testing/selftests/bpf/prog_tests/skb_map_kptrs.c
@@ -0,0 +1,75 @@
+// SPDX-License-Identifier: GPL-2.0
+#include <test_progs.h>
+
+#define SKB_KPTR_MAP_PATH "/sys/fs/bpf/skb_kptr_map"
+
+static void skb_map_kptrs(void)
+{
+ int err, prog_fd, store_fd, get_fd, map_fd;
+ struct bpf_program *prog;
+ struct bpf_object *obj;
+ char buff[128] = {};
+ struct bpf_map *map;
+ int i;
+ LIBBPF_OPTS(bpf_test_run_opts, topts,
+ .data_in = buff,
+ .data_size_in = sizeof(buff),
+ .repeat = 1,
+ );
+
+ err = bpf_prog_test_load("skb_map_kptrs.bpf.o", BPF_PROG_TYPE_SCHED_CLS, &obj,
+ &prog_fd);
+ if (CHECK_FAIL(err))
+ return;
+
+ map = bpf_object__find_map_by_name(obj, "skb_map");
+ if (CHECK_FAIL(!map))
+ goto map_err;
+
+ map_fd = bpf_map__fd(map);
+ if (map_fd < 0)
+ goto map_err;
+
+ err = bpf_obj_pin(map_fd, SKB_KPTR_MAP_PATH);
+ if (err < 0)
+ goto map_err;
+
+ prog = bpf_object__find_program_by_name(obj, "tc_skb_map_store");
+ if (CHECK_FAIL(!prog))
+ goto out;
+
+ store_fd = bpf_program__fd(prog);
+ if (CHECK_FAIL(store_fd < 0))
+ goto out;
+
+ // store skbs
+ for (i = 0; i < bpf_map__max_entries(map); i++) {
+ err = bpf_prog_test_run_opts(store_fd, &topts);
+ ASSERT_OK(err, "skb kptr store");
+ }
+
+ prog = bpf_object__find_program_by_name(obj, "tc_skb_map_get");
+ if (CHECK_FAIL(!prog))
+ goto out;
+
+ get_fd = bpf_program__fd(prog);
+ if (CHECK_FAIL(get_fd < 0))
+ goto out;
+
+ // get skbs
+ for (i = 0; i < bpf_map__max_entries(map); i++) {
+ err = bpf_prog_test_run_opts(get_fd, &topts);
+ ASSERT_OK(err, "skb kptr get");
+ }
+
+out:
+ unlink(SKB_KPTR_MAP_PATH);
+map_err:
+ bpf_object__close(obj);
+}
+
+void test_skb_map_kptrs(void)
+{
+ skb_map_kptrs();
+}
+
diff --git a/tools/testing/selftests/bpf/progs/skb_map_kptrs.c b/tools/testing/selftests/bpf/progs/skb_map_kptrs.c
new file mode 100644
index 000000000000..f4972978cb04
--- /dev/null
+++ b/tools/testing/selftests/bpf/progs/skb_map_kptrs.c
@@ -0,0 +1,77 @@
+// SPDX-License-Identifier: GPL-2.0
+#include "vmlinux.h"
+#include <bpf/bpf_helpers.h>
+
+void *bpf_cast_to_kern_ctx(void *) __ksym;
+struct sk_buff *bpf_skb_acquire(struct sk_buff *skb) __ksym;
+void bpf_skb_release(struct sk_buff *skb) __ksym;
+
+struct skb_map_val {
+ struct sk_buff __kptr * skb;
+};
+
+static __u32 get_idx;
+static __u32 store_idx;
+
+#define MAX_ENTRIES 100
+
+struct {
+ __uint(type, BPF_MAP_TYPE_ARRAY);
+ __type(key, __u32);
+ __type(value, struct skb_map_val);
+ __uint(max_entries, MAX_ENTRIES);
+} skb_map SEC(".maps");
+
+static __always_inline __u32 idx_bump(__u32 idx)
+{
+ return idx >= MAX_ENTRIES ? 0 : idx + 1;
+}
+
+SEC("tc") int tc_skb_map_store(struct __sk_buff *ctx)
+{
+ struct sk_buff *skbk = bpf_cast_to_kern_ctx(ctx);
+ struct skb_map_val *map_entry, tmp_entry;
+ struct sk_buff *tmp;
+
+ tmp_entry.skb = NULL;
+ bpf_map_update_elem(&skb_map, &store_idx, &tmp_entry, BPF_ANY);
+ map_entry = bpf_map_lookup_elem(&skb_map, &store_idx);
+ if (!map_entry)
+ return -1;
+
+ skbk = bpf_skb_acquire(skbk);
+ if (!skbk)
+ return -2;
+
+ tmp = bpf_kptr_xchg(&map_entry->skb, skbk);
+ if (tmp)
+ bpf_skb_release(tmp);
+
+ store_idx = idx_bump(store_idx);
+
+ return 0;
+}
+
+SEC("tc") int tc_skb_map_get(struct __sk_buff *ctx)
+{
+ struct sk_buff *stored_skb = NULL;
+ struct skb_map_val *map_entry;
+ struct sk_buff *tmp = NULL;
+
+ (void)ctx;
+
+ map_entry = bpf_map_lookup_elem(&skb_map, &get_idx);
+ if (!map_entry)
+ return -1;
+
+ stored_skb = bpf_kptr_xchg(&map_entry->skb, tmp);
+ if (!stored_skb)
+ return -2;
+
+ bpf_skb_release(stored_skb);
+ get_idx = idx_bump(get_idx);
+
+ return 0;
+}
+
+char _license[] SEC("license") = "GPL";
--
2.43.0
