218 lines · 5.7 KB · C
RawDownload
// SPDX-License-Identifier: GPL-2.0/* Copyright (c) 2021 Facebook */ #include <linux/bitmap.h>#include <linux/bpf.h>#include <linux/btf.h>#include <linux/err.h>#include <linux/jhash.h>#include <linux/random.h>#include <linux/btf_ids.h> #define BLOOM_CREATE_FLAG_MASK \	(BPF_F_NUMA_NODE | BPF_F_ZERO_SEED | BPF_F_ACCESS_MASK) struct bpf_bloom_filter {	struct bpf_map map;	u32 bitset_mask;	u32 hash_seed;	u32 nr_hash_funcs;	unsigned long bitset[];}; static u32 hash(struct bpf_bloom_filter *bloom, void *value,		u32 value_size, u32 index){	u32 h; 	if (likely(value_size % 4 == 0))		h = jhash2(value, value_size / 4, bloom->hash_seed + index);	else		h = jhash(value, value_size, bloom->hash_seed + index); 	return h & bloom->bitset_mask;} static long bloom_map_peek_elem(struct bpf_map *map, void *value){	struct bpf_bloom_filter *bloom =		container_of(map, struct bpf_bloom_filter, map);	u32 i, h; 	for (i = 0; i < bloom->nr_hash_funcs; i++) {		h = hash(bloom, value, map->value_size, i);		if (!test_bit(h % BITS_PER_LONG, bloom->bitset + BIT_WORD(h)))			return -ENOENT;	} 	return 0;} static long bloom_map_push_elem(struct bpf_map *map, void *value, u64 flags){	struct bpf_bloom_filter *bloom =		container_of(map, struct bpf_bloom_filter, map);	u32 i, h; 	if (flags != BPF_ANY)		return -EINVAL; 	/*	 * On 32-bit architectures, hashes larger than INT_MAX would be	 * treated as negative by set_bit().	 */	for (i = 0; i < bloom->nr_hash_funcs; i++) {		h = hash(bloom, value, map->value_size, i);		set_bit(h % BITS_PER_LONG, bloom->bitset + BIT_WORD(h));	} 	return 0;} static long bloom_map_pop_elem(struct bpf_map *map, void *value){	return -EOPNOTSUPP;} static long bloom_map_delete_elem(struct bpf_map *map, void *value){	return -EOPNOTSUPP;} static int bloom_map_get_next_key(struct bpf_map *map, void *key, void *next_key){	return -EOPNOTSUPP;} /* Called from syscall */static int bloom_map_alloc_check(union bpf_attr *attr){	if (attr->value_size > KMALLOC_MAX_SIZE)		/* if value_size is bigger, the user space won't be able to		 * access the elements.		 */		return -E2BIG; 	return 0;} static struct bpf_map *bloom_map_alloc(union bpf_attr *attr){	u32 bitset_mask, nr_hash_funcs, nr_bits;	int numa_node = bpf_map_attr_numa_node(attr);	struct bpf_bloom_filter *bloom;	u64 bitset_bytes; 	if (attr->key_size != 0 || attr->value_size == 0 ||	    attr->max_entries == 0 ||	    attr->map_flags & ~BLOOM_CREATE_FLAG_MASK ||	    !bpf_map_flags_access_ok(attr->map_flags) ||	    /* The lower 4 bits of map_extra (0xF) specify the number	     * of hash functions	     */	    (attr->map_extra & ~0xF))		return ERR_PTR(-EINVAL); 	nr_hash_funcs = attr->map_extra;	if (nr_hash_funcs == 0)		/* Default to using 5 hash functions if unspecified */		nr_hash_funcs = 5; 	/* For the bloom filter, the optimal bit array size that minimizes the	 * false positive probability is n * k / ln(2) where n is the number of	 * expected entries in the bloom filter and k is the number of hash	 * functions. We use 7 / 5 to approximate 1 / ln(2).	 *	 * We round this up to the nearest power of two to enable more efficient	 * hashing using bitmasks. The bitmask will be the bit array size - 1.	 *	 * If this overflows a u32, the bit array size will have 2^32 (4	 * GB) bits.	 */	if (check_mul_overflow(attr->max_entries, nr_hash_funcs, &nr_bits) ||	    check_mul_overflow(nr_bits / 5, (u32)7, &nr_bits) ||	    nr_bits > (1UL << 31)) {		bitset_mask = U32_MAX;	} else {		if (nr_bits <= BITS_PER_LONG)			nr_bits = BITS_PER_LONG;		else			nr_bits = roundup_pow_of_two(nr_bits);		bitset_mask = nr_bits - 1;	} 	bitset_bytes = BITS_TO_LONGS((u64)bitset_mask + 1) * sizeof(unsigned long);	bloom = bpf_map_area_alloc(sizeof(*bloom) + bitset_bytes, numa_node); 	if (!bloom)		return ERR_PTR(-ENOMEM); 	bpf_map_init_from_attr(&bloom->map, attr); 	bloom->nr_hash_funcs = nr_hash_funcs;	bloom->bitset_mask = bitset_mask; 	if (!(attr->map_flags & BPF_F_ZERO_SEED))		bloom->hash_seed = get_random_u32(); 	return &bloom->map;} static void bloom_map_free(struct bpf_map *map){	struct bpf_bloom_filter *bloom =		container_of(map, struct bpf_bloom_filter, map); 	bpf_map_area_free(bloom);} static void *bloom_map_lookup_elem(struct bpf_map *map, void *key){	/* The eBPF program should use map_peek_elem instead */	return ERR_PTR(-EINVAL);} static long bloom_map_update_elem(struct bpf_map *map, void *key,				  void *value, u64 flags){	/* The eBPF program should use map_push_elem instead */	return -EINVAL;} static int bloom_map_check_btf(struct bpf_map *map,			       const struct btf *btf,			       const struct btf_type *key_type,			       const struct btf_type *value_type){	/* Bloom filter maps are keyless */	return btf_type_is_void(key_type) ? 0 : -EINVAL;} static u64 bloom_map_mem_usage(const struct bpf_map *map){	struct bpf_bloom_filter *bloom;	u64 bitset_bytes; 	bloom = container_of(map, struct bpf_bloom_filter, map);	bitset_bytes = BITS_TO_BYTES((u64)bloom->bitset_mask + 1);	bitset_bytes = roundup(bitset_bytes, sizeof(unsigned long));	return sizeof(*bloom) + bitset_bytes;} BTF_ID_LIST_SINGLE(bpf_bloom_map_btf_ids, struct, bpf_bloom_filter)const struct bpf_map_ops bloom_filter_map_ops = {	.map_meta_equal = bpf_map_meta_equal,	.map_alloc_check = bloom_map_alloc_check,	.map_alloc = bloom_map_alloc,	.map_free = bloom_map_free,	.map_get_next_key = bloom_map_get_next_key,	.map_push_elem = bloom_map_push_elem,	.map_peek_elem = bloom_map_peek_elem,	.map_pop_elem = bloom_map_pop_elem,	.map_lookup_elem = bloom_map_lookup_elem,	.map_update_elem = bloom_map_update_elem,	.map_delete_elem = bloom_map_delete_elem,	.map_check_btf = bloom_map_check_btf,	.map_mem_usage = bloom_map_mem_usage,	.map_btf_id = &bpf_bloom_map_btf_ids[0],};