1 // SPDX-License-Identifier: GPL-2.0
2 #include <test_progs.h>
4 static void *parallel_map_access(void *arg)
6 int err, map_fd = *(u32 *) arg;
7 int vars[17], i, j, rnd, key = 0;
9 for (i = 0; i < 10000; i++) {
10 err = bpf_map_lookup_elem_flags(map_fd, &key, vars, BPF_F_LOCK);
11 if (CHECK_FAIL(err)) {
12 printf("lookup failed\n");
15 if (CHECK_FAIL(vars[0] != 0)) {
16 printf("lookup #%d var[0]=%d\n", i, vars[0]);
20 for (j = 2; j < 17; j++) {
23 printf("lookup #%d var[1]=%d var[%d]=%d\n",
25 CHECK_FAIL(vars[j] != rnd);
33 void test_map_lock(void)
35 const char *file = "./test_map_lock.o";
36 int prog_fd, map_fd[2], vars[17] = {};
37 pthread_t thread_id[6];
38 struct bpf_object *obj = NULL;
39 int err = 0, key = 0, i;
42 err = bpf_prog_load(file, BPF_PROG_TYPE_CGROUP_SKB, &obj, &prog_fd);
43 if (CHECK_FAIL(err)) {
44 printf("test_map_lock:bpf_prog_load errno %d\n", errno);
47 map_fd[0] = bpf_find_map(__func__, obj, "hash_map");
48 if (CHECK_FAIL(map_fd[0] < 0))
50 map_fd[1] = bpf_find_map(__func__, obj, "array_map");
51 if (CHECK_FAIL(map_fd[1] < 0))
54 bpf_map_update_elem(map_fd[0], &key, vars, BPF_F_LOCK);
56 for (i = 0; i < 4; i++)
57 if (CHECK_FAIL(pthread_create(&thread_id[i], NULL,
58 &spin_lock_thread, &prog_fd)))
60 for (i = 4; i < 6; i++)
61 if (CHECK_FAIL(pthread_create(&thread_id[i], NULL,
65 for (i = 0; i < 4; i++)
66 if (CHECK_FAIL(pthread_join(thread_id[i], &ret) ||
67 ret != (void *)&prog_fd))
69 for (i = 4; i < 6; i++)
70 if (CHECK_FAIL(pthread_join(thread_id[i], &ret) ||
71 ret != (void *)&map_fd[i - 4]))
74 bpf_object__close(obj);