Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 | /* * Copyright (c) 2021 Apple Inc. All rights reserved. * * @APPLE_OSREFERENCE_LICENSE_HEADER_START@ * * This file contains Original Code and/or Modifications of Original Code * as defined in and that are subject to the Apple Public Source License * Version 2.0 (the 'License'). You may not use this file except in * compliance with the License. The rights granted to you under the License * may not be used to create, or enable the creation or redistribution of, * unlawful or unlicensed copies of an Apple operating system, or to * circumvent, violate, or enable the circumvention or violation of, any * terms of an Apple operating system software license agreement. * * Please obtain a copy of the License at * http://www.opensource.apple.com/apsl/ and read it before using this file. * * The Original Code and all software distributed under the License are * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. * Please see the License for the specific language governing rights and * limitations under the License. * * @APPLE_OSREFERENCE_LICENSE_HEADER_END@ */ #include <stdbool.h> #include <sys/types.h> #include <sys/malloc.h> #include <machine/endian.h> #include <net/flowhash.h> #include <net/bloom_filter.h> #include <os/base.h> size_t net_bloom_filter_get_size(uint32_t num_bits) { if (num_bits == 0) { // 0 bits is not valid return 0; } uint32_t num_elements = howmany(num_bits, kNetBloomFilterBitsPerTableElement); return sizeof(struct net_bloom_filter) + (sizeof(uint32_t) * num_elements); } struct net_bloom_filter * net_bloom_filter_create(uint32_t num_bits) { if (num_bits == 0) { return NULL; } const size_t size = net_bloom_filter_get_size(num_bits); struct net_bloom_filter *filter = (struct net_bloom_filter *)kalloc_data(size, Z_WAITOK | Z_ZERO); if (filter == NULL) { return NULL; } filter->b_table_num_bits = num_bits; return filter; } void net_bloom_filter_destroy(struct net_bloom_filter *filter) { if (filter != NULL) { uint8_t *filter_buffer = (uint8_t *)filter; kfree_data(filter_buffer, net_bloom_filter_get_size(filter->b_table_num_bits)); } } static inline void net_bloom_filter_insert_using_function(struct net_bloom_filter *filter, net_flowhash_fn_t *function, const void * __sized_by(length)buffer, uint32_t length) { u_int32_t hash = (function(buffer, length, 0) % filter->b_table_num_bits); u_int32_t index = hash / kNetBloomFilterBitsPerTableElement; u_int32_t bit = hash % kNetBloomFilterBitsPerTableElement; (filter->b_table[index]) |= (1ull << bit); } void net_bloom_filter_insert(struct net_bloom_filter *filter, const void * __sized_by(length)buffer, uint32_t length) { net_bloom_filter_insert_using_function(filter, &net_flowhash_jhash, buffer, length); net_bloom_filter_insert_using_function(filter, &net_flowhash_mh3_x86_32, buffer, length); net_bloom_filter_insert_using_function(filter, &net_flowhash_mh3_x64_128, buffer, length); } static inline bool net_bloom_filter_contains_using_function(struct net_bloom_filter *filter, net_flowhash_fn_t *function, const void * __sized_by(length)buffer, uint32_t length) { u_int32_t hash = (function(buffer, length, 0) % filter->b_table_num_bits); u_int32_t index = hash / kNetBloomFilterBitsPerTableElement; u_int32_t bit = hash % kNetBloomFilterBitsPerTableElement; return (filter->b_table[index]) & (1ull << bit); } bool net_bloom_filter_contains(struct net_bloom_filter *filter, const void * __sized_by(length)buffer, uint32_t length) { return net_bloom_filter_contains_using_function(filter, &net_flowhash_jhash, buffer, length) && net_bloom_filter_contains_using_function(filter, &net_flowhash_mh3_x86_32, buffer, length) && net_bloom_filter_contains_using_function(filter, &net_flowhash_mh3_x64_128, buffer, length); } |