]> git.proxmox.com Git - mirror_ubuntu-hirsute-kernel.git/blame - kernel/bpf/arraymap.c
bpf: Move bpf_free_used_maps into sleepable section
[mirror_ubuntu-hirsute-kernel.git] / kernel / bpf / arraymap.c
CommitLineData
5b497af4 1// SPDX-License-Identifier: GPL-2.0-only
28fbcfa0 2/* Copyright (c) 2011-2014 PLUMgrid, http://plumgrid.com
81ed18ab 3 * Copyright (c) 2016,2017 Facebook
28fbcfa0
AS
4 */
5#include <linux/bpf.h>
a26ca7c9 6#include <linux/btf.h>
28fbcfa0 7#include <linux/err.h>
28fbcfa0
AS
8#include <linux/slab.h>
9#include <linux/mm.h>
04fd61ab 10#include <linux/filter.h>
0cdf5640 11#include <linux/perf_event.h>
a26ca7c9 12#include <uapi/linux/btf.h>
28fbcfa0 13
56f668df
MKL
14#include "map_in_map.h"
15
6e71b04a 16#define ARRAY_CREATE_FLAG_MASK \
fc970227 17 (BPF_F_NUMA_NODE | BPF_F_MMAPABLE | BPF_F_ACCESS_MASK)
6e71b04a 18
a10423b8
AS
19static void bpf_array_free_percpu(struct bpf_array *array)
20{
21 int i;
22
32fff239 23 for (i = 0; i < array->map.max_entries; i++) {
a10423b8 24 free_percpu(array->pptrs[i]);
32fff239
ED
25 cond_resched();
26 }
a10423b8
AS
27}
28
29static int bpf_array_alloc_percpu(struct bpf_array *array)
30{
31 void __percpu *ptr;
32 int i;
33
34 for (i = 0; i < array->map.max_entries; i++) {
35 ptr = __alloc_percpu_gfp(array->elem_size, 8,
36 GFP_USER | __GFP_NOWARN);
37 if (!ptr) {
38 bpf_array_free_percpu(array);
39 return -ENOMEM;
40 }
41 array->pptrs[i] = ptr;
32fff239 42 cond_resched();
a10423b8
AS
43 }
44
45 return 0;
46}
47
28fbcfa0 48/* Called from syscall */
5dc4c4b7 49int array_map_alloc_check(union bpf_attr *attr)
28fbcfa0 50{
a10423b8 51 bool percpu = attr->map_type == BPF_MAP_TYPE_PERCPU_ARRAY;
96eabe7a 52 int numa_node = bpf_map_attr_numa_node(attr);
28fbcfa0
AS
53
54 /* check sanity of attributes */
55 if (attr->max_entries == 0 || attr->key_size != 4 ||
6e71b04a
CF
56 attr->value_size == 0 ||
57 attr->map_flags & ~ARRAY_CREATE_FLAG_MASK ||
591fe988 58 !bpf_map_flags_access_ok(attr->map_flags) ||
96eabe7a 59 (percpu && numa_node != NUMA_NO_NODE))
ad46061f 60 return -EINVAL;
28fbcfa0 61
fc970227
AN
62 if (attr->map_type != BPF_MAP_TYPE_ARRAY &&
63 attr->map_flags & BPF_F_MMAPABLE)
64 return -EINVAL;
65
7984c27c 66 if (attr->value_size > KMALLOC_MAX_SIZE)
01b3f521
AS
67 /* if value_size is bigger, the user space won't be able to
68 * access the elements.
69 */
ad46061f
JK
70 return -E2BIG;
71
72 return 0;
73}
74
75static struct bpf_map *array_map_alloc(union bpf_attr *attr)
76{
77 bool percpu = attr->map_type == BPF_MAP_TYPE_PERCPU_ARRAY;
9c2d63b8 78 int ret, numa_node = bpf_map_attr_numa_node(attr);
ad46061f
JK
79 u32 elem_size, index_mask, max_entries;
80 bool unpriv = !capable(CAP_SYS_ADMIN);
9c2d63b8 81 u64 cost, array_size, mask64;
b936ca64 82 struct bpf_map_memory mem;
ad46061f 83 struct bpf_array *array;
01b3f521 84
28fbcfa0
AS
85 elem_size = round_up(attr->value_size, 8);
86
b2157399 87 max_entries = attr->max_entries;
b2157399 88
bbeb6e43
DB
89 /* On 32 bit archs roundup_pow_of_two() with max_entries that has
90 * upper most bit set in u32 space is undefined behavior due to
91 * resulting 1U << 32, so do it manually here in u64 space.
92 */
93 mask64 = fls_long(max_entries - 1);
94 mask64 = 1ULL << mask64;
95 mask64 -= 1;
96
97 index_mask = mask64;
98 if (unpriv) {
b2157399
AS
99 /* round up array size to nearest power of 2,
100 * since cpu will speculate within index_mask limits
101 */
102 max_entries = index_mask + 1;
bbeb6e43
DB
103 /* Check for overflows. */
104 if (max_entries < attr->max_entries)
105 return ERR_PTR(-E2BIG);
106 }
b2157399 107
a10423b8 108 array_size = sizeof(*array);
fc970227 109 if (percpu) {
b2157399 110 array_size += (u64) max_entries * sizeof(void *);
fc970227
AN
111 } else {
112 /* rely on vmalloc() to return page-aligned memory and
113 * ensure array->value is exactly page-aligned
114 */
115 if (attr->map_flags & BPF_F_MMAPABLE) {
116 array_size = PAGE_ALIGN(array_size);
117 array_size += PAGE_ALIGN((u64) max_entries * elem_size);
118 } else {
119 array_size += (u64) max_entries * elem_size;
120 }
121 }
a10423b8
AS
122
123 /* make sure there is no u32 overflow later in round_up() */
9c2d63b8 124 cost = array_size;
c85d6913 125 if (percpu)
9c2d63b8 126 cost += (u64)attr->max_entries * elem_size * num_possible_cpus();
9c2d63b8 127
b936ca64 128 ret = bpf_map_charge_init(&mem, cost);
9c2d63b8
DB
129 if (ret < 0)
130 return ERR_PTR(ret);
daaf427c 131
28fbcfa0 132 /* allocate all map elements and zero-initialize them */
fc970227
AN
133 if (attr->map_flags & BPF_F_MMAPABLE) {
134 void *data;
135
136 /* kmalloc'ed memory can't be mmap'ed, use explicit vmalloc */
137 data = bpf_map_area_mmapable_alloc(array_size, numa_node);
138 if (!data) {
139 bpf_map_charge_finish(&mem);
140 return ERR_PTR(-ENOMEM);
141 }
142 array = data + PAGE_ALIGN(sizeof(struct bpf_array))
143 - offsetof(struct bpf_array, value);
144 } else {
145 array = bpf_map_area_alloc(array_size, numa_node);
146 }
b936ca64
RG
147 if (!array) {
148 bpf_map_charge_finish(&mem);
d407bd25 149 return ERR_PTR(-ENOMEM);
b936ca64 150 }
b2157399
AS
151 array->index_mask = index_mask;
152 array->map.unpriv_array = unpriv;
28fbcfa0
AS
153
154 /* copy mandatory map attributes */
32852649 155 bpf_map_init_from_attr(&array->map, attr);
b936ca64 156 bpf_map_charge_move(&array->map.memory, &mem);
28fbcfa0
AS
157 array->elem_size = elem_size;
158
9c2d63b8 159 if (percpu && bpf_array_alloc_percpu(array)) {
b936ca64 160 bpf_map_charge_finish(&array->map.memory);
d407bd25 161 bpf_map_area_free(array);
a10423b8
AS
162 return ERR_PTR(-ENOMEM);
163 }
a10423b8 164
28fbcfa0 165 return &array->map;
28fbcfa0
AS
166}
167
168/* Called from syscall or from eBPF program */
169static void *array_map_lookup_elem(struct bpf_map *map, void *key)
170{
171 struct bpf_array *array = container_of(map, struct bpf_array, map);
172 u32 index = *(u32 *)key;
173
a10423b8 174 if (unlikely(index >= array->map.max_entries))
28fbcfa0
AS
175 return NULL;
176
b2157399 177 return array->value + array->elem_size * (index & array->index_mask);
28fbcfa0
AS
178}
179
d8eca5bb
DB
180static int array_map_direct_value_addr(const struct bpf_map *map, u64 *imm,
181 u32 off)
182{
183 struct bpf_array *array = container_of(map, struct bpf_array, map);
184
185 if (map->max_entries != 1)
186 return -ENOTSUPP;
187 if (off >= map->value_size)
188 return -EINVAL;
189
190 *imm = (unsigned long)array->value;
191 return 0;
192}
193
194static int array_map_direct_value_meta(const struct bpf_map *map, u64 imm,
195 u32 *off)
196{
197 struct bpf_array *array = container_of(map, struct bpf_array, map);
198 u64 base = (unsigned long)array->value;
199 u64 range = array->elem_size;
200
201 if (map->max_entries != 1)
202 return -ENOTSUPP;
203 if (imm < base || imm >= base + range)
204 return -ENOENT;
205
206 *off = imm - base;
207 return 0;
208}
209
81ed18ab
AS
210/* emit BPF instructions equivalent to C code of array_map_lookup_elem() */
211static u32 array_map_gen_lookup(struct bpf_map *map, struct bpf_insn *insn_buf)
212{
b2157399 213 struct bpf_array *array = container_of(map, struct bpf_array, map);
81ed18ab 214 struct bpf_insn *insn = insn_buf;
fad73a1a 215 u32 elem_size = round_up(map->value_size, 8);
81ed18ab
AS
216 const int ret = BPF_REG_0;
217 const int map_ptr = BPF_REG_1;
218 const int index = BPF_REG_2;
219
220 *insn++ = BPF_ALU64_IMM(BPF_ADD, map_ptr, offsetof(struct bpf_array, value));
221 *insn++ = BPF_LDX_MEM(BPF_W, ret, index, 0);
b2157399
AS
222 if (map->unpriv_array) {
223 *insn++ = BPF_JMP_IMM(BPF_JGE, ret, map->max_entries, 4);
224 *insn++ = BPF_ALU32_IMM(BPF_AND, ret, array->index_mask);
225 } else {
226 *insn++ = BPF_JMP_IMM(BPF_JGE, ret, map->max_entries, 3);
227 }
fad73a1a
MKL
228
229 if (is_power_of_2(elem_size)) {
81ed18ab
AS
230 *insn++ = BPF_ALU64_IMM(BPF_LSH, ret, ilog2(elem_size));
231 } else {
232 *insn++ = BPF_ALU64_IMM(BPF_MUL, ret, elem_size);
233 }
234 *insn++ = BPF_ALU64_REG(BPF_ADD, ret, map_ptr);
235 *insn++ = BPF_JMP_IMM(BPF_JA, 0, 0, 1);
236 *insn++ = BPF_MOV64_IMM(ret, 0);
237 return insn - insn_buf;
238}
239
a10423b8
AS
240/* Called from eBPF program */
241static void *percpu_array_map_lookup_elem(struct bpf_map *map, void *key)
242{
243 struct bpf_array *array = container_of(map, struct bpf_array, map);
244 u32 index = *(u32 *)key;
245
246 if (unlikely(index >= array->map.max_entries))
247 return NULL;
248
b2157399 249 return this_cpu_ptr(array->pptrs[index & array->index_mask]);
a10423b8
AS
250}
251
15a07b33
AS
252int bpf_percpu_array_copy(struct bpf_map *map, void *key, void *value)
253{
254 struct bpf_array *array = container_of(map, struct bpf_array, map);
255 u32 index = *(u32 *)key;
256 void __percpu *pptr;
257 int cpu, off = 0;
258 u32 size;
259
260 if (unlikely(index >= array->map.max_entries))
261 return -ENOENT;
262
263 /* per_cpu areas are zero-filled and bpf programs can only
264 * access 'value_size' of them, so copying rounded areas
265 * will not leak any kernel data
266 */
267 size = round_up(map->value_size, 8);
268 rcu_read_lock();
b2157399 269 pptr = array->pptrs[index & array->index_mask];
15a07b33
AS
270 for_each_possible_cpu(cpu) {
271 bpf_long_memcpy(value + off, per_cpu_ptr(pptr, cpu), size);
272 off += size;
273 }
274 rcu_read_unlock();
275 return 0;
276}
277
28fbcfa0
AS
278/* Called from syscall */
279static int array_map_get_next_key(struct bpf_map *map, void *key, void *next_key)
280{
281 struct bpf_array *array = container_of(map, struct bpf_array, map);
8fe45924 282 u32 index = key ? *(u32 *)key : U32_MAX;
28fbcfa0
AS
283 u32 *next = (u32 *)next_key;
284
285 if (index >= array->map.max_entries) {
286 *next = 0;
287 return 0;
288 }
289
290 if (index == array->map.max_entries - 1)
291 return -ENOENT;
292
293 *next = index + 1;
294 return 0;
295}
296
297/* Called from syscall or from eBPF program */
298static int array_map_update_elem(struct bpf_map *map, void *key, void *value,
299 u64 map_flags)
300{
301 struct bpf_array *array = container_of(map, struct bpf_array, map);
302 u32 index = *(u32 *)key;
96049f3a 303 char *val;
28fbcfa0 304
96049f3a 305 if (unlikely((map_flags & ~BPF_F_LOCK) > BPF_EXIST))
28fbcfa0
AS
306 /* unknown flags */
307 return -EINVAL;
308
a10423b8 309 if (unlikely(index >= array->map.max_entries))
28fbcfa0
AS
310 /* all elements were pre-allocated, cannot insert a new one */
311 return -E2BIG;
312
96049f3a 313 if (unlikely(map_flags & BPF_NOEXIST))
daaf427c 314 /* all elements already exist */
28fbcfa0
AS
315 return -EEXIST;
316
96049f3a
AS
317 if (unlikely((map_flags & BPF_F_LOCK) &&
318 !map_value_has_spin_lock(map)))
319 return -EINVAL;
320
321 if (array->map.map_type == BPF_MAP_TYPE_PERCPU_ARRAY) {
b2157399 322 memcpy(this_cpu_ptr(array->pptrs[index & array->index_mask]),
a10423b8 323 value, map->value_size);
96049f3a
AS
324 } else {
325 val = array->value +
326 array->elem_size * (index & array->index_mask);
327 if (map_flags & BPF_F_LOCK)
328 copy_map_value_locked(map, val, value, false);
329 else
330 copy_map_value(map, val, value);
331 }
28fbcfa0
AS
332 return 0;
333}
334
15a07b33
AS
335int bpf_percpu_array_update(struct bpf_map *map, void *key, void *value,
336 u64 map_flags)
337{
338 struct bpf_array *array = container_of(map, struct bpf_array, map);
339 u32 index = *(u32 *)key;
340 void __percpu *pptr;
341 int cpu, off = 0;
342 u32 size;
343
344 if (unlikely(map_flags > BPF_EXIST))
345 /* unknown flags */
346 return -EINVAL;
347
348 if (unlikely(index >= array->map.max_entries))
349 /* all elements were pre-allocated, cannot insert a new one */
350 return -E2BIG;
351
352 if (unlikely(map_flags == BPF_NOEXIST))
353 /* all elements already exist */
354 return -EEXIST;
355
356 /* the user space will provide round_up(value_size, 8) bytes that
357 * will be copied into per-cpu area. bpf programs can only access
358 * value_size of it. During lookup the same extra bytes will be
359 * returned or zeros which were zero-filled by percpu_alloc,
360 * so no kernel data leaks possible
361 */
362 size = round_up(map->value_size, 8);
363 rcu_read_lock();
b2157399 364 pptr = array->pptrs[index & array->index_mask];
15a07b33
AS
365 for_each_possible_cpu(cpu) {
366 bpf_long_memcpy(per_cpu_ptr(pptr, cpu), value + off, size);
367 off += size;
368 }
369 rcu_read_unlock();
370 return 0;
371}
372
28fbcfa0
AS
373/* Called from syscall or from eBPF program */
374static int array_map_delete_elem(struct bpf_map *map, void *key)
375{
376 return -EINVAL;
377}
378
fc970227
AN
379static void *array_map_vmalloc_addr(struct bpf_array *array)
380{
381 return (void *)round_down((unsigned long)array, PAGE_SIZE);
382}
383
28fbcfa0
AS
384/* Called when map->refcnt goes to zero, either from workqueue or from syscall */
385static void array_map_free(struct bpf_map *map)
386{
387 struct bpf_array *array = container_of(map, struct bpf_array, map);
388
389 /* at this point bpf_prog->aux->refcnt == 0 and this map->refcnt == 0,
390 * so the programs (can be more than one that used this map) were
391 * disconnected from events. Wait for outstanding programs to complete
392 * and free the array
393 */
394 synchronize_rcu();
395
a10423b8
AS
396 if (array->map.map_type == BPF_MAP_TYPE_PERCPU_ARRAY)
397 bpf_array_free_percpu(array);
398
fc970227
AN
399 if (array->map.map_flags & BPF_F_MMAPABLE)
400 bpf_map_area_free(array_map_vmalloc_addr(array));
401 else
402 bpf_map_area_free(array);
28fbcfa0
AS
403}
404
a26ca7c9
MKL
405static void array_map_seq_show_elem(struct bpf_map *map, void *key,
406 struct seq_file *m)
407{
408 void *value;
409
410 rcu_read_lock();
411
412 value = array_map_lookup_elem(map, key);
413 if (!value) {
414 rcu_read_unlock();
415 return;
416 }
417
2824ecb7
DB
418 if (map->btf_key_type_id)
419 seq_printf(m, "%u: ", *(u32 *)key);
9b2cf328 420 btf_type_seq_show(map->btf, map->btf_value_type_id, value, m);
a26ca7c9
MKL
421 seq_puts(m, "\n");
422
423 rcu_read_unlock();
424}
425
c7b27c37
YS
426static void percpu_array_map_seq_show_elem(struct bpf_map *map, void *key,
427 struct seq_file *m)
428{
429 struct bpf_array *array = container_of(map, struct bpf_array, map);
430 u32 index = *(u32 *)key;
431 void __percpu *pptr;
432 int cpu;
433
434 rcu_read_lock();
435
436 seq_printf(m, "%u: {\n", *(u32 *)key);
437 pptr = array->pptrs[index & array->index_mask];
438 for_each_possible_cpu(cpu) {
439 seq_printf(m, "\tcpu%d: ", cpu);
440 btf_type_seq_show(map->btf, map->btf_value_type_id,
441 per_cpu_ptr(pptr, cpu), m);
442 seq_puts(m, "\n");
443 }
444 seq_puts(m, "}\n");
445
446 rcu_read_unlock();
447}
448
e8d2bec0 449static int array_map_check_btf(const struct bpf_map *map,
1b2b234b 450 const struct btf *btf,
e8d2bec0
DB
451 const struct btf_type *key_type,
452 const struct btf_type *value_type)
a26ca7c9 453{
a26ca7c9
MKL
454 u32 int_data;
455
2824ecb7
DB
456 /* One exception for keyless BTF: .bss/.data/.rodata map */
457 if (btf_type_is_void(key_type)) {
458 if (map->map_type != BPF_MAP_TYPE_ARRAY ||
459 map->max_entries != 1)
460 return -EINVAL;
461
462 if (BTF_INFO_KIND(value_type->info) != BTF_KIND_DATASEC)
463 return -EINVAL;
464
465 return 0;
466 }
467
e8d2bec0 468 if (BTF_INFO_KIND(key_type->info) != BTF_KIND_INT)
a26ca7c9
MKL
469 return -EINVAL;
470
471 int_data = *(u32 *)(key_type + 1);
e8d2bec0
DB
472 /* bpf array can only take a u32 key. This check makes sure
473 * that the btf matches the attr used during map_create.
a26ca7c9 474 */
e8d2bec0 475 if (BTF_INT_BITS(int_data) != 32 || BTF_INT_OFFSET(int_data))
a26ca7c9
MKL
476 return -EINVAL;
477
478 return 0;
479}
480
b2e2f0e6 481static int array_map_mmap(struct bpf_map *map, struct vm_area_struct *vma)
fc970227
AN
482{
483 struct bpf_array *array = container_of(map, struct bpf_array, map);
484 pgoff_t pgoff = PAGE_ALIGN(sizeof(*array)) >> PAGE_SHIFT;
485
486 if (!(map->map_flags & BPF_F_MMAPABLE))
487 return -EINVAL;
488
489 return remap_vmalloc_range(vma, array_map_vmalloc_addr(array), pgoff);
490}
491
40077e0c 492const struct bpf_map_ops array_map_ops = {
ad46061f 493 .map_alloc_check = array_map_alloc_check,
28fbcfa0
AS
494 .map_alloc = array_map_alloc,
495 .map_free = array_map_free,
496 .map_get_next_key = array_map_get_next_key,
497 .map_lookup_elem = array_map_lookup_elem,
498 .map_update_elem = array_map_update_elem,
499 .map_delete_elem = array_map_delete_elem,
81ed18ab 500 .map_gen_lookup = array_map_gen_lookup,
d8eca5bb
DB
501 .map_direct_value_addr = array_map_direct_value_addr,
502 .map_direct_value_meta = array_map_direct_value_meta,
fc970227 503 .map_mmap = array_map_mmap,
a26ca7c9
MKL
504 .map_seq_show_elem = array_map_seq_show_elem,
505 .map_check_btf = array_map_check_btf,
28fbcfa0
AS
506};
507
40077e0c 508const struct bpf_map_ops percpu_array_map_ops = {
ad46061f 509 .map_alloc_check = array_map_alloc_check,
a10423b8
AS
510 .map_alloc = array_map_alloc,
511 .map_free = array_map_free,
512 .map_get_next_key = array_map_get_next_key,
513 .map_lookup_elem = percpu_array_map_lookup_elem,
514 .map_update_elem = array_map_update_elem,
515 .map_delete_elem = array_map_delete_elem,
c7b27c37 516 .map_seq_show_elem = percpu_array_map_seq_show_elem,
e8d2bec0 517 .map_check_btf = array_map_check_btf,
a10423b8
AS
518};
519
ad46061f 520static int fd_array_map_alloc_check(union bpf_attr *attr)
04fd61ab 521{
2a36f0b9 522 /* only file descriptors can be stored in this type of map */
04fd61ab 523 if (attr->value_size != sizeof(u32))
ad46061f 524 return -EINVAL;
591fe988
DB
525 /* Program read-only/write-only not supported for special maps yet. */
526 if (attr->map_flags & (BPF_F_RDONLY_PROG | BPF_F_WRONLY_PROG))
527 return -EINVAL;
ad46061f 528 return array_map_alloc_check(attr);
04fd61ab
AS
529}
530
2a36f0b9 531static void fd_array_map_free(struct bpf_map *map)
04fd61ab
AS
532{
533 struct bpf_array *array = container_of(map, struct bpf_array, map);
534 int i;
535
536 synchronize_rcu();
537
538 /* make sure it's empty */
539 for (i = 0; i < array->map.max_entries; i++)
2a36f0b9 540 BUG_ON(array->ptrs[i] != NULL);
d407bd25
DB
541
542 bpf_map_area_free(array);
04fd61ab
AS
543}
544
2a36f0b9 545static void *fd_array_map_lookup_elem(struct bpf_map *map, void *key)
04fd61ab 546{
3b4a63f6 547 return ERR_PTR(-EOPNOTSUPP);
04fd61ab
AS
548}
549
14dc6f04
MKL
550/* only called from syscall */
551int bpf_fd_array_map_lookup_elem(struct bpf_map *map, void *key, u32 *value)
552{
553 void **elem, *ptr;
554 int ret = 0;
555
556 if (!map->ops->map_fd_sys_lookup_elem)
557 return -ENOTSUPP;
558
559 rcu_read_lock();
560 elem = array_map_lookup_elem(map, key);
561 if (elem && (ptr = READ_ONCE(*elem)))
562 *value = map->ops->map_fd_sys_lookup_elem(ptr);
563 else
564 ret = -ENOENT;
565 rcu_read_unlock();
566
567 return ret;
568}
569
04fd61ab 570/* only called from syscall */
d056a788
DB
571int bpf_fd_array_map_update_elem(struct bpf_map *map, struct file *map_file,
572 void *key, void *value, u64 map_flags)
04fd61ab
AS
573{
574 struct bpf_array *array = container_of(map, struct bpf_array, map);
2a36f0b9 575 void *new_ptr, *old_ptr;
04fd61ab
AS
576 u32 index = *(u32 *)key, ufd;
577
578 if (map_flags != BPF_ANY)
579 return -EINVAL;
580
581 if (index >= array->map.max_entries)
582 return -E2BIG;
583
584 ufd = *(u32 *)value;
d056a788 585 new_ptr = map->ops->map_fd_get_ptr(map, map_file, ufd);
2a36f0b9
WN
586 if (IS_ERR(new_ptr))
587 return PTR_ERR(new_ptr);
04fd61ab 588
2a36f0b9
WN
589 old_ptr = xchg(array->ptrs + index, new_ptr);
590 if (old_ptr)
591 map->ops->map_fd_put_ptr(old_ptr);
04fd61ab
AS
592
593 return 0;
594}
595
2a36f0b9 596static int fd_array_map_delete_elem(struct bpf_map *map, void *key)
04fd61ab
AS
597{
598 struct bpf_array *array = container_of(map, struct bpf_array, map);
2a36f0b9 599 void *old_ptr;
04fd61ab
AS
600 u32 index = *(u32 *)key;
601
602 if (index >= array->map.max_entries)
603 return -E2BIG;
604
2a36f0b9
WN
605 old_ptr = xchg(array->ptrs + index, NULL);
606 if (old_ptr) {
607 map->ops->map_fd_put_ptr(old_ptr);
04fd61ab
AS
608 return 0;
609 } else {
610 return -ENOENT;
611 }
612}
613
d056a788
DB
614static void *prog_fd_array_get_ptr(struct bpf_map *map,
615 struct file *map_file, int fd)
2a36f0b9
WN
616{
617 struct bpf_array *array = container_of(map, struct bpf_array, map);
618 struct bpf_prog *prog = bpf_prog_get(fd);
d056a788 619
2a36f0b9
WN
620 if (IS_ERR(prog))
621 return prog;
622
623 if (!bpf_prog_array_compatible(array, prog)) {
624 bpf_prog_put(prog);
625 return ERR_PTR(-EINVAL);
626 }
d056a788 627
2a36f0b9
WN
628 return prog;
629}
630
631static void prog_fd_array_put_ptr(void *ptr)
632{
1aacde3d 633 bpf_prog_put(ptr);
2a36f0b9
WN
634}
635
14dc6f04
MKL
636static u32 prog_fd_array_sys_lookup_elem(void *ptr)
637{
638 return ((struct bpf_prog *)ptr)->aux->id;
639}
640
04fd61ab 641/* decrement refcnt of all bpf_progs that are stored in this map */
ba6b8de4 642static void bpf_fd_array_map_clear(struct bpf_map *map)
04fd61ab
AS
643{
644 struct bpf_array *array = container_of(map, struct bpf_array, map);
645 int i;
646
647 for (i = 0; i < array->map.max_entries; i++)
2a36f0b9 648 fd_array_map_delete_elem(map, &i);
04fd61ab
AS
649}
650
a7c19db3
YS
651static void prog_array_map_seq_show_elem(struct bpf_map *map, void *key,
652 struct seq_file *m)
653{
654 void **elem, *ptr;
655 u32 prog_id;
656
657 rcu_read_lock();
658
659 elem = array_map_lookup_elem(map, key);
660 if (elem) {
661 ptr = READ_ONCE(*elem);
662 if (ptr) {
663 seq_printf(m, "%u: ", *(u32 *)key);
664 prog_id = prog_fd_array_sys_lookup_elem(ptr);
665 btf_type_seq_show(map->btf, map->btf_value_type_id,
666 &prog_id, m);
667 seq_puts(m, "\n");
668 }
669 }
670
671 rcu_read_unlock();
672}
673
40077e0c 674const struct bpf_map_ops prog_array_map_ops = {
ad46061f
JK
675 .map_alloc_check = fd_array_map_alloc_check,
676 .map_alloc = array_map_alloc,
2a36f0b9 677 .map_free = fd_array_map_free,
04fd61ab 678 .map_get_next_key = array_map_get_next_key,
2a36f0b9 679 .map_lookup_elem = fd_array_map_lookup_elem,
2a36f0b9
WN
680 .map_delete_elem = fd_array_map_delete_elem,
681 .map_fd_get_ptr = prog_fd_array_get_ptr,
682 .map_fd_put_ptr = prog_fd_array_put_ptr,
14dc6f04 683 .map_fd_sys_lookup_elem = prog_fd_array_sys_lookup_elem,
ba6b8de4 684 .map_release_uref = bpf_fd_array_map_clear,
a7c19db3 685 .map_seq_show_elem = prog_array_map_seq_show_elem,
04fd61ab
AS
686};
687
3b1efb19
DB
688static struct bpf_event_entry *bpf_event_entry_gen(struct file *perf_file,
689 struct file *map_file)
ea317b26 690{
3b1efb19
DB
691 struct bpf_event_entry *ee;
692
858d68f1 693 ee = kzalloc(sizeof(*ee), GFP_ATOMIC);
3b1efb19
DB
694 if (ee) {
695 ee->event = perf_file->private_data;
696 ee->perf_file = perf_file;
697 ee->map_file = map_file;
698 }
699
700 return ee;
701}
702
703static void __bpf_event_entry_free(struct rcu_head *rcu)
704{
705 struct bpf_event_entry *ee;
706
707 ee = container_of(rcu, struct bpf_event_entry, rcu);
708 fput(ee->perf_file);
709 kfree(ee);
710}
711
712static void bpf_event_entry_free_rcu(struct bpf_event_entry *ee)
713{
714 call_rcu(&ee->rcu, __bpf_event_entry_free);
ea317b26
KX
715}
716
d056a788
DB
717static void *perf_event_fd_array_get_ptr(struct bpf_map *map,
718 struct file *map_file, int fd)
ea317b26 719{
3b1efb19
DB
720 struct bpf_event_entry *ee;
721 struct perf_event *event;
722 struct file *perf_file;
f91840a3 723 u64 value;
ea317b26 724
3b1efb19
DB
725 perf_file = perf_event_get(fd);
726 if (IS_ERR(perf_file))
727 return perf_file;
e03e7ee3 728
f91840a3 729 ee = ERR_PTR(-EOPNOTSUPP);
3b1efb19 730 event = perf_file->private_data;
97562633 731 if (perf_event_read_local(event, &value, NULL, NULL) == -EOPNOTSUPP)
3b1efb19
DB
732 goto err_out;
733
f91840a3
AS
734 ee = bpf_event_entry_gen(perf_file, map_file);
735 if (ee)
736 return ee;
737 ee = ERR_PTR(-ENOMEM);
3b1efb19
DB
738err_out:
739 fput(perf_file);
740 return ee;
ea317b26
KX
741}
742
743static void perf_event_fd_array_put_ptr(void *ptr)
744{
3b1efb19
DB
745 bpf_event_entry_free_rcu(ptr);
746}
747
748static void perf_event_fd_array_release(struct bpf_map *map,
749 struct file *map_file)
750{
751 struct bpf_array *array = container_of(map, struct bpf_array, map);
752 struct bpf_event_entry *ee;
753 int i;
754
755 rcu_read_lock();
756 for (i = 0; i < array->map.max_entries; i++) {
757 ee = READ_ONCE(array->ptrs[i]);
758 if (ee && ee->map_file == map_file)
759 fd_array_map_delete_elem(map, &i);
760 }
761 rcu_read_unlock();
ea317b26
KX
762}
763
40077e0c 764const struct bpf_map_ops perf_event_array_map_ops = {
ad46061f
JK
765 .map_alloc_check = fd_array_map_alloc_check,
766 .map_alloc = array_map_alloc,
3b1efb19 767 .map_free = fd_array_map_free,
ea317b26
KX
768 .map_get_next_key = array_map_get_next_key,
769 .map_lookup_elem = fd_array_map_lookup_elem,
ea317b26
KX
770 .map_delete_elem = fd_array_map_delete_elem,
771 .map_fd_get_ptr = perf_event_fd_array_get_ptr,
772 .map_fd_put_ptr = perf_event_fd_array_put_ptr,
3b1efb19 773 .map_release = perf_event_fd_array_release,
e8d2bec0 774 .map_check_btf = map_check_no_btf,
ea317b26
KX
775};
776
60d20f91 777#ifdef CONFIG_CGROUPS
4ed8ec52
MKL
778static void *cgroup_fd_array_get_ptr(struct bpf_map *map,
779 struct file *map_file /* not used */,
780 int fd)
781{
782 return cgroup_get_from_fd(fd);
783}
784
785static void cgroup_fd_array_put_ptr(void *ptr)
786{
787 /* cgroup_put free cgrp after a rcu grace period */
788 cgroup_put(ptr);
789}
790
791static void cgroup_fd_array_free(struct bpf_map *map)
792{
793 bpf_fd_array_map_clear(map);
794 fd_array_map_free(map);
795}
796
40077e0c 797const struct bpf_map_ops cgroup_array_map_ops = {
ad46061f
JK
798 .map_alloc_check = fd_array_map_alloc_check,
799 .map_alloc = array_map_alloc,
4ed8ec52
MKL
800 .map_free = cgroup_fd_array_free,
801 .map_get_next_key = array_map_get_next_key,
802 .map_lookup_elem = fd_array_map_lookup_elem,
803 .map_delete_elem = fd_array_map_delete_elem,
804 .map_fd_get_ptr = cgroup_fd_array_get_ptr,
805 .map_fd_put_ptr = cgroup_fd_array_put_ptr,
e8d2bec0 806 .map_check_btf = map_check_no_btf,
4ed8ec52 807};
4ed8ec52 808#endif
56f668df
MKL
809
810static struct bpf_map *array_of_map_alloc(union bpf_attr *attr)
811{
812 struct bpf_map *map, *inner_map_meta;
813
814 inner_map_meta = bpf_map_meta_alloc(attr->inner_map_fd);
815 if (IS_ERR(inner_map_meta))
816 return inner_map_meta;
817
ad46061f 818 map = array_map_alloc(attr);
56f668df
MKL
819 if (IS_ERR(map)) {
820 bpf_map_meta_free(inner_map_meta);
821 return map;
822 }
823
824 map->inner_map_meta = inner_map_meta;
825
826 return map;
827}
828
829static void array_of_map_free(struct bpf_map *map)
830{
831 /* map->inner_map_meta is only accessed by syscall which
832 * is protected by fdget/fdput.
833 */
834 bpf_map_meta_free(map->inner_map_meta);
835 bpf_fd_array_map_clear(map);
836 fd_array_map_free(map);
837}
838
839static void *array_of_map_lookup_elem(struct bpf_map *map, void *key)
840{
841 struct bpf_map **inner_map = array_map_lookup_elem(map, key);
842
843 if (!inner_map)
844 return NULL;
845
846 return READ_ONCE(*inner_map);
847}
848
7b0c2a05
DB
849static u32 array_of_map_gen_lookup(struct bpf_map *map,
850 struct bpf_insn *insn_buf)
851{
b2157399 852 struct bpf_array *array = container_of(map, struct bpf_array, map);
7b0c2a05
DB
853 u32 elem_size = round_up(map->value_size, 8);
854 struct bpf_insn *insn = insn_buf;
855 const int ret = BPF_REG_0;
856 const int map_ptr = BPF_REG_1;
857 const int index = BPF_REG_2;
858
859 *insn++ = BPF_ALU64_IMM(BPF_ADD, map_ptr, offsetof(struct bpf_array, value));
860 *insn++ = BPF_LDX_MEM(BPF_W, ret, index, 0);
b2157399
AS
861 if (map->unpriv_array) {
862 *insn++ = BPF_JMP_IMM(BPF_JGE, ret, map->max_entries, 6);
863 *insn++ = BPF_ALU32_IMM(BPF_AND, ret, array->index_mask);
864 } else {
865 *insn++ = BPF_JMP_IMM(BPF_JGE, ret, map->max_entries, 5);
866 }
7b0c2a05
DB
867 if (is_power_of_2(elem_size))
868 *insn++ = BPF_ALU64_IMM(BPF_LSH, ret, ilog2(elem_size));
869 else
870 *insn++ = BPF_ALU64_IMM(BPF_MUL, ret, elem_size);
871 *insn++ = BPF_ALU64_REG(BPF_ADD, ret, map_ptr);
872 *insn++ = BPF_LDX_MEM(BPF_DW, ret, ret, 0);
873 *insn++ = BPF_JMP_IMM(BPF_JEQ, ret, 0, 1);
874 *insn++ = BPF_JMP_IMM(BPF_JA, 0, 0, 1);
875 *insn++ = BPF_MOV64_IMM(ret, 0);
876
877 return insn - insn_buf;
878}
879
40077e0c 880const struct bpf_map_ops array_of_maps_map_ops = {
ad46061f 881 .map_alloc_check = fd_array_map_alloc_check,
56f668df
MKL
882 .map_alloc = array_of_map_alloc,
883 .map_free = array_of_map_free,
884 .map_get_next_key = array_map_get_next_key,
885 .map_lookup_elem = array_of_map_lookup_elem,
886 .map_delete_elem = fd_array_map_delete_elem,
887 .map_fd_get_ptr = bpf_map_fd_get_ptr,
888 .map_fd_put_ptr = bpf_map_fd_put_ptr,
14dc6f04 889 .map_fd_sys_lookup_elem = bpf_map_fd_sys_lookup_elem,
7b0c2a05 890 .map_gen_lookup = array_of_map_gen_lookup,
e8d2bec0 891 .map_check_btf = map_check_no_btf,
56f668df 892};