/src/h2o/deps/klib/khash.h
Line | Count | Source (jump to first uncovered line) |
1 | | /* The MIT License |
2 | | |
3 | | Copyright (c) 2008, 2009, 2011 by Attractive Chaos <attractor@live.co.uk> |
4 | | |
5 | | Permission is hereby granted, free of charge, to any person obtaining |
6 | | a copy of this software and associated documentation files (the |
7 | | "Software"), to deal in the Software without restriction, including |
8 | | without limitation the rights to use, copy, modify, merge, publish, |
9 | | distribute, sublicense, and/or sell copies of the Software, and to |
10 | | permit persons to whom the Software is furnished to do so, subject to |
11 | | the following conditions: |
12 | | |
13 | | The above copyright notice and this permission notice shall be |
14 | | included in all copies or substantial portions of the Software. |
15 | | |
16 | | THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
17 | | EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
18 | | MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
19 | | NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS |
20 | | BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN |
21 | | ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
22 | | CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE |
23 | | SOFTWARE. |
24 | | */ |
25 | | |
26 | | /* |
27 | | An example: |
28 | | |
29 | | #include "khash.h" |
30 | | KHASH_MAP_INIT_INT(32, char) |
31 | | int main() { |
32 | | int ret, is_missing; |
33 | | khiter_t k; |
34 | | khash_t(32) *h = kh_init(32); |
35 | | k = kh_put(32, h, 5, &ret); |
36 | | kh_value(h, k) = 10; |
37 | | k = kh_get(32, h, 10); |
38 | | is_missing = (k == kh_end(h)); |
39 | | k = kh_get(32, h, 5); |
40 | | kh_del(32, h, k); |
41 | | for (k = kh_begin(h); k != kh_end(h); ++k) |
42 | | if (kh_exist(h, k)) kh_value(h, k) = 1; |
43 | | kh_destroy(32, h); |
44 | | return 0; |
45 | | } |
46 | | */ |
47 | | |
48 | | /* |
49 | | 2013-05-02 (0.2.8): |
50 | | |
51 | | * Use quadratic probing. When the capacity is power of 2, stepping function |
52 | | i*(i+1)/2 guarantees to traverse each bucket. It is better than double |
53 | | hashing on cache performance and is more robust than linear probing. |
54 | | |
55 | | In theory, double hashing should be more robust than quadratic probing. |
56 | | However, my implementation is probably not for large hash tables, because |
57 | | the second hash function is closely tied to the first hash function, |
58 | | which reduce the effectiveness of double hashing. |
59 | | |
60 | | Reference: http://research.cs.vt.edu/AVresearch/hashing/quadratic.php |
61 | | |
62 | | 2011-12-29 (0.2.7): |
63 | | |
64 | | * Minor code clean up; no actual effect. |
65 | | |
66 | | 2011-09-16 (0.2.6): |
67 | | |
68 | | * The capacity is a power of 2. This seems to dramatically improve the |
69 | | speed for simple keys. Thank Zilong Tan for the suggestion. Reference: |
70 | | |
71 | | - http://code.google.com/p/ulib/ |
72 | | - http://nothings.org/computer/judy/ |
73 | | |
74 | | * Allow to optionally use linear probing which usually has better |
75 | | performance for random input. Double hashing is still the default as it |
76 | | is more robust to certain non-random input. |
77 | | |
78 | | * Added Wang's integer hash function (not used by default). This hash |
79 | | function is more robust to certain non-random input. |
80 | | |
81 | | 2011-02-14 (0.2.5): |
82 | | |
83 | | * Allow to declare global functions. |
84 | | |
85 | | 2009-09-26 (0.2.4): |
86 | | |
87 | | * Improve portability |
88 | | |
89 | | 2008-09-19 (0.2.3): |
90 | | |
91 | | * Corrected the example |
92 | | * Improved interfaces |
93 | | |
94 | | 2008-09-11 (0.2.2): |
95 | | |
96 | | * Improved speed a little in kh_put() |
97 | | |
98 | | 2008-09-10 (0.2.1): |
99 | | |
100 | | * Added kh_clear() |
101 | | * Fixed a compiling error |
102 | | |
103 | | 2008-09-02 (0.2.0): |
104 | | |
105 | | * Changed to token concatenation which increases flexibility. |
106 | | |
107 | | 2008-08-31 (0.1.2): |
108 | | |
109 | | * Fixed a bug in kh_get(), which has not been tested previously. |
110 | | |
111 | | 2008-08-31 (0.1.1): |
112 | | |
113 | | * Added destructor |
114 | | */ |
115 | | |
116 | | |
117 | | #ifndef __AC_KHASH_H |
118 | | #define __AC_KHASH_H |
119 | | |
120 | | /*! |
121 | | @header |
122 | | |
123 | | Generic hash table library. |
124 | | */ |
125 | | |
126 | | #define AC_VERSION_KHASH_H "0.2.8" |
127 | | |
128 | | #include <stdlib.h> |
129 | | #include <string.h> |
130 | | #include <limits.h> |
131 | | |
132 | | /* compiler specific configuration */ |
133 | | |
134 | | #if UINT_MAX == 0xffffffffu |
135 | | typedef unsigned int khint32_t; |
136 | | #elif ULONG_MAX == 0xffffffffu |
137 | | typedef unsigned long khint32_t; |
138 | | #endif |
139 | | |
140 | | #if ULONG_MAX == ULLONG_MAX |
141 | | typedef unsigned long khint64_t; |
142 | | #else |
143 | | typedef unsigned long long khint64_t; |
144 | | #endif |
145 | | |
146 | | #ifndef kh_inline |
147 | | #ifdef _MSC_VER |
148 | | #define kh_inline __inline |
149 | | #else |
150 | | #define kh_inline inline |
151 | | #endif |
152 | | #endif /* kh_inline */ |
153 | | |
154 | | typedef khint32_t khint_t; |
155 | | typedef khint_t khiter_t; |
156 | | |
157 | 1.59M | #define __ac_isempty(flag, i) ((flag[i>>4]>>((i&0xfU)<<1))&2) |
158 | 968k | #define __ac_isdel(flag, i) ((flag[i>>4]>>((i&0xfU)<<1))&1) |
159 | 669k | #define __ac_iseither(flag, i) ((flag[i>>4]>>((i&0xfU)<<1))&3) |
160 | | #define __ac_set_isdel_false(flag, i) (flag[i>>4]&=~(1ul<<((i&0xfU)<<1))) |
161 | 40.8k | #define __ac_set_isempty_false(flag, i) (flag[i>>4]&=~(2ul<<((i&0xfU)<<1))) |
162 | 118k | #define __ac_set_isboth_false(flag, i) (flag[i>>4]&=~(3ul<<((i&0xfU)<<1))) |
163 | 116k | #define __ac_set_isdel_true(flag, i) (flag[i>>4]|=1ul<<((i&0xfU)<<1)) |
164 | | |
165 | 30.1k | #define __ac_fsize(m) ((m) < 16? 1 : (m)>>4) |
166 | | |
167 | | #ifndef kroundup32 |
168 | 29.3k | #define kroundup32(x) (--(x), (x)|=(x)>>1, (x)|=(x)>>2, (x)|=(x)>>4, (x)|=(x)>>8, (x)|=(x)>>16, ++(x)) |
169 | | #endif |
170 | | |
171 | | #ifndef kcalloc |
172 | 26.4k | #define kcalloc(N,Z) calloc(N,Z) |
173 | | #endif |
174 | | #ifndef kmalloc |
175 | 58.7k | #define kmalloc(Z) malloc(Z) |
176 | | #endif |
177 | | #ifndef krealloc |
178 | 52.9k | #define krealloc(P,Z) realloc(P,Z) |
179 | | #endif |
180 | | #ifndef kfree |
181 | 134k | #define kfree(P) free(P) |
182 | | #endif |
183 | | |
184 | | static const double __ac_HASH_UPPER = 0.77; |
185 | | |
186 | | #define __KHASH_TYPE(name, khkey_t, khval_t) \ |
187 | | typedef struct kh_##name##_s { \ |
188 | | khint_t n_buckets, size, n_occupied, upper_bound; \ |
189 | | khint32_t *flags; \ |
190 | | khkey_t *keys; \ |
191 | | khval_t *vals; \ |
192 | | } kh_##name##_t; |
193 | | |
194 | | #define __KHASH_PROTOTYPES(name, khkey_t, khval_t) \ |
195 | | extern kh_##name##_t *kh_init_##name(void); \ |
196 | | extern void kh_destroy_##name(kh_##name##_t *h); \ |
197 | | extern void kh_clear_##name(kh_##name##_t *h); \ |
198 | | extern khint_t kh_get_##name(const kh_##name##_t *h, khkey_t key); \ |
199 | | extern int kh_resize_##name(kh_##name##_t *h, khint_t new_n_buckets); \ |
200 | | extern khint_t kh_put_##name(kh_##name##_t *h, khkey_t key, int *ret); \ |
201 | | extern void kh_del_##name(kh_##name##_t *h, khint_t x); |
202 | | |
203 | | #define __KHASH_IMPL(name, SCOPE, khkey_t, khval_t, kh_is_map, __hash_func, __hash_equal) \ |
204 | 26.4k | SCOPE kh_##name##_t *kh_init_##name(void) { \ |
205 | 26.4k | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ |
206 | 26.4k | } \ Line | Count | Source | 204 | 6 | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 6 | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 6 | } \ |
mimemap.c:kh_init_typeset Line | Count | Source | 204 | 6 | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 6 | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 6 | } \ |
connection.c:kh_init_h2o_http2_stream_t Line | Count | Source | 204 | 13.3k | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 13.3k | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 13.3k | } \ |
Unexecuted instantiation: scheduler.c:kh_init_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_init_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_init_h2o_http2_stream_t Unexecuted instantiation: common.c:kh_init_h2o_quic_idmap Unexecuted instantiation: common.c:kh_init_h2o_quic_acceptmap Line | Count | Source | 204 | 6.52k | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 6.52k | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 6.52k | } \ |
Unexecuted instantiation: server.c:kh_init_h2o_quic_idmap Unexecuted instantiation: server.c:kh_init_h2o_quic_acceptmap Unexecuted instantiation: quicly.c:kh_init_quicly_stream_t Unexecuted instantiation: cache.c:kh_init_cache filecache.c:kh_init_opencache_set Line | Count | Source | 204 | 3 | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 3 | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 3 | } \ |
Unexecuted instantiation: http3client.c:kh_init_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_init_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_init_stream driver_h3.cc:kh_init_h2o_quic_idmap() Line | Count | Source | 204 | 1 | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 1 | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 1 | } \ |
driver_h3.cc:kh_init_h2o_quic_acceptmap() Line | Count | Source | 204 | 1 | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 1 | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 1 | } \ |
quicly_mock.c:kh_init_quicly_stream_t Line | Count | Source | 204 | 6.52k | SCOPE kh_##name##_t *kh_init_##name(void) { \ | 205 | 6.52k | return (kh_##name##_t*)kcalloc(1, sizeof(kh_##name##_t)); \ | 206 | 6.52k | } \ |
|
207 | | SCOPE void kh_destroy_##name(kh_##name##_t *h) \ |
208 | 26.3k | { \ |
209 | 26.3k | if (h) { \ |
210 | 26.3k | kfree((void *)h->keys); kfree(h->flags); \ |
211 | 26.3k | kfree((void *)h->vals); \ |
212 | 26.3k | kfree(h); \ |
213 | 26.3k | } \ |
214 | 26.3k | } \ Unexecuted instantiation: mimemap.c:kh_destroy_typeset Unexecuted instantiation: mimemap.c:kh_destroy_extmap connection.c:kh_destroy_h2o_http2_stream_t Line | Count | Source | 208 | 13.3k | { \ | 209 | 13.3k | if (h) { \ | 210 | 13.3k | kfree((void *)h->keys); kfree(h->flags); \ | 211 | 13.3k | kfree((void *)h->vals); \ | 212 | 13.3k | kfree(h); \ | 213 | 13.3k | } \ | 214 | 13.3k | } \ |
Unexecuted instantiation: scheduler.c:kh_destroy_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_destroy_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_destroy_h2o_http2_stream_t Unexecuted instantiation: common.c:kh_destroy_h2o_quic_idmap Unexecuted instantiation: common.c:kh_destroy_h2o_quic_acceptmap server.c:kh_destroy_stream Line | Count | Source | 208 | 6.52k | { \ | 209 | 6.52k | if (h) { \ | 210 | 6.52k | kfree((void *)h->keys); kfree(h->flags); \ | 211 | 6.52k | kfree((void *)h->vals); \ | 212 | 6.52k | kfree(h); \ | 213 | 6.52k | } \ | 214 | 6.52k | } \ |
Unexecuted instantiation: server.c:kh_destroy_h2o_quic_idmap Unexecuted instantiation: server.c:kh_destroy_h2o_quic_acceptmap Unexecuted instantiation: quicly.c:kh_destroy_quicly_stream_t Unexecuted instantiation: cache.c:kh_destroy_cache Unexecuted instantiation: filecache.c:kh_destroy_opencache_set Unexecuted instantiation: http3client.c:kh_destroy_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_destroy_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_destroy_stream Unexecuted instantiation: driver_h3.cc:kh_destroy_h2o_quic_idmap(kh_h2o_quic_idmap_s*) Unexecuted instantiation: driver_h3.cc:kh_destroy_h2o_quic_acceptmap(kh_h2o_quic_acceptmap_s*) quicly_mock.c:kh_destroy_quicly_stream_t Line | Count | Source | 208 | 6.52k | { \ | 209 | 6.52k | if (h) { \ | 210 | 6.52k | kfree((void *)h->keys); kfree(h->flags); \ | 211 | 6.52k | kfree((void *)h->vals); \ | 212 | 6.52k | kfree(h); \ | 213 | 6.52k | } \ | 214 | 6.52k | } \ |
|
215 | | SCOPE void kh_clear_##name(kh_##name##_t *h) \ |
216 | 816 | { \ |
217 | 816 | if (h && h->flags) { \ |
218 | 810 | memset(h->flags, 0xaa, __ac_fsize(h->n_buckets) * sizeof(khint32_t)); \ |
219 | 810 | h->size = h->n_occupied = 0; \ |
220 | 810 | } \ |
221 | 816 | } \ mimemap.c:kh_clear_typeset Line | Count | Source | 216 | 816 | { \ | 217 | 816 | if (h && h->flags) { \ | 218 | 810 | memset(h->flags, 0xaa, __ac_fsize(h->n_buckets) * sizeof(khint32_t)); \ | 219 | 810 | h->size = h->n_occupied = 0; \ | 220 | 810 | } \ | 221 | 816 | } \ |
Unexecuted instantiation: mimemap.c:kh_clear_extmap Unexecuted instantiation: connection.c:kh_clear_h2o_http2_stream_t Unexecuted instantiation: scheduler.c:kh_clear_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_clear_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_clear_h2o_http2_stream_t Unexecuted instantiation: common.c:kh_clear_h2o_quic_idmap Unexecuted instantiation: common.c:kh_clear_h2o_quic_acceptmap Unexecuted instantiation: server.c:kh_clear_h2o_quic_idmap Unexecuted instantiation: server.c:kh_clear_h2o_quic_acceptmap Unexecuted instantiation: server.c:kh_clear_stream Unexecuted instantiation: quicly.c:kh_clear_quicly_stream_t Unexecuted instantiation: cache.c:kh_clear_cache Unexecuted instantiation: filecache.c:kh_clear_opencache_set Unexecuted instantiation: http3client.c:kh_clear_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_clear_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_clear_stream Unexecuted instantiation: driver_h3.cc:kh_clear_h2o_quic_idmap(kh_h2o_quic_idmap_s*) Unexecuted instantiation: driver_h3.cc:kh_clear_h2o_quic_acceptmap(kh_h2o_quic_acceptmap_s*) Unexecuted instantiation: quicly_mock.c:kh_clear_quicly_stream_t |
222 | | SCOPE khint_t kh_get_##name(const kh_##name##_t *h, khkey_t key) \ |
223 | 275k | { \ |
224 | 275k | if (h->n_buckets) { \ |
225 | 247k | khint_t k, i, last, mask, step = 0; \ |
226 | 247k | mask = h->n_buckets - 1; \ |
227 | 247k | k = __hash_func(key); i = k & mask; \ |
228 | 247k | last = i; \ |
229 | 448k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ |
230 | 201k | i = (i + (++step)) & mask; \ |
231 | 201k | if (i == last) return h->n_buckets; \ |
232 | 201k | } \ |
233 | 247k | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ |
234 | 247k | } else return 0; \ |
235 | 275k | } \ Line | Count | Source | 223 | 810 | { \ | 224 | 810 | if (h->n_buckets) { \ | 225 | 804 | khint_t k, i, last, mask, step = 0; \ | 226 | 804 | mask = h->n_buckets - 1; \ | 227 | 804 | k = __hash_func(key); i = k & mask; \ | 228 | 804 | last = i; \ | 229 | 2.13k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 1.32k | i = (i + (++step)) & mask; \ | 231 | 1.32k | if (i == last) return h->n_buckets; \ | 232 | 1.32k | } \ | 233 | 804 | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 804 | } else return 0; \ | 235 | 810 | } \ |
Line | Count | Source | 223 | 56.7k | { \ | 224 | 56.7k | if (h->n_buckets) { \ | 225 | 56.6k | khint_t k, i, last, mask, step = 0; \ | 226 | 56.6k | mask = h->n_buckets - 1; \ | 227 | 56.6k | k = __hash_func(key); i = k & mask; \ | 228 | 56.6k | last = i; \ | 229 | 77.8k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 21.1k | i = (i + (++step)) & mask; \ | 231 | 21.1k | if (i == last) return h->n_buckets; \ | 232 | 21.1k | } \ | 233 | 56.6k | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 56.6k | } else return 0; \ | 235 | 56.7k | } \ |
connection.c:kh_get_h2o_http2_stream_t Line | Count | Source | 223 | 169k | { \ | 224 | 169k | if (h->n_buckets) { \ | 225 | 157k | khint_t k, i, last, mask, step = 0; \ | 226 | 157k | mask = h->n_buckets - 1; \ | 227 | 157k | k = __hash_func(key); i = k & mask; \ | 228 | 157k | last = i; \ | 229 | 329k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 172k | i = (i + (++step)) & mask; \ | 231 | 172k | if (i == last) return h->n_buckets; \ | 232 | 172k | } \ | 233 | 157k | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 157k | } else return 0; \ | 235 | 169k | } \ |
Unexecuted instantiation: scheduler.c:kh_get_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_get_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_get_h2o_http2_stream_t Unexecuted instantiation: common.c:kh_get_h2o_quic_acceptmap common.c:kh_get_h2o_quic_idmap Line | Count | Source | 223 | 6.52k | { \ | 224 | 6.52k | if (h->n_buckets) { \ | 225 | 6.52k | khint_t k, i, last, mask, step = 0; \ | 226 | 6.52k | mask = h->n_buckets - 1; \ | 227 | 6.52k | k = __hash_func(key); i = k & mask; \ | 228 | 6.52k | last = i; \ | 229 | 6.52k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 0 | i = (i + (++step)) & mask; \ | 231 | 0 | if (i == last) return h->n_buckets; \ | 232 | 0 | } \ | 233 | 6.52k | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 6.52k | } else return 0; \ | 235 | 6.52k | } \ |
Line | Count | Source | 223 | 698 | { \ | 224 | 698 | if (h->n_buckets) { \ | 225 | 0 | khint_t k, i, last, mask, step = 0; \ | 226 | 0 | mask = h->n_buckets - 1; \ | 227 | 0 | k = __hash_func(key); i = k & mask; \ | 228 | 0 | last = i; \ | 229 | 0 | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 0 | i = (i + (++step)) & mask; \ | 231 | 0 | if (i == last) return h->n_buckets; \ | 232 | 0 | } \ | 233 | 0 | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 698 | } else return 0; \ | 235 | 698 | } \ |
Unexecuted instantiation: server.c:kh_get_h2o_quic_idmap Unexecuted instantiation: server.c:kh_get_h2o_quic_acceptmap Unexecuted instantiation: quicly.c:kh_get_quicly_stream_t Unexecuted instantiation: cache.c:kh_get_cache filecache.c:kh_get_opencache_set Line | Count | Source | 223 | 15.2k | { \ | 224 | 15.2k | if (h->n_buckets) { \ | 225 | 0 | khint_t k, i, last, mask, step = 0; \ | 226 | 0 | mask = h->n_buckets - 1; \ | 227 | 0 | k = __hash_func(key); i = k & mask; \ | 228 | 0 | last = i; \ | 229 | 0 | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 0 | i = (i + (++step)) & mask; \ | 231 | 0 | if (i == last) return h->n_buckets; \ | 232 | 0 | } \ | 233 | 0 | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 15.2k | } else return 0; \ | 235 | 15.2k | } \ |
Unexecuted instantiation: http3client.c:kh_get_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_get_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_get_stream Unexecuted instantiation: driver_h3.cc:kh_get_h2o_quic_idmap(kh_h2o_quic_idmap_s const*, unsigned int) Unexecuted instantiation: driver_h3.cc:kh_get_h2o_quic_acceptmap(kh_h2o_quic_acceptmap_s const*, unsigned long) quicly_mock.c:kh_get_quicly_stream_t Line | Count | Source | 223 | 26.0k | { \ | 224 | 26.0k | if (h->n_buckets) { \ | 225 | 26.0k | khint_t k, i, last, mask, step = 0; \ | 226 | 26.0k | mask = h->n_buckets - 1; \ | 227 | 26.0k | k = __hash_func(key); i = k & mask; \ | 228 | 26.0k | last = i; \ | 229 | 32.6k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 230 | 6.52k | i = (i + (++step)) & mask; \ | 231 | 6.52k | if (i == last) return h->n_buckets; \ | 232 | 6.52k | } \ | 233 | 26.0k | return __ac_iseither(h->flags, i)? h->n_buckets : i; \ | 234 | 26.0k | } else return 0; \ | 235 | 26.0k | } \ |
|
236 | | SCOPE int kh_resize_##name(kh_##name##_t *h, khint_t new_n_buckets) \ |
237 | 29.3k | { /* This function uses 0.25*n_buckets bytes of working space instead of [sizeof(key_t+val_t)+.25]*n_buckets. */ \ |
238 | 29.3k | khint32_t *new_flags = 0; \ |
239 | 29.3k | khint_t j = 1; \ |
240 | 29.3k | { \ |
241 | 29.3k | kroundup32(new_n_buckets); \ |
242 | 29.3k | if (new_n_buckets < 4) new_n_buckets = 4; \ |
243 | 29.3k | if (h->size >= (khint_t)(new_n_buckets * __ac_HASH_UPPER + 0.5)) j = 0; /* requested size is too small */ \ |
244 | 29.3k | else { /* hash table size to be changed (shrink or expand); rehash */ \ |
245 | 29.3k | new_flags = (khint32_t*)kmalloc(__ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ |
246 | 29.3k | if (!new_flags) return -1; \ |
247 | 29.3k | memset(new_flags, 0xaa, __ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ |
248 | 29.3k | if (h->n_buckets < new_n_buckets) { /* expand */ \ |
249 | 26.4k | khkey_t *new_keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ |
250 | 26.4k | if (!new_keys) { kfree(new_flags); return -1; } \ |
251 | 26.4k | h->keys = new_keys; \ |
252 | 26.4k | if (kh_is_map) { \ |
253 | 26.4k | khval_t *new_vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ |
254 | 26.4k | if (!new_vals) { kfree(new_flags); return -1; } \ |
255 | 26.4k | h->vals = new_vals; \ |
256 | 26.4k | } \ |
257 | 26.4k | } /* otherwise shrink */ \ |
258 | 29.3k | } \ |
259 | 29.3k | } \ |
260 | 29.3k | if (j) { /* rehashing is needed */ \ |
261 | 92.1k | for (j = 0; j != h->n_buckets; ++j) { \ |
262 | 62.7k | if (__ac_iseither(h->flags, j) == 0) { \ |
263 | 32.4k | khkey_t key = h->keys[j]; \ |
264 | 32.4k | khval_t val; \ |
265 | 32.4k | khint_t new_mask; \ |
266 | 32.4k | new_mask = new_n_buckets - 1; \ |
267 | 32.4k | if (kh_is_map) val = h->vals[j]; \ |
268 | 32.4k | __ac_set_isdel_true(h->flags, j); \ |
269 | 40.8k | while (1) { /* kick-out process; sort of like in Cuckoo hashing */ \ |
270 | 40.8k | khint_t k, i, step = 0; \ |
271 | 40.8k | k = __hash_func(key); \ |
272 | 40.8k | i = k & new_mask; \ |
273 | 60.9k | while (!__ac_isempty(new_flags, i)) i = (i + (++step)) & new_mask; \ |
274 | 40.8k | __ac_set_isempty_false(new_flags, i); \ |
275 | 40.8k | if (i < h->n_buckets && __ac_iseither(h->flags, i) == 0) { /* kick out the existing element */ \ |
276 | 8.42k | { khkey_t tmp = h->keys[i]; h->keys[i] = key; key = tmp; } \ |
277 | 8.42k | if (kh_is_map) { khval_t tmp = h->vals[i]; h->vals[i] = val; val = tmp; } \ |
278 | 8.42k | __ac_set_isdel_true(h->flags, i); /* mark it as deleted in the old hash table */ \ |
279 | 32.4k | } else { /* write the element and jump out of the loop */ \ |
280 | 32.4k | h->keys[i] = key; \ |
281 | 32.4k | if (kh_is_map) h->vals[i] = val; \ |
282 | 32.4k | break; \ |
283 | 32.4k | } \ |
284 | 40.8k | } \ |
285 | 32.4k | } \ |
286 | 62.7k | } \ |
287 | 29.3k | if (h->n_buckets > new_n_buckets) { /* shrink the hash table */ \ |
288 | 0 | h->keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ |
289 | 0 | if (kh_is_map) h->vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ |
290 | 0 | } \ |
291 | 29.3k | kfree(h->flags); /* free the working space */ \ |
292 | 29.3k | h->flags = new_flags; \ |
293 | 29.3k | h->n_buckets = new_n_buckets; \ |
294 | 29.3k | h->n_occupied = h->size; \ |
295 | 29.3k | h->upper_bound = (khint_t)(h->n_buckets * __ac_HASH_UPPER + 0.5); \ |
296 | 29.3k | } \ |
297 | 29.3k | return 0; \ |
298 | 29.3k | } \ mimemap.c:kh_resize_typeset Line | Count | Source | 237 | 42 | { /* This function uses 0.25*n_buckets bytes of working space instead of [sizeof(key_t+val_t)+.25]*n_buckets. */ \ | 238 | 42 | khint32_t *new_flags = 0; \ | 239 | 42 | khint_t j = 1; \ | 240 | 42 | { \ | 241 | 42 | kroundup32(new_n_buckets); \ | 242 | 42 | if (new_n_buckets < 4) new_n_buckets = 4; \ | 243 | 42 | if (h->size >= (khint_t)(new_n_buckets * __ac_HASH_UPPER + 0.5)) j = 0; /* requested size is too small */ \ | 244 | 42 | else { /* hash table size to be changed (shrink or expand); rehash */ \ | 245 | 42 | new_flags = (khint32_t*)kmalloc(__ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 246 | 42 | if (!new_flags) return -1; \ | 247 | 42 | memset(new_flags, 0xaa, __ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 248 | 42 | if (h->n_buckets < new_n_buckets) { /* expand */ \ | 249 | 42 | khkey_t *new_keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 250 | 42 | if (!new_keys) { kfree(new_flags); return -1; } \ | 251 | 42 | h->keys = new_keys; \ | 252 | 42 | if (kh_is_map) { \ | 253 | 0 | khval_t *new_vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 254 | 0 | if (!new_vals) { kfree(new_flags); return -1; } \ | 255 | 0 | h->vals = new_vals; \ | 256 | 0 | } \ | 257 | 42 | } /* otherwise shrink */ \ | 258 | 42 | } \ | 259 | 42 | } \ | 260 | 42 | if (j) { /* rehashing is needed */ \ | 261 | 1.55k | for (j = 0; j != h->n_buckets; ++j) { \ | 262 | 1.51k | if (__ac_iseither(h->flags, j) == 0) { \ | 263 | 1.16k | khkey_t key = h->keys[j]; \ | 264 | 1.16k | khval_t val; \ | 265 | 1.16k | khint_t new_mask; \ | 266 | 1.16k | new_mask = new_n_buckets - 1; \ | 267 | 1.16k | if (kh_is_map) val = h->vals[j]; \ | 268 | 1.16k | __ac_set_isdel_true(h->flags, j); \ | 269 | 1.16k | while (1) { /* kick-out process; sort of like in Cuckoo hashing */ \ | 270 | 1.16k | khint_t k, i, step = 0; \ | 271 | 1.16k | k = __hash_func(key); \ | 272 | 1.16k | i = k & new_mask; \ | 273 | 1.43k | while (!__ac_isempty(new_flags, i)) i = (i + (++step)) & new_mask; \ | 274 | 1.16k | __ac_set_isempty_false(new_flags, i); \ | 275 | 1.16k | if (i < h->n_buckets && __ac_iseither(h->flags, i) == 0) { /* kick out the existing element */ \ | 276 | 0 | { khkey_t tmp = h->keys[i]; h->keys[i] = key; key = tmp; } \ | 277 | 0 | if (kh_is_map) { khval_t tmp = h->vals[i]; h->vals[i] = val; val = tmp; } \ | 278 | 0 | __ac_set_isdel_true(h->flags, i); /* mark it as deleted in the old hash table */ \ | 279 | 1.16k | } else { /* write the element and jump out of the loop */ \ | 280 | 1.16k | h->keys[i] = key; \ | 281 | 1.16k | if (kh_is_map) h->vals[i] = val; \ | 282 | 1.16k | break; \ | 283 | 1.16k | } \ | 284 | 1.16k | } \ | 285 | 1.16k | } \ | 286 | 1.51k | } \ | 287 | 42 | if (h->n_buckets > new_n_buckets) { /* shrink the hash table */ \ | 288 | 0 | h->keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 289 | 0 | if (kh_is_map) h->vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 290 | 0 | } \ | 291 | 42 | kfree(h->flags); /* free the working space */ \ | 292 | 42 | h->flags = new_flags; \ | 293 | 42 | h->n_buckets = new_n_buckets; \ | 294 | 42 | h->n_occupied = h->size; \ | 295 | 42 | h->upper_bound = (khint_t)(h->n_buckets * __ac_HASH_UPPER + 0.5); \ | 296 | 42 | } \ | 297 | 42 | return 0; \ | 298 | 42 | } \ |
mimemap.c:kh_resize_extmap Line | Count | Source | 237 | 42 | { /* This function uses 0.25*n_buckets bytes of working space instead of [sizeof(key_t+val_t)+.25]*n_buckets. */ \ | 238 | 42 | khint32_t *new_flags = 0; \ | 239 | 42 | khint_t j = 1; \ | 240 | 42 | { \ | 241 | 42 | kroundup32(new_n_buckets); \ | 242 | 42 | if (new_n_buckets < 4) new_n_buckets = 4; \ | 243 | 42 | if (h->size >= (khint_t)(new_n_buckets * __ac_HASH_UPPER + 0.5)) j = 0; /* requested size is too small */ \ | 244 | 42 | else { /* hash table size to be changed (shrink or expand); rehash */ \ | 245 | 42 | new_flags = (khint32_t*)kmalloc(__ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 246 | 42 | if (!new_flags) return -1; \ | 247 | 42 | memset(new_flags, 0xaa, __ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 248 | 42 | if (h->n_buckets < new_n_buckets) { /* expand */ \ | 249 | 42 | khkey_t *new_keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 250 | 42 | if (!new_keys) { kfree(new_flags); return -1; } \ | 251 | 42 | h->keys = new_keys; \ | 252 | 42 | if (kh_is_map) { \ | 253 | 42 | khval_t *new_vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 254 | 42 | if (!new_vals) { kfree(new_flags); return -1; } \ | 255 | 42 | h->vals = new_vals; \ | 256 | 42 | } \ | 257 | 42 | } /* otherwise shrink */ \ | 258 | 42 | } \ | 259 | 42 | } \ | 260 | 42 | if (j) { /* rehashing is needed */ \ | 261 | 1.55k | for (j = 0; j != h->n_buckets; ++j) { \ | 262 | 1.51k | if (__ac_iseither(h->flags, j) == 0) { \ | 263 | 1.16k | khkey_t key = h->keys[j]; \ | 264 | 1.16k | khval_t val; \ | 265 | 1.16k | khint_t new_mask; \ | 266 | 1.16k | new_mask = new_n_buckets - 1; \ | 267 | 1.16k | if (kh_is_map) val = h->vals[j]; \ | 268 | 1.16k | __ac_set_isdel_true(h->flags, j); \ | 269 | 1.16k | while (1) { /* kick-out process; sort of like in Cuckoo hashing */ \ | 270 | 1.16k | khint_t k, i, step = 0; \ | 271 | 1.16k | k = __hash_func(key); \ | 272 | 1.16k | i = k & new_mask; \ | 273 | 1.54k | while (!__ac_isempty(new_flags, i)) i = (i + (++step)) & new_mask; \ | 274 | 1.16k | __ac_set_isempty_false(new_flags, i); \ | 275 | 1.16k | if (i < h->n_buckets && __ac_iseither(h->flags, i) == 0) { /* kick out the existing element */ \ | 276 | 0 | { khkey_t tmp = h->keys[i]; h->keys[i] = key; key = tmp; } \ | 277 | 0 | if (kh_is_map) { khval_t tmp = h->vals[i]; h->vals[i] = val; val = tmp; } \ | 278 | 0 | __ac_set_isdel_true(h->flags, i); /* mark it as deleted in the old hash table */ \ | 279 | 1.16k | } else { /* write the element and jump out of the loop */ \ | 280 | 1.16k | h->keys[i] = key; \ | 281 | 1.16k | if (kh_is_map) h->vals[i] = val; \ | 282 | 1.16k | break; \ | 283 | 1.16k | } \ | 284 | 1.16k | } \ | 285 | 1.16k | } \ | 286 | 1.51k | } \ | 287 | 42 | if (h->n_buckets > new_n_buckets) { /* shrink the hash table */ \ | 288 | 0 | h->keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 289 | 0 | if (kh_is_map) h->vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 290 | 0 | } \ | 291 | 42 | kfree(h->flags); /* free the working space */ \ | 292 | 42 | h->flags = new_flags; \ | 293 | 42 | h->n_buckets = new_n_buckets; \ | 294 | 42 | h->n_occupied = h->size; \ | 295 | 42 | h->upper_bound = (khint_t)(h->n_buckets * __ac_HASH_UPPER + 0.5); \ | 296 | 42 | } \ | 297 | 42 | return 0; \ | 298 | 42 | } \ |
connection.c:kh_resize_h2o_http2_stream_t Line | Count | Source | 237 | 16.2k | { /* This function uses 0.25*n_buckets bytes of working space instead of [sizeof(key_t+val_t)+.25]*n_buckets. */ \ | 238 | 16.2k | khint32_t *new_flags = 0; \ | 239 | 16.2k | khint_t j = 1; \ | 240 | 16.2k | { \ | 241 | 16.2k | kroundup32(new_n_buckets); \ | 242 | 16.2k | if (new_n_buckets < 4) new_n_buckets = 4; \ | 243 | 16.2k | if (h->size >= (khint_t)(new_n_buckets * __ac_HASH_UPPER + 0.5)) j = 0; /* requested size is too small */ \ | 244 | 16.2k | else { /* hash table size to be changed (shrink or expand); rehash */ \ | 245 | 16.2k | new_flags = (khint32_t*)kmalloc(__ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 246 | 16.2k | if (!new_flags) return -1; \ | 247 | 16.2k | memset(new_flags, 0xaa, __ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 248 | 16.2k | if (h->n_buckets < new_n_buckets) { /* expand */ \ | 249 | 13.3k | khkey_t *new_keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 250 | 13.3k | if (!new_keys) { kfree(new_flags); return -1; } \ | 251 | 13.3k | h->keys = new_keys; \ | 252 | 13.3k | if (kh_is_map) { \ | 253 | 13.3k | khval_t *new_vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 254 | 13.3k | if (!new_vals) { kfree(new_flags); return -1; } \ | 255 | 13.3k | h->vals = new_vals; \ | 256 | 13.3k | } \ | 257 | 13.3k | } /* otherwise shrink */ \ | 258 | 16.2k | } \ | 259 | 16.2k | } \ | 260 | 16.2k | if (j) { /* rehashing is needed */ \ | 261 | 49.8k | for (j = 0; j != h->n_buckets; ++j) { \ | 262 | 33.6k | if (__ac_iseither(h->flags, j) == 0) { \ | 263 | 17.0k | khkey_t key = h->keys[j]; \ | 264 | 17.0k | khval_t val; \ | 265 | 17.0k | khint_t new_mask; \ | 266 | 17.0k | new_mask = new_n_buckets - 1; \ | 267 | 17.0k | if (kh_is_map) val = h->vals[j]; \ | 268 | 17.0k | __ac_set_isdel_true(h->flags, j); \ | 269 | 18.9k | while (1) { /* kick-out process; sort of like in Cuckoo hashing */ \ | 270 | 18.9k | khint_t k, i, step = 0; \ | 271 | 18.9k | k = __hash_func(key); \ | 272 | 18.9k | i = k & new_mask; \ | 273 | 31.9k | while (!__ac_isempty(new_flags, i)) i = (i + (++step)) & new_mask; \ | 274 | 18.9k | __ac_set_isempty_false(new_flags, i); \ | 275 | 18.9k | if (i < h->n_buckets && __ac_iseither(h->flags, i) == 0) { /* kick out the existing element */ \ | 276 | 1.90k | { khkey_t tmp = h->keys[i]; h->keys[i] = key; key = tmp; } \ | 277 | 1.90k | if (kh_is_map) { khval_t tmp = h->vals[i]; h->vals[i] = val; val = tmp; } \ | 278 | 1.90k | __ac_set_isdel_true(h->flags, i); /* mark it as deleted in the old hash table */ \ | 279 | 17.0k | } else { /* write the element and jump out of the loop */ \ | 280 | 17.0k | h->keys[i] = key; \ | 281 | 17.0k | if (kh_is_map) h->vals[i] = val; \ | 282 | 17.0k | break; \ | 283 | 17.0k | } \ | 284 | 18.9k | } \ | 285 | 17.0k | } \ | 286 | 33.6k | } \ | 287 | 16.2k | if (h->n_buckets > new_n_buckets) { /* shrink the hash table */ \ | 288 | 0 | h->keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 289 | 0 | if (kh_is_map) h->vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 290 | 0 | } \ | 291 | 16.2k | kfree(h->flags); /* free the working space */ \ | 292 | 16.2k | h->flags = new_flags; \ | 293 | 16.2k | h->n_buckets = new_n_buckets; \ | 294 | 16.2k | h->n_occupied = h->size; \ | 295 | 16.2k | h->upper_bound = (khint_t)(h->n_buckets * __ac_HASH_UPPER + 0.5); \ | 296 | 16.2k | } \ | 297 | 16.2k | return 0; \ | 298 | 16.2k | } \ |
Unexecuted instantiation: scheduler.c:kh_resize_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_resize_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_resize_h2o_http2_stream_t Unexecuted instantiation: common.c:kh_resize_h2o_quic_acceptmap common.c:kh_resize_h2o_quic_idmap Line | Count | Source | 237 | 1 | { /* This function uses 0.25*n_buckets bytes of working space instead of [sizeof(key_t+val_t)+.25]*n_buckets. */ \ | 238 | 1 | khint32_t *new_flags = 0; \ | 239 | 1 | khint_t j = 1; \ | 240 | 1 | { \ | 241 | 1 | kroundup32(new_n_buckets); \ | 242 | 1 | if (new_n_buckets < 4) new_n_buckets = 4; \ | 243 | 1 | if (h->size >= (khint_t)(new_n_buckets * __ac_HASH_UPPER + 0.5)) j = 0; /* requested size is too small */ \ | 244 | 1 | else { /* hash table size to be changed (shrink or expand); rehash */ \ | 245 | 1 | new_flags = (khint32_t*)kmalloc(__ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 246 | 1 | if (!new_flags) return -1; \ | 247 | 1 | memset(new_flags, 0xaa, __ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 248 | 1 | if (h->n_buckets < new_n_buckets) { /* expand */ \ | 249 | 1 | khkey_t *new_keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 250 | 1 | if (!new_keys) { kfree(new_flags); return -1; } \ | 251 | 1 | h->keys = new_keys; \ | 252 | 1 | if (kh_is_map) { \ | 253 | 1 | khval_t *new_vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 254 | 1 | if (!new_vals) { kfree(new_flags); return -1; } \ | 255 | 1 | h->vals = new_vals; \ | 256 | 1 | } \ | 257 | 1 | } /* otherwise shrink */ \ | 258 | 1 | } \ | 259 | 1 | } \ | 260 | 1 | if (j) { /* rehashing is needed */ \ | 261 | 1 | for (j = 0; j != h->n_buckets; ++j) { \ | 262 | 0 | if (__ac_iseither(h->flags, j) == 0) { \ | 263 | 0 | khkey_t key = h->keys[j]; \ | 264 | 0 | khval_t val; \ | 265 | 0 | khint_t new_mask; \ | 266 | 0 | new_mask = new_n_buckets - 1; \ | 267 | 0 | if (kh_is_map) val = h->vals[j]; \ | 268 | 0 | __ac_set_isdel_true(h->flags, j); \ | 269 | 0 | while (1) { /* kick-out process; sort of like in Cuckoo hashing */ \ | 270 | 0 | khint_t k, i, step = 0; \ | 271 | 0 | k = __hash_func(key); \ | 272 | 0 | i = k & new_mask; \ | 273 | 0 | while (!__ac_isempty(new_flags, i)) i = (i + (++step)) & new_mask; \ | 274 | 0 | __ac_set_isempty_false(new_flags, i); \ | 275 | 0 | if (i < h->n_buckets && __ac_iseither(h->flags, i) == 0) { /* kick out the existing element */ \ | 276 | 0 | { khkey_t tmp = h->keys[i]; h->keys[i] = key; key = tmp; } \ | 277 | 0 | if (kh_is_map) { khval_t tmp = h->vals[i]; h->vals[i] = val; val = tmp; } \ | 278 | 0 | __ac_set_isdel_true(h->flags, i); /* mark it as deleted in the old hash table */ \ | 279 | 0 | } else { /* write the element and jump out of the loop */ \ | 280 | 0 | h->keys[i] = key; \ | 281 | 0 | if (kh_is_map) h->vals[i] = val; \ | 282 | 0 | break; \ | 283 | 0 | } \ | 284 | 0 | } \ | 285 | 0 | } \ | 286 | 0 | } \ | 287 | 1 | if (h->n_buckets > new_n_buckets) { /* shrink the hash table */ \ | 288 | 0 | h->keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 289 | 0 | if (kh_is_map) h->vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 290 | 0 | } \ | 291 | 1 | kfree(h->flags); /* free the working space */ \ | 292 | 1 | h->flags = new_flags; \ | 293 | 1 | h->n_buckets = new_n_buckets; \ | 294 | 1 | h->n_occupied = h->size; \ | 295 | 1 | h->upper_bound = (khint_t)(h->n_buckets * __ac_HASH_UPPER + 0.5); \ | 296 | 1 | } \ | 297 | 1 | return 0; \ | 298 | 1 | } \ |
Unexecuted instantiation: server.c:kh_resize_stream Unexecuted instantiation: server.c:kh_resize_h2o_quic_idmap Unexecuted instantiation: server.c:kh_resize_h2o_quic_acceptmap Unexecuted instantiation: quicly.c:kh_resize_quicly_stream_t Unexecuted instantiation: cache.c:kh_resize_cache Unexecuted instantiation: filecache.c:kh_resize_opencache_set Unexecuted instantiation: http3client.c:kh_resize_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_resize_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_resize_stream Unexecuted instantiation: driver_h3.cc:kh_resize_h2o_quic_idmap(kh_h2o_quic_idmap_s*, unsigned int) Unexecuted instantiation: driver_h3.cc:kh_resize_h2o_quic_acceptmap(kh_h2o_quic_acceptmap_s*, unsigned int) quicly_mock.c:kh_resize_quicly_stream_t Line | Count | Source | 237 | 13.0k | { /* This function uses 0.25*n_buckets bytes of working space instead of [sizeof(key_t+val_t)+.25]*n_buckets. */ \ | 238 | 13.0k | khint32_t *new_flags = 0; \ | 239 | 13.0k | khint_t j = 1; \ | 240 | 13.0k | { \ | 241 | 13.0k | kroundup32(new_n_buckets); \ | 242 | 13.0k | if (new_n_buckets < 4) new_n_buckets = 4; \ | 243 | 13.0k | if (h->size >= (khint_t)(new_n_buckets * __ac_HASH_UPPER + 0.5)) j = 0; /* requested size is too small */ \ | 244 | 13.0k | else { /* hash table size to be changed (shrink or expand); rehash */ \ | 245 | 13.0k | new_flags = (khint32_t*)kmalloc(__ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 246 | 13.0k | if (!new_flags) return -1; \ | 247 | 13.0k | memset(new_flags, 0xaa, __ac_fsize(new_n_buckets) * sizeof(khint32_t)); \ | 248 | 13.0k | if (h->n_buckets < new_n_buckets) { /* expand */ \ | 249 | 13.0k | khkey_t *new_keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 250 | 13.0k | if (!new_keys) { kfree(new_flags); return -1; } \ | 251 | 13.0k | h->keys = new_keys; \ | 252 | 13.0k | if (kh_is_map) { \ | 253 | 13.0k | khval_t *new_vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 254 | 13.0k | if (!new_vals) { kfree(new_flags); return -1; } \ | 255 | 13.0k | h->vals = new_vals; \ | 256 | 13.0k | } \ | 257 | 13.0k | } /* otherwise shrink */ \ | 258 | 13.0k | } \ | 259 | 13.0k | } \ | 260 | 13.0k | if (j) { /* rehashing is needed */ \ | 261 | 39.1k | for (j = 0; j != h->n_buckets; ++j) { \ | 262 | 26.0k | if (__ac_iseither(h->flags, j) == 0) { \ | 263 | 13.0k | khkey_t key = h->keys[j]; \ | 264 | 13.0k | khval_t val; \ | 265 | 13.0k | khint_t new_mask; \ | 266 | 13.0k | new_mask = new_n_buckets - 1; \ | 267 | 13.0k | if (kh_is_map) val = h->vals[j]; \ | 268 | 13.0k | __ac_set_isdel_true(h->flags, j); \ | 269 | 19.5k | while (1) { /* kick-out process; sort of like in Cuckoo hashing */ \ | 270 | 19.5k | khint_t k, i, step = 0; \ | 271 | 19.5k | k = __hash_func(key); \ | 272 | 19.5k | i = k & new_mask; \ | 273 | 26.0k | while (!__ac_isempty(new_flags, i)) i = (i + (++step)) & new_mask; \ | 274 | 19.5k | __ac_set_isempty_false(new_flags, i); \ | 275 | 19.5k | if (i < h->n_buckets && __ac_iseither(h->flags, i) == 0) { /* kick out the existing element */ \ | 276 | 6.52k | { khkey_t tmp = h->keys[i]; h->keys[i] = key; key = tmp; } \ | 277 | 6.52k | if (kh_is_map) { khval_t tmp = h->vals[i]; h->vals[i] = val; val = tmp; } \ | 278 | 6.52k | __ac_set_isdel_true(h->flags, i); /* mark it as deleted in the old hash table */ \ | 279 | 13.0k | } else { /* write the element and jump out of the loop */ \ | 280 | 13.0k | h->keys[i] = key; \ | 281 | 13.0k | if (kh_is_map) h->vals[i] = val; \ | 282 | 13.0k | break; \ | 283 | 13.0k | } \ | 284 | 19.5k | } \ | 285 | 13.0k | } \ | 286 | 26.0k | } \ | 287 | 13.0k | if (h->n_buckets > new_n_buckets) { /* shrink the hash table */ \ | 288 | 0 | h->keys = (khkey_t*)krealloc((void *)h->keys, new_n_buckets * sizeof(khkey_t)); \ | 289 | 0 | if (kh_is_map) h->vals = (khval_t*)krealloc((void *)h->vals, new_n_buckets * sizeof(khval_t)); \ | 290 | 0 | } \ | 291 | 13.0k | kfree(h->flags); /* free the working space */ \ | 292 | 13.0k | h->flags = new_flags; \ | 293 | 13.0k | h->n_buckets = new_n_buckets; \ | 294 | 13.0k | h->n_occupied = h->size; \ | 295 | 13.0k | h->upper_bound = (khint_t)(h->n_buckets * __ac_HASH_UPPER + 0.5); \ | 296 | 13.0k | } \ | 297 | 13.0k | return 0; \ | 298 | 13.0k | } \ |
|
299 | | SCOPE khint_t kh_put_##name(kh_##name##_t *h, khkey_t key, int *ret) \ |
300 | 118k | { \ |
301 | 118k | khint_t x; \ |
302 | 118k | if (h->n_occupied >= h->upper_bound) { /* update the hash table */ \ |
303 | 29.3k | if (h->n_buckets > (h->size<<1)) { \ |
304 | 2.90k | if (kh_resize_##name(h, h->n_buckets - 1) < 0) { /* clear "deleted" elements */ \ |
305 | 0 | *ret = -1; return h->n_buckets; \ |
306 | 0 | } \ |
307 | 26.4k | } else if (kh_resize_##name(h, h->n_buckets + 1) < 0) { /* expand the hash table */ \ |
308 | 0 | *ret = -1; return h->n_buckets; \ |
309 | 0 | } \ |
310 | 29.3k | } /* TODO: to implement automatically shrinking; resize() already support shrinking */ \ |
311 | 118k | { \ |
312 | 118k | khint_t k, i, site, last, mask = h->n_buckets - 1, step = 0; \ |
313 | 118k | x = site = h->n_buckets; k = __hash_func(key); i = k & mask; \ |
314 | 118k | if (__ac_isempty(h->flags, i)) x = i; /* for speed up */ \ |
315 | 118k | else { \ |
316 | 53.0k | last = i; \ |
317 | 148k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ |
318 | 95.0k | if (__ac_isdel(h->flags, i)) site = i; \ |
319 | 95.0k | i = (i + (++step)) & mask; \ |
320 | 95.0k | if (i == last) { x = site; break; } \ |
321 | 95.0k | } \ |
322 | 53.0k | if (x == h->n_buckets) { \ |
323 | 53.0k | if (__ac_isempty(h->flags, i) && site != h->n_buckets) x = site; \ |
324 | 53.0k | else x = i; \ |
325 | 53.0k | } \ |
326 | 53.0k | } \ |
327 | 118k | } \ |
328 | 118k | if (__ac_isempty(h->flags, x)) { /* not present at all */ \ |
329 | 100k | h->keys[x] = key; \ |
330 | 100k | __ac_set_isboth_false(h->flags, x); \ |
331 | 100k | ++h->size; ++h->n_occupied; \ |
332 | 100k | *ret = 1; \ |
333 | 100k | } else if (__ac_isdel(h->flags, x)) { /* deleted */ \ |
334 | 17.6k | h->keys[x] = key; \ |
335 | 17.6k | __ac_set_isboth_false(h->flags, x); \ |
336 | 17.6k | ++h->size; \ |
337 | 17.6k | *ret = 2; \ |
338 | 17.6k | } else *ret = 0; /* Don't touch h->keys[x] if present and not deleted */ \ |
339 | 118k | return x; \ |
340 | 118k | } \ Line | Count | Source | 300 | 41.7k | { \ | 301 | 41.7k | khint_t x; \ | 302 | 41.7k | if (h->n_occupied >= h->upper_bound) { /* update the hash table */ \ | 303 | 42 | if (h->n_buckets > (h->size<<1)) { \ | 304 | 0 | if (kh_resize_##name(h, h->n_buckets - 1) < 0) { /* clear "deleted" elements */ \ | 305 | 0 | *ret = -1; return h->n_buckets; \ | 306 | 0 | } \ | 307 | 42 | } else if (kh_resize_##name(h, h->n_buckets + 1) < 0) { /* expand the hash table */ \ | 308 | 0 | *ret = -1; return h->n_buckets; \ | 309 | 0 | } \ | 310 | 42 | } /* TODO: to implement automatically shrinking; resize() already support shrinking */ \ | 311 | 41.7k | { \ | 312 | 41.7k | khint_t k, i, site, last, mask = h->n_buckets - 1, step = 0; \ | 313 | 41.7k | x = site = h->n_buckets; k = __hash_func(key); i = k & mask; \ | 314 | 41.7k | if (__ac_isempty(h->flags, i)) x = i; /* for speed up */ \ | 315 | 41.7k | else { \ | 316 | 8.59k | last = i; \ | 317 | 25.8k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 318 | 17.2k | if (__ac_isdel(h->flags, i)) site = i; \ | 319 | 17.2k | i = (i + (++step)) & mask; \ | 320 | 17.2k | if (i == last) { x = site; break; } \ | 321 | 17.2k | } \ | 322 | 8.59k | if (x == h->n_buckets) { \ | 323 | 8.59k | if (__ac_isempty(h->flags, i) && site != h->n_buckets) x = site; \ | 324 | 8.59k | else x = i; \ | 325 | 8.59k | } \ | 326 | 8.59k | } \ | 327 | 41.7k | } \ | 328 | 41.7k | if (__ac_isempty(h->flags, x)) { /* not present at all */ \ | 329 | 41.7k | h->keys[x] = key; \ | 330 | 41.7k | __ac_set_isboth_false(h->flags, x); \ | 331 | 41.7k | ++h->size; ++h->n_occupied; \ | 332 | 41.7k | *ret = 1; \ | 333 | 41.7k | } else if (__ac_isdel(h->flags, x)) { /* deleted */ \ | 334 | 0 | h->keys[x] = key; \ | 335 | 0 | __ac_set_isboth_false(h->flags, x); \ | 336 | 0 | ++h->size; \ | 337 | 0 | *ret = 2; \ | 338 | 0 | } else *ret = 0; /* Don't touch h->keys[x] if present and not deleted */ \ | 339 | 41.7k | return x; \ | 340 | 41.7k | } \ |
Line | Count | Source | 300 | 810 | { \ | 301 | 810 | khint_t x; \ | 302 | 810 | if (h->n_occupied >= h->upper_bound) { /* update the hash table */ \ | 303 | 42 | if (h->n_buckets > (h->size<<1)) { \ | 304 | 0 | if (kh_resize_##name(h, h->n_buckets - 1) < 0) { /* clear "deleted" elements */ \ | 305 | 0 | *ret = -1; return h->n_buckets; \ | 306 | 0 | } \ | 307 | 42 | } else if (kh_resize_##name(h, h->n_buckets + 1) < 0) { /* expand the hash table */ \ | 308 | 0 | *ret = -1; return h->n_buckets; \ | 309 | 0 | } \ | 310 | 42 | } /* TODO: to implement automatically shrinking; resize() already support shrinking */ \ | 311 | 810 | { \ | 312 | 810 | khint_t k, i, site, last, mask = h->n_buckets - 1, step = 0; \ | 313 | 810 | x = site = h->n_buckets; k = __hash_func(key); i = k & mask; \ | 314 | 810 | if (__ac_isempty(h->flags, i)) x = i; /* for speed up */ \ | 315 | 810 | else { \ | 316 | 486 | last = i; \ | 317 | 1.77k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 318 | 1.28k | if (__ac_isdel(h->flags, i)) site = i; \ | 319 | 1.28k | i = (i + (++step)) & mask; \ | 320 | 1.28k | if (i == last) { x = site; break; } \ | 321 | 1.28k | } \ | 322 | 486 | if (x == h->n_buckets) { \ | 323 | 486 | if (__ac_isempty(h->flags, i) && site != h->n_buckets) x = site; \ | 324 | 486 | else x = i; \ | 325 | 486 | } \ | 326 | 486 | } \ | 327 | 810 | } \ | 328 | 810 | if (__ac_isempty(h->flags, x)) { /* not present at all */ \ | 329 | 810 | h->keys[x] = key; \ | 330 | 810 | __ac_set_isboth_false(h->flags, x); \ | 331 | 810 | ++h->size; ++h->n_occupied; \ | 332 | 810 | *ret = 1; \ | 333 | 810 | } else if (__ac_isdel(h->flags, x)) { /* deleted */ \ | 334 | 0 | h->keys[x] = key; \ | 335 | 0 | __ac_set_isboth_false(h->flags, x); \ | 336 | 0 | ++h->size; \ | 337 | 0 | *ret = 2; \ | 338 | 0 | } else *ret = 0; /* Don't touch h->keys[x] if present and not deleted */ \ | 339 | 810 | return x; \ | 340 | 810 | } \ |
connection.c:kh_put_h2o_http2_stream_t Line | Count | Source | 300 | 43.1k | { \ | 301 | 43.1k | khint_t x; \ | 302 | 43.1k | if (h->n_occupied >= h->upper_bound) { /* update the hash table */ \ | 303 | 16.2k | if (h->n_buckets > (h->size<<1)) { \ | 304 | 2.90k | if (kh_resize_##name(h, h->n_buckets - 1) < 0) { /* clear "deleted" elements */ \ | 305 | 0 | *ret = -1; return h->n_buckets; \ | 306 | 0 | } \ | 307 | 13.3k | } else if (kh_resize_##name(h, h->n_buckets + 1) < 0) { /* expand the hash table */ \ | 308 | 0 | *ret = -1; return h->n_buckets; \ | 309 | 0 | } \ | 310 | 16.2k | } /* TODO: to implement automatically shrinking; resize() already support shrinking */ \ | 311 | 43.1k | { \ | 312 | 43.1k | khint_t k, i, site, last, mask = h->n_buckets - 1, step = 0; \ | 313 | 43.1k | x = site = h->n_buckets; k = __hash_func(key); i = k & mask; \ | 314 | 43.1k | if (__ac_isempty(h->flags, i)) x = i; /* for speed up */ \ | 315 | 43.1k | else { \ | 316 | 24.3k | last = i; \ | 317 | 74.8k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 318 | 50.4k | if (__ac_isdel(h->flags, i)) site = i; \ | 319 | 50.4k | i = (i + (++step)) & mask; \ | 320 | 50.4k | if (i == last) { x = site; break; } \ | 321 | 50.4k | } \ | 322 | 24.3k | if (x == h->n_buckets) { \ | 323 | 24.3k | if (__ac_isempty(h->flags, i) && site != h->n_buckets) x = site; \ | 324 | 24.3k | else x = i; \ | 325 | 24.3k | } \ | 326 | 24.3k | } \ | 327 | 43.1k | } \ | 328 | 43.1k | if (__ac_isempty(h->flags, x)) { /* not present at all */ \ | 329 | 31.9k | h->keys[x] = key; \ | 330 | 31.9k | __ac_set_isboth_false(h->flags, x); \ | 331 | 31.9k | ++h->size; ++h->n_occupied; \ | 332 | 31.9k | *ret = 1; \ | 333 | 31.9k | } else if (__ac_isdel(h->flags, x)) { /* deleted */ \ | 334 | 11.1k | h->keys[x] = key; \ | 335 | 11.1k | __ac_set_isboth_false(h->flags, x); \ | 336 | 11.1k | ++h->size; \ | 337 | 11.1k | *ret = 2; \ | 338 | 11.1k | } else *ret = 0; /* Don't touch h->keys[x] if present and not deleted */ \ | 339 | 43.1k | return x; \ | 340 | 43.1k | } \ |
Unexecuted instantiation: scheduler.c:kh_put_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_put_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_put_h2o_http2_stream_t Unexecuted instantiation: common.c:kh_put_h2o_quic_acceptmap common.c:kh_put_h2o_quic_idmap Line | Count | Source | 300 | 6.52k | { \ | 301 | 6.52k | khint_t x; \ | 302 | 6.52k | if (h->n_occupied >= h->upper_bound) { /* update the hash table */ \ | 303 | 1 | if (h->n_buckets > (h->size<<1)) { \ | 304 | 0 | if (kh_resize_##name(h, h->n_buckets - 1) < 0) { /* clear "deleted" elements */ \ | 305 | 0 | *ret = -1; return h->n_buckets; \ | 306 | 0 | } \ | 307 | 1 | } else if (kh_resize_##name(h, h->n_buckets + 1) < 0) { /* expand the hash table */ \ | 308 | 0 | *ret = -1; return h->n_buckets; \ | 309 | 0 | } \ | 310 | 1 | } /* TODO: to implement automatically shrinking; resize() already support shrinking */ \ | 311 | 6.52k | { \ | 312 | 6.52k | khint_t k, i, site, last, mask = h->n_buckets - 1, step = 0; \ | 313 | 6.52k | x = site = h->n_buckets; k = __hash_func(key); i = k & mask; \ | 314 | 6.52k | if (__ac_isempty(h->flags, i)) x = i; /* for speed up */ \ | 315 | 6.52k | else { \ | 316 | 6.52k | last = i; \ | 317 | 13.0k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 318 | 6.52k | if (__ac_isdel(h->flags, i)) site = i; \ | 319 | 6.52k | i = (i + (++step)) & mask; \ | 320 | 6.52k | if (i == last) { x = site; break; } \ | 321 | 6.52k | } \ | 322 | 6.52k | if (x == h->n_buckets) { \ | 323 | 6.52k | if (__ac_isempty(h->flags, i) && site != h->n_buckets) x = site; \ | 324 | 6.52k | else x = i; \ | 325 | 6.52k | } \ | 326 | 6.52k | } \ | 327 | 6.52k | } \ | 328 | 6.52k | if (__ac_isempty(h->flags, x)) { /* not present at all */ \ | 329 | 1 | h->keys[x] = key; \ | 330 | 1 | __ac_set_isboth_false(h->flags, x); \ | 331 | 1 | ++h->size; ++h->n_occupied; \ | 332 | 1 | *ret = 1; \ | 333 | 6.52k | } else if (__ac_isdel(h->flags, x)) { /* deleted */ \ | 334 | 6.52k | h->keys[x] = key; \ | 335 | 6.52k | __ac_set_isboth_false(h->flags, x); \ | 336 | 6.52k | ++h->size; \ | 337 | 6.52k | *ret = 2; \ | 338 | 6.52k | } else *ret = 0; /* Don't touch h->keys[x] if present and not deleted */ \ | 339 | 6.52k | return x; \ | 340 | 6.52k | } \ |
Unexecuted instantiation: server.c:kh_put_stream Unexecuted instantiation: server.c:kh_put_h2o_quic_idmap Unexecuted instantiation: server.c:kh_put_h2o_quic_acceptmap Unexecuted instantiation: quicly.c:kh_put_quicly_stream_t Unexecuted instantiation: cache.c:kh_put_cache Unexecuted instantiation: filecache.c:kh_put_opencache_set Unexecuted instantiation: http3client.c:kh_put_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_put_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_put_stream Unexecuted instantiation: driver_h3.cc:kh_put_h2o_quic_idmap(kh_h2o_quic_idmap_s*, unsigned int, int*) Unexecuted instantiation: driver_h3.cc:kh_put_h2o_quic_acceptmap(kh_h2o_quic_acceptmap_s*, unsigned long, int*) quicly_mock.c:kh_put_quicly_stream_t Line | Count | Source | 300 | 26.0k | { \ | 301 | 26.0k | khint_t x; \ | 302 | 26.0k | if (h->n_occupied >= h->upper_bound) { /* update the hash table */ \ | 303 | 13.0k | if (h->n_buckets > (h->size<<1)) { \ | 304 | 0 | if (kh_resize_##name(h, h->n_buckets - 1) < 0) { /* clear "deleted" elements */ \ | 305 | 0 | *ret = -1; return h->n_buckets; \ | 306 | 0 | } \ | 307 | 13.0k | } else if (kh_resize_##name(h, h->n_buckets + 1) < 0) { /* expand the hash table */ \ | 308 | 0 | *ret = -1; return h->n_buckets; \ | 309 | 0 | } \ | 310 | 13.0k | } /* TODO: to implement automatically shrinking; resize() already support shrinking */ \ | 311 | 26.0k | { \ | 312 | 26.0k | khint_t k, i, site, last, mask = h->n_buckets - 1, step = 0; \ | 313 | 26.0k | x = site = h->n_buckets; k = __hash_func(key); i = k & mask; \ | 314 | 26.0k | if (__ac_isempty(h->flags, i)) x = i; /* for speed up */ \ | 315 | 26.0k | else { \ | 316 | 13.0k | last = i; \ | 317 | 32.6k | while (!__ac_isempty(h->flags, i) && (__ac_isdel(h->flags, i) || !__hash_equal(h->keys[i], key))) { \ | 318 | 19.5k | if (__ac_isdel(h->flags, i)) site = i; \ | 319 | 19.5k | i = (i + (++step)) & mask; \ | 320 | 19.5k | if (i == last) { x = site; break; } \ | 321 | 19.5k | } \ | 322 | 13.0k | if (x == h->n_buckets) { \ | 323 | 13.0k | if (__ac_isempty(h->flags, i) && site != h->n_buckets) x = site; \ | 324 | 13.0k | else x = i; \ | 325 | 13.0k | } \ | 326 | 13.0k | } \ | 327 | 26.0k | } \ | 328 | 26.0k | if (__ac_isempty(h->flags, x)) { /* not present at all */ \ | 329 | 26.0k | h->keys[x] = key; \ | 330 | 26.0k | __ac_set_isboth_false(h->flags, x); \ | 331 | 26.0k | ++h->size; ++h->n_occupied; \ | 332 | 26.0k | *ret = 1; \ | 333 | 26.0k | } else if (__ac_isdel(h->flags, x)) { /* deleted */ \ | 334 | 0 | h->keys[x] = key; \ | 335 | 0 | __ac_set_isboth_false(h->flags, x); \ | 336 | 0 | ++h->size; \ | 337 | 0 | *ret = 2; \ | 338 | 0 | } else *ret = 0; /* Don't touch h->keys[x] if present and not deleted */ \ | 339 | 26.0k | return x; \ | 340 | 26.0k | } \ |
|
341 | | SCOPE void kh_del_##name(kh_##name##_t *h, khint_t x) \ |
342 | 75.7k | { \ |
343 | 75.7k | if (x != h->n_buckets && !__ac_iseither(h->flags, x)) { \ |
344 | 75.7k | __ac_set_isdel_true(h->flags, x); \ |
345 | 75.7k | --h->size; \ |
346 | 75.7k | } \ |
347 | 75.7k | } Unexecuted instantiation: mimemap.c:kh_del_extmap Unexecuted instantiation: mimemap.c:kh_del_typeset connection.c:kh_del_h2o_http2_stream_t Line | Count | Source | 342 | 43.1k | { \ | 343 | 43.1k | if (x != h->n_buckets && !__ac_iseither(h->flags, x)) { \ | 344 | 43.1k | __ac_set_isdel_true(h->flags, x); \ | 345 | 43.1k | --h->size; \ | 346 | 43.1k | } \ | 347 | 43.1k | } |
Unexecuted instantiation: scheduler.c:kh_del_h2o_http2_stream_t Unexecuted instantiation: stream.c:kh_del_h2o_http2_stream_t Unexecuted instantiation: http2_debug_state.c:kh_del_h2o_http2_stream_t common.c:kh_del_h2o_quic_idmap Line | Count | Source | 342 | 6.52k | { \ | 343 | 6.52k | if (x != h->n_buckets && !__ac_iseither(h->flags, x)) { \ | 344 | 6.52k | __ac_set_isdel_true(h->flags, x); \ | 345 | 6.52k | --h->size; \ | 346 | 6.52k | } \ | 347 | 6.52k | } |
Unexecuted instantiation: common.c:kh_del_h2o_quic_acceptmap Unexecuted instantiation: server.c:kh_del_stream Unexecuted instantiation: server.c:kh_del_h2o_quic_idmap Unexecuted instantiation: server.c:kh_del_h2o_quic_acceptmap Unexecuted instantiation: quicly.c:kh_del_quicly_stream_t Unexecuted instantiation: cache.c:kh_del_cache Unexecuted instantiation: filecache.c:kh_del_opencache_set Unexecuted instantiation: http3client.c:kh_del_h2o_quic_idmap Unexecuted instantiation: http3client.c:kh_del_h2o_quic_acceptmap Unexecuted instantiation: http2client.c:kh_del_stream Unexecuted instantiation: driver_h3.cc:kh_del_h2o_quic_idmap(kh_h2o_quic_idmap_s*, unsigned int) Unexecuted instantiation: driver_h3.cc:kh_del_h2o_quic_acceptmap(kh_h2o_quic_acceptmap_s*, unsigned int) quicly_mock.c:kh_del_quicly_stream_t Line | Count | Source | 342 | 26.0k | { \ | 343 | 26.0k | if (x != h->n_buckets && !__ac_iseither(h->flags, x)) { \ | 344 | 26.0k | __ac_set_isdel_true(h->flags, x); \ | 345 | 26.0k | --h->size; \ | 346 | 26.0k | } \ | 347 | 26.0k | } |
|
348 | | |
349 | | #define KHASH_DECLARE(name, khkey_t, khval_t) \ |
350 | | __KHASH_TYPE(name, khkey_t, khval_t) \ |
351 | | __KHASH_PROTOTYPES(name, khkey_t, khval_t) |
352 | | |
353 | | #define KHASH_INIT2(name, SCOPE, khkey_t, khval_t, kh_is_map, __hash_func, __hash_equal) \ |
354 | | __KHASH_TYPE(name, khkey_t, khval_t) \ |
355 | | __KHASH_IMPL(name, SCOPE, khkey_t, khval_t, kh_is_map, __hash_func, __hash_equal) |
356 | | |
357 | | #define KHASH_INIT(name, khkey_t, khval_t, kh_is_map, __hash_func, __hash_equal) \ |
358 | | KHASH_INIT2(name, static kh_inline, khkey_t, khval_t, kh_is_map, __hash_func, __hash_equal) |
359 | | |
360 | | /* --- BEGIN OF HASH FUNCTIONS --- */ |
361 | | |
362 | | /*! @function |
363 | | @abstract Integer hash function |
364 | | @param key The integer [khint32_t] |
365 | | @return The hash value [khint_t] |
366 | | */ |
367 | 13.0k | #define kh_int_hash_func(key) (khint32_t)(key) |
368 | | /*! @function |
369 | | @abstract Integer comparison function |
370 | | */ |
371 | 6.52k | #define kh_int_hash_equal(a, b) ((a) == (b)) |
372 | | /*! @function |
373 | | @abstract 64-bit integer hash function |
374 | | @param key The integer [khint64_t] |
375 | | @return The hash value [khint_t] |
376 | | */ |
377 | 290k | #define kh_int64_hash_func(key) (khint32_t)((key)>>33^(key)^(key)<<11) |
378 | | /*! @function |
379 | | @abstract 64-bit integer comparison function |
380 | | */ |
381 | 301k | #define kh_int64_hash_equal(a, b) ((a) == (b)) |
382 | | /*! @function |
383 | | @abstract const char* hash function |
384 | | @param s Pointer to a null terminated string |
385 | | @return The hash value |
386 | | */ |
387 | | static kh_inline khint_t __ac_X31_hash_string(const char *s) |
388 | 2.77k | { |
389 | 2.77k | khint_t h = (khint_t)*s; |
390 | 9.00k | if (h) for (++s ; *s; ++s) h = (h << 5) - h + (khint_t)*s; |
391 | 2.77k | return h; |
392 | 2.77k | } mimemap.c:__ac_X31_hash_string Line | Count | Source | 388 | 2.77k | { | 389 | 2.77k | khint_t h = (khint_t)*s; | 390 | 9.00k | if (h) for (++s ; *s; ++s) h = (h << 5) - h + (khint_t)*s; | 391 | 2.77k | return h; | 392 | 2.77k | } |
Unexecuted instantiation: connection.c:__ac_X31_hash_string Unexecuted instantiation: scheduler.c:__ac_X31_hash_string Unexecuted instantiation: stream.c:__ac_X31_hash_string Unexecuted instantiation: http2_debug_state.c:__ac_X31_hash_string Unexecuted instantiation: common.c:__ac_X31_hash_string Unexecuted instantiation: server.c:__ac_X31_hash_string Unexecuted instantiation: quicly.c:__ac_X31_hash_string Unexecuted instantiation: cache.c:__ac_X31_hash_string Unexecuted instantiation: filecache.c:__ac_X31_hash_string Unexecuted instantiation: http3client.c:__ac_X31_hash_string Unexecuted instantiation: http2client.c:__ac_X31_hash_string Unexecuted instantiation: driver_h3.cc:__ac_X31_hash_string(char const*) Unexecuted instantiation: quicly_mock.c:__ac_X31_hash_string |
393 | | /*! @function |
394 | | @abstract Another interface to const char* hash function |
395 | | @param key Pointer to a null terminated string [const char*] |
396 | | @return The hash value [khint_t] |
397 | | */ |
398 | 2.77k | #define kh_str_hash_func(key) __ac_X31_hash_string(key) |
399 | | /*! @function |
400 | | @abstract Const char* comparison function |
401 | | */ |
402 | 2.61k | #define kh_str_hash_equal(a, b) (strcmp(a, b) == 0) |
403 | | |
404 | | static kh_inline khint_t __ac_Wang_hash(khint_t key) |
405 | 0 | { |
406 | 0 | key += ~(key << 15); |
407 | 0 | key ^= (key >> 10); |
408 | 0 | key += (key << 3); |
409 | 0 | key ^= (key >> 6); |
410 | 0 | key += ~(key << 11); |
411 | 0 | key ^= (key >> 16); |
412 | 0 | return key; |
413 | 0 | } Unexecuted instantiation: mimemap.c:__ac_Wang_hash Unexecuted instantiation: connection.c:__ac_Wang_hash Unexecuted instantiation: scheduler.c:__ac_Wang_hash Unexecuted instantiation: stream.c:__ac_Wang_hash Unexecuted instantiation: http2_debug_state.c:__ac_Wang_hash Unexecuted instantiation: common.c:__ac_Wang_hash Unexecuted instantiation: server.c:__ac_Wang_hash Unexecuted instantiation: quicly.c:__ac_Wang_hash Unexecuted instantiation: cache.c:__ac_Wang_hash Unexecuted instantiation: filecache.c:__ac_Wang_hash Unexecuted instantiation: http3client.c:__ac_Wang_hash Unexecuted instantiation: http2client.c:__ac_Wang_hash Unexecuted instantiation: driver_h3.cc:__ac_Wang_hash(unsigned int) Unexecuted instantiation: quicly_mock.c:__ac_Wang_hash |
414 | | #define kh_int_hash_func2(k) __ac_Wang_hash((khint_t)key) |
415 | | |
416 | | /* --- END OF HASH FUNCTIONS --- */ |
417 | | |
418 | | /* Other convenient macros... */ |
419 | | |
420 | | /*! |
421 | | @abstract Type of the hash table. |
422 | | @param name Name of the hash table [symbol] |
423 | | */ |
424 | | #define khash_t(name) kh_##name##_t |
425 | | |
426 | | /*! @function |
427 | | @abstract Initiate a hash table. |
428 | | @param name Name of the hash table [symbol] |
429 | | @return Pointer to the hash table [khash_t(name)*] |
430 | | */ |
431 | 26.4k | #define kh_init(name) kh_init_##name() |
432 | | |
433 | | /*! @function |
434 | | @abstract Destroy a hash table. |
435 | | @param name Name of the hash table [symbol] |
436 | | @param h Pointer to the hash table [khash_t(name)*] |
437 | | */ |
438 | 26.3k | #define kh_destroy(name, h) kh_destroy_##name(h) |
439 | | |
440 | | /*! @function |
441 | | @abstract Reset a hash table without deallocating memory. |
442 | | @param name Name of the hash table [symbol] |
443 | | @param h Pointer to the hash table [khash_t(name)*] |
444 | | */ |
445 | 816 | #define kh_clear(name, h) kh_clear_##name(h) |
446 | | |
447 | | /*! @function |
448 | | @abstract Resize a hash table. |
449 | | @param name Name of the hash table [symbol] |
450 | | @param h Pointer to the hash table [khash_t(name)*] |
451 | | @param s New size [khint_t] |
452 | | */ |
453 | | #define kh_resize(name, h, s) kh_resize_##name(h, s) |
454 | | |
455 | | /*! @function |
456 | | @abstract Insert a key to the hash table. |
457 | | @param name Name of the hash table [symbol] |
458 | | @param h Pointer to the hash table [khash_t(name)*] |
459 | | @param k Key [type of keys] |
460 | | @param r Extra return code: -1 if the operation failed; |
461 | | 0 if the key is present in the hash table; |
462 | | 1 if the bucket is empty (never used); 2 if the element in |
463 | | the bucket has been deleted [int*] |
464 | | @return Iterator to the inserted element [khint_t] |
465 | | */ |
466 | 70.0k | #define kh_put(name, h, k, r) kh_put_##name(h, k, r) |
467 | | |
468 | | /*! @function |
469 | | @abstract Retrieve a key from the hash table. |
470 | | @param name Name of the hash table [symbol] |
471 | | @param h Pointer to the hash table [khash_t(name)*] |
472 | | @param k Key [type of keys] |
473 | | @return Iterator to the found element, or kh_end(h) if the element is absent [khint_t] |
474 | | */ |
475 | 212k | #define kh_get(name, h, k) kh_get_##name(h, k) |
476 | | |
477 | | /*! @function |
478 | | @abstract Remove a key from the hash table. |
479 | | @param name Name of the hash table [symbol] |
480 | | @param h Pointer to the hash table [khash_t(name)*] |
481 | | @param k Iterator to the element to be deleted [khint_t] |
482 | | */ |
483 | 69.9k | #define kh_del(name, h, k) kh_del_##name(h, k) |
484 | | |
485 | | /*! @function |
486 | | @abstract Test whether a bucket contains data. |
487 | | @param h Pointer to the hash table [khash_t(name)*] |
488 | | @param x Iterator to the bucket [khint_t] |
489 | | @return 1 if containing data; 0 otherwise [int] |
490 | | */ |
491 | 263k | #define kh_exist(h, x) (!__ac_iseither((h)->flags, (x))) |
492 | | |
493 | | /*! @function |
494 | | @abstract Get key given an iterator |
495 | | @param h Pointer to the hash table [khash_t(name)*] |
496 | | @param x Iterator to the bucket [khint_t] |
497 | | @return Key [type of keys] |
498 | | */ |
499 | 56.4k | #define kh_key(h, x) ((h)->keys[x]) |
500 | | |
501 | | /*! @function |
502 | | @abstract Get value given an iterator |
503 | | @param h Pointer to the hash table [khash_t(name)*] |
504 | | @param x Iterator to the bucket [khint_t] |
505 | | @return Value [type of values] |
506 | | @discussion For hash sets, calling this results in segfault. |
507 | | */ |
508 | 226k | #define kh_val(h, x) ((h)->vals[x]) |
509 | | |
510 | | /*! @function |
511 | | @abstract Alias of kh_val() |
512 | | */ |
513 | | #define kh_value(h, x) ((h)->vals[x]) |
514 | | |
515 | | /*! @function |
516 | | @abstract Get the start iterator |
517 | | @param h Pointer to the hash table [khash_t(name)*] |
518 | | @return The start iterator [khint_t] |
519 | | */ |
520 | 27.0k | #define kh_begin(h) (khint_t)(0) |
521 | | |
522 | | /*! @function |
523 | | @abstract Get the end iterator |
524 | | @param h Pointer to the hash table [khash_t(name)*] |
525 | | @return The end iterator [khint_t] |
526 | | */ |
527 | 440k | #define kh_end(h) ((h)->n_buckets) |
528 | | |
529 | | /*! @function |
530 | | @abstract Get the number of elements in the hash table |
531 | | @param h Pointer to the hash table [khash_t(name)*] |
532 | | @return Number of elements in the hash table [khint_t] |
533 | | */ |
534 | 0 | #define kh_size(h) ((h)->size) |
535 | | |
536 | | /*! @function |
537 | | @abstract Get the number of buckets in the hash table |
538 | | @param h Pointer to the hash table [khash_t(name)*] |
539 | | @return Number of buckets in the hash table [khint_t] |
540 | | */ |
541 | | #define kh_n_buckets(h) ((h)->n_buckets) |
542 | | |
543 | | /*! @function |
544 | | @abstract Iterate over the entries in the hash table |
545 | | @param h Pointer to the hash table [khash_t(name)*] |
546 | | @param kvar Variable to which key will be assigned |
547 | | @param vvar Variable to which value will be assigned |
548 | | @param code Block of code to execute |
549 | | */ |
550 | 819 | #define kh_foreach(h, kvar, vvar, code) { khint_t __i; \ |
551 | 109k | for (__i = kh_begin(h); __i != kh_end(h); ++__i) { \ |
552 | 108k | if (!kh_exist(h,__i)) continue; \ |
553 | 108k | (kvar) = kh_key(h,__i); \ |
554 | 56.2k | (vvar) = kh_val(h,__i); \ |
555 | 209k | code; \ |
556 | 405 | } } |
557 | | |
558 | | /*! @function |
559 | | @abstract Iterate over the values in the hash table |
560 | | @param h Pointer to the hash table [khash_t(name)*] |
561 | | @param vvar Variable to which value will be assigned |
562 | | @param code Block of code to execute |
563 | | */ |
564 | 26.2k | #define kh_foreach_value(h, vvar, code) { khint_t __i; \ |
565 | 181k | for (__i = kh_begin(h); __i != kh_end(h); ++__i) { \ |
566 | 155k | if (!kh_exist(h,__i)) continue; \ |
567 | 155k | (vvar) = kh_val(h,__i); \ |
568 | 52.4k | code; \ |
569 | 0 | } } |
570 | | |
571 | | /* More conenient interfaces */ |
572 | | |
573 | | /*! @function |
574 | | @abstract Instantiate a hash set containing integer keys |
575 | | @param name Name of the hash table [symbol] |
576 | | */ |
577 | | #define KHASH_SET_INIT_INT(name) \ |
578 | | KHASH_INIT(name, khint32_t, char, 0, kh_int_hash_func, kh_int_hash_equal) |
579 | | |
580 | | /*! @function |
581 | | @abstract Instantiate a hash map containing integer keys |
582 | | @param name Name of the hash table [symbol] |
583 | | @param khval_t Type of values [type] |
584 | | */ |
585 | | #define KHASH_MAP_INIT_INT(name, khval_t) \ |
586 | 13.0k | KHASH_INIT(name, khint32_t, khval_t, 1, kh_int_hash_func, kh_int_hash_equal) |
587 | | |
588 | | /*! @function |
589 | | @abstract Instantiate a hash map containing 64-bit integer keys |
590 | | @param name Name of the hash table [symbol] |
591 | | */ |
592 | | #define KHASH_SET_INIT_INT64(name) \ |
593 | | KHASH_INIT(name, khint64_t, char, 0, kh_int64_hash_func, kh_int64_hash_equal) |
594 | | |
595 | | /*! @function |
596 | | @abstract Instantiate a hash map containing 64-bit integer keys |
597 | | @param name Name of the hash table [symbol] |
598 | | @param khval_t Type of values [type] |
599 | | */ |
600 | | #define KHASH_MAP_INIT_INT64(name, khval_t) \ |
601 | 301k | KHASH_INIT(name, khint64_t, khval_t, 1, kh_int64_hash_func, kh_int64_hash_equal) |
602 | | |
603 | | typedef const char *kh_cstr_t; |
604 | | /*! @function |
605 | | @abstract Instantiate a hash map containing const char* keys |
606 | | @param name Name of the hash table [symbol] |
607 | | */ |
608 | | #define KHASH_SET_INIT_STR(name) \ |
609 | 0 | KHASH_INIT(name, kh_cstr_t, char, 0, kh_str_hash_func, kh_str_hash_equal) |
610 | | |
611 | | /*! @function |
612 | | @abstract Instantiate a hash map containing const char* keys |
613 | | @param name Name of the hash table [symbol] |
614 | | @param khval_t Type of values [type] |
615 | | */ |
616 | | #define KHASH_MAP_INIT_STR(name, khval_t) \ |
617 | 2.77k | KHASH_INIT(name, kh_cstr_t, khval_t, 1, kh_str_hash_func, kh_str_hash_equal) |
618 | | |
619 | | #endif /* __AC_KHASH_H */ |