radixtree.c revision 1.4 1 1.4 yamt /* $NetBSD: radixtree.c,v 1.4 2011/05/19 09:58:28 yamt Exp $ */
2 1.1 yamt
3 1.1 yamt /*-
4 1.1 yamt * Copyright (c)2011 YAMAMOTO Takashi,
5 1.1 yamt * All rights reserved.
6 1.1 yamt *
7 1.1 yamt * Redistribution and use in source and binary forms, with or without
8 1.1 yamt * modification, are permitted provided that the following conditions
9 1.1 yamt * are met:
10 1.1 yamt * 1. Redistributions of source code must retain the above copyright
11 1.1 yamt * notice, this list of conditions and the following disclaimer.
12 1.1 yamt * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 yamt * notice, this list of conditions and the following disclaimer in the
14 1.1 yamt * documentation and/or other materials provided with the distribution.
15 1.1 yamt *
16 1.1 yamt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 1.1 yamt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 1.1 yamt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 1.1 yamt * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 1.1 yamt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 1.1 yamt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 1.1 yamt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 1.1 yamt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 1.1 yamt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 1.1 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 1.1 yamt * SUCH DAMAGE.
27 1.1 yamt */
28 1.1 yamt
29 1.1 yamt /*
30 1.1 yamt * radix tree
31 1.1 yamt *
32 1.1 yamt * it's designed to work efficiently with dense index distribution.
33 1.1 yamt * the memory consumption (number of necessary intermediate nodes)
34 1.1 yamt * heavily depends on index distribution. basically, more dense index
35 1.1 yamt * distribution consumes less nodes per item.
36 1.1 yamt * approximately,
37 1.1 yamt * the best case: about RADIX_TREE_PTR_PER_NODE items per node.
38 1.1 yamt * the worst case: RADIX_TREE_MAX_HEIGHT nodes per item.
39 1.1 yamt */
40 1.1 yamt
41 1.1 yamt #include <sys/cdefs.h>
42 1.1 yamt
43 1.2 yamt #if defined(_KERNEL) || defined(_STANDALONE)
44 1.4 yamt __KERNEL_RCSID(0, "$NetBSD: radixtree.c,v 1.4 2011/05/19 09:58:28 yamt Exp $");
45 1.1 yamt #include <sys/param.h>
46 1.3 yamt #include <sys/errno.h>
47 1.1 yamt #include <sys/pool.h>
48 1.1 yamt #include <sys/radixtree.h>
49 1.3 yamt #include <lib/libkern/libkern.h>
50 1.3 yamt #if defined(_STANDALONE)
51 1.3 yamt #include <lib/libsa/stand.h>
52 1.3 yamt #endif /* defined(_STANDALONE) */
53 1.2 yamt #else /* defined(_KERNEL) || defined(_STANDALONE) */
54 1.4 yamt __RCSID("$NetBSD: radixtree.c,v 1.4 2011/05/19 09:58:28 yamt Exp $");
55 1.1 yamt #include <assert.h>
56 1.1 yamt #include <errno.h>
57 1.1 yamt #include <stdbool.h>
58 1.1 yamt #include <stdlib.h>
59 1.1 yamt #if 1
60 1.1 yamt #define KASSERT assert
61 1.1 yamt #else
62 1.1 yamt #define KASSERT(a) /* nothing */
63 1.1 yamt #endif
64 1.2 yamt #endif /* defined(_KERNEL) || defined(_STANDALONE) */
65 1.1 yamt
66 1.1 yamt #include <sys/radixtree.h>
67 1.1 yamt
68 1.1 yamt #define RADIX_TREE_BITS_PER_HEIGHT 4 /* XXX tune */
69 1.1 yamt #define RADIX_TREE_PTR_PER_NODE (1 << RADIX_TREE_BITS_PER_HEIGHT)
70 1.1 yamt #define RADIX_TREE_MAX_HEIGHT (64 / RADIX_TREE_BITS_PER_HEIGHT)
71 1.2 yamt __CTASSERT((64 % RADIX_TREE_BITS_PER_HEIGHT) == 0);
72 1.1 yamt
73 1.2 yamt __CTASSERT(((1 << RADIX_TREE_TAG_ID_MAX) & (sizeof(int) - 1)) == 0);
74 1.1 yamt #define RADIX_TREE_TAG_MASK ((1 << RADIX_TREE_TAG_ID_MAX) - 1)
75 1.1 yamt
76 1.1 yamt static inline void *
77 1.1 yamt entry_ptr(void *p)
78 1.1 yamt {
79 1.1 yamt
80 1.1 yamt return (void *)((uintptr_t)p & ~RADIX_TREE_TAG_MASK);
81 1.1 yamt }
82 1.1 yamt
83 1.1 yamt static inline unsigned int
84 1.1 yamt entry_tagmask(void *p)
85 1.1 yamt {
86 1.1 yamt
87 1.1 yamt return (uintptr_t)p & RADIX_TREE_TAG_MASK;
88 1.1 yamt }
89 1.1 yamt
90 1.1 yamt static inline void *
91 1.1 yamt entry_compose(void *p, unsigned int tagmask)
92 1.1 yamt {
93 1.1 yamt
94 1.1 yamt return (void *)((uintptr_t)p | tagmask);
95 1.1 yamt }
96 1.1 yamt
97 1.1 yamt static inline bool
98 1.1 yamt entry_match_p(void *p, unsigned int tagmask)
99 1.1 yamt {
100 1.1 yamt
101 1.1 yamt KASSERT(entry_ptr(p) != NULL || entry_tagmask(p) == 0);
102 1.1 yamt if (p == NULL) {
103 1.1 yamt return false;
104 1.1 yamt }
105 1.1 yamt if (tagmask == 0) {
106 1.1 yamt return true;
107 1.1 yamt }
108 1.1 yamt return (entry_tagmask(p) & tagmask) != 0;
109 1.1 yamt }
110 1.1 yamt
111 1.1 yamt static inline unsigned int
112 1.1 yamt tagid_to_mask(radix_tree_tagid_t id)
113 1.1 yamt {
114 1.1 yamt
115 1.1 yamt return 1U << id;
116 1.1 yamt }
117 1.1 yamt
118 1.1 yamt /*
119 1.1 yamt * radix_tree_node: an intermediate node
120 1.1 yamt *
121 1.1 yamt * we don't care the type of leaf nodes. they are just void *.
122 1.1 yamt */
123 1.1 yamt
124 1.1 yamt struct radix_tree_node {
125 1.1 yamt void *n_ptrs[RADIX_TREE_PTR_PER_NODE];
126 1.1 yamt unsigned int n_nptrs; /* # of non-NULL pointers in n_ptrs */
127 1.1 yamt };
128 1.1 yamt
129 1.1 yamt static unsigned int
130 1.1 yamt any_children_tagmask(struct radix_tree_node *n)
131 1.1 yamt {
132 1.1 yamt unsigned int mask;
133 1.1 yamt int i;
134 1.1 yamt
135 1.1 yamt mask = 0;
136 1.1 yamt for (i = 0; i < RADIX_TREE_PTR_PER_NODE; i++) {
137 1.1 yamt mask |= (unsigned int)(uintptr_t)n->n_ptrs[i];
138 1.1 yamt }
139 1.1 yamt return mask & RADIX_TREE_TAG_MASK;
140 1.1 yamt }
141 1.1 yamt
142 1.1 yamt /*
143 1.1 yamt * p_refs[0].pptr == &t->t_root
144 1.1 yamt * :
145 1.1 yamt * p_refs[n].pptr == &(*p_refs[n-1])->n_ptrs[x]
146 1.1 yamt * :
147 1.1 yamt * :
148 1.1 yamt * p_refs[t->t_height].pptr == &leaf_pointer
149 1.1 yamt */
150 1.1 yamt
151 1.1 yamt struct radix_tree_path {
152 1.1 yamt struct radix_tree_node_ref {
153 1.1 yamt void **pptr;
154 1.1 yamt } p_refs[RADIX_TREE_MAX_HEIGHT + 1]; /* +1 for the root ptr */
155 1.1 yamt int p_lastidx;
156 1.1 yamt };
157 1.1 yamt
158 1.1 yamt static inline void **
159 1.1 yamt path_pptr(struct radix_tree *t, struct radix_tree_path *p,
160 1.1 yamt unsigned int height)
161 1.1 yamt {
162 1.1 yamt
163 1.1 yamt KASSERT(height <= t->t_height);
164 1.1 yamt return p->p_refs[height].pptr;
165 1.1 yamt }
166 1.1 yamt
167 1.1 yamt static inline struct radix_tree_node *
168 1.1 yamt path_node(struct radix_tree * t, struct radix_tree_path *p, unsigned int height)
169 1.1 yamt {
170 1.1 yamt
171 1.1 yamt KASSERT(height <= t->t_height);
172 1.1 yamt return entry_ptr(*path_pptr(t, p, height));
173 1.1 yamt }
174 1.1 yamt
175 1.1 yamt static inline unsigned int
176 1.1 yamt path_idx(struct radix_tree * t, struct radix_tree_path *p, unsigned int height)
177 1.1 yamt {
178 1.1 yamt
179 1.1 yamt KASSERT(height <= t->t_height);
180 1.1 yamt return path_pptr(t, p, height + 1) - path_node(t, p, height)->n_ptrs;
181 1.1 yamt }
182 1.1 yamt
183 1.1 yamt /*
184 1.1 yamt * radix_tree_init_tree:
185 1.1 yamt *
186 1.1 yamt * initialize a tree.
187 1.1 yamt */
188 1.1 yamt
189 1.1 yamt void
190 1.1 yamt radix_tree_init_tree(struct radix_tree *t)
191 1.1 yamt {
192 1.1 yamt
193 1.1 yamt t->t_height = 0;
194 1.1 yamt t->t_root = NULL;
195 1.1 yamt }
196 1.1 yamt
197 1.1 yamt /*
198 1.1 yamt * radix_tree_init_tree:
199 1.1 yamt *
200 1.1 yamt * clean up a tree.
201 1.1 yamt */
202 1.1 yamt
203 1.1 yamt void
204 1.1 yamt radix_tree_fini_tree(struct radix_tree *t)
205 1.1 yamt {
206 1.1 yamt
207 1.1 yamt KASSERT(t->t_root == NULL);
208 1.1 yamt KASSERT(t->t_height == 0);
209 1.1 yamt }
210 1.1 yamt
211 1.3 yamt static void
212 1.3 yamt radix_tree_node_init(struct radix_tree_node *n)
213 1.3 yamt {
214 1.3 yamt
215 1.3 yamt memset(n, 0, sizeof(*n));
216 1.3 yamt }
217 1.3 yamt
218 1.1 yamt #if defined(_KERNEL)
219 1.2 yamt pool_cache_t radix_tree_node_cache __read_mostly;
220 1.1 yamt
221 1.1 yamt static int
222 1.1 yamt radix_tree_node_ctor(void *dummy, void *item, int flags)
223 1.1 yamt {
224 1.1 yamt struct radix_tree_node *n = item;
225 1.1 yamt
226 1.1 yamt KASSERT(dummy == NULL);
227 1.3 yamt radix_tree_node_init(n);
228 1.1 yamt return 0;
229 1.1 yamt }
230 1.1 yamt
231 1.1 yamt /*
232 1.1 yamt * radix_tree_init:
233 1.1 yamt *
234 1.1 yamt * initialize the subsystem.
235 1.1 yamt */
236 1.1 yamt
237 1.1 yamt void
238 1.1 yamt radix_tree_init(void)
239 1.1 yamt {
240 1.1 yamt
241 1.1 yamt radix_tree_node_cache = pool_cache_init(sizeof(struct radix_tree_node),
242 1.1 yamt 0, 0, 0, "radix_tree_node", NULL, IPL_NONE, radix_tree_node_ctor,
243 1.1 yamt NULL, NULL);
244 1.1 yamt KASSERT(radix_tree_node_cache != NULL);
245 1.1 yamt }
246 1.1 yamt #endif /* defined(_KERNEL) */
247 1.1 yamt
248 1.1 yamt static bool __unused
249 1.1 yamt radix_tree_node_clean_p(const struct radix_tree_node *n)
250 1.1 yamt {
251 1.1 yamt unsigned int i;
252 1.1 yamt
253 1.1 yamt if (n->n_nptrs != 0) {
254 1.1 yamt return false;
255 1.1 yamt }
256 1.1 yamt for (i = 0; i < RADIX_TREE_PTR_PER_NODE; i++) {
257 1.1 yamt if (n->n_ptrs[i] != NULL) {
258 1.1 yamt return false;
259 1.1 yamt }
260 1.1 yamt }
261 1.1 yamt return true;
262 1.1 yamt }
263 1.1 yamt
264 1.1 yamt static struct radix_tree_node *
265 1.1 yamt radix_tree_alloc_node(void)
266 1.1 yamt {
267 1.1 yamt struct radix_tree_node *n;
268 1.1 yamt
269 1.1 yamt #if defined(_KERNEL)
270 1.1 yamt n = pool_cache_get(radix_tree_node_cache, PR_NOWAIT);
271 1.1 yamt #else /* defined(_KERNEL) */
272 1.3 yamt #if defined(_STANDALONE)
273 1.3 yamt n = alloc(sizeof(*n));
274 1.3 yamt #else /* defined(_STANDALONE) */
275 1.3 yamt n = malloc(sizeof(*n));
276 1.3 yamt #endif /* defined(_STANDALONE) */
277 1.3 yamt if (n != NULL) {
278 1.3 yamt radix_tree_node_init(n);
279 1.3 yamt }
280 1.1 yamt #endif /* defined(_KERNEL) */
281 1.1 yamt KASSERT(n == NULL || radix_tree_node_clean_p(n));
282 1.1 yamt return n;
283 1.1 yamt }
284 1.1 yamt
285 1.1 yamt static void
286 1.1 yamt radix_tree_free_node(struct radix_tree_node *n)
287 1.1 yamt {
288 1.1 yamt
289 1.1 yamt KASSERT(radix_tree_node_clean_p(n));
290 1.1 yamt #if defined(_KERNEL)
291 1.1 yamt pool_cache_put(radix_tree_node_cache, n);
292 1.3 yamt #elif defined(_STANDALONE)
293 1.3 yamt dealloc(n, sizeof(*n));
294 1.3 yamt #else
295 1.1 yamt free(n);
296 1.3 yamt #endif
297 1.1 yamt }
298 1.1 yamt
299 1.1 yamt static int
300 1.1 yamt radix_tree_grow(struct radix_tree *t, unsigned int newheight)
301 1.1 yamt {
302 1.1 yamt const unsigned int tagmask = entry_tagmask(t->t_root);
303 1.1 yamt
304 1.1 yamt KASSERT(newheight <= 64 / RADIX_TREE_BITS_PER_HEIGHT);
305 1.1 yamt if (t->t_root == NULL) {
306 1.1 yamt t->t_height = newheight;
307 1.1 yamt return 0;
308 1.1 yamt }
309 1.1 yamt while (t->t_height < newheight) {
310 1.1 yamt struct radix_tree_node *n;
311 1.1 yamt
312 1.1 yamt n = radix_tree_alloc_node();
313 1.1 yamt if (n == NULL) {
314 1.1 yamt /*
315 1.1 yamt * don't bother to revert our changes.
316 1.1 yamt * the caller will likely retry.
317 1.1 yamt */
318 1.1 yamt return ENOMEM;
319 1.1 yamt }
320 1.1 yamt n->n_nptrs = 1;
321 1.1 yamt n->n_ptrs[0] = t->t_root;
322 1.1 yamt t->t_root = entry_compose(n, tagmask);
323 1.1 yamt t->t_height++;
324 1.1 yamt }
325 1.1 yamt return 0;
326 1.1 yamt }
327 1.1 yamt
328 1.1 yamt static inline void **
329 1.1 yamt radix_tree_lookup_ptr(struct radix_tree *t, uint64_t idx,
330 1.1 yamt struct radix_tree_path *path, bool alloc, const unsigned int tagmask)
331 1.1 yamt {
332 1.1 yamt struct radix_tree_node *n;
333 1.1 yamt int hshift = RADIX_TREE_BITS_PER_HEIGHT * t->t_height;
334 1.1 yamt int shift;
335 1.1 yamt void **vpp;
336 1.1 yamt const uint64_t mask = (UINT64_C(1) << RADIX_TREE_BITS_PER_HEIGHT) - 1;
337 1.1 yamt struct radix_tree_node_ref *refs = NULL;
338 1.1 yamt
339 1.1 yamt KASSERT(tagmask == 0 || !alloc);
340 1.1 yamt KASSERT(path == NULL || !alloc);
341 1.1 yamt vpp = &t->t_root;
342 1.1 yamt if (path != NULL) {
343 1.1 yamt refs = path->p_refs;
344 1.1 yamt refs->pptr = vpp;
345 1.1 yamt }
346 1.1 yamt n = NULL;
347 1.1 yamt for (shift = 64 - RADIX_TREE_BITS_PER_HEIGHT; shift >= 0;) {
348 1.1 yamt struct radix_tree_node *c;
349 1.1 yamt void *entry;
350 1.1 yamt const uint64_t i = (idx >> shift) & mask;
351 1.1 yamt
352 1.1 yamt if (shift >= hshift) {
353 1.1 yamt unsigned int newheight;
354 1.1 yamt
355 1.1 yamt KASSERT(vpp == &t->t_root);
356 1.1 yamt if (i == 0) {
357 1.1 yamt shift -= RADIX_TREE_BITS_PER_HEIGHT;
358 1.1 yamt continue;
359 1.1 yamt }
360 1.1 yamt if (!alloc) {
361 1.1 yamt if (path != NULL) {
362 1.1 yamt KASSERT((refs - path->p_refs) == 0);
363 1.1 yamt path->p_lastidx = 0;
364 1.1 yamt }
365 1.1 yamt return NULL;
366 1.1 yamt }
367 1.1 yamt newheight = shift / RADIX_TREE_BITS_PER_HEIGHT + 1;
368 1.1 yamt if (radix_tree_grow(t, newheight)) {
369 1.1 yamt return NULL;
370 1.1 yamt }
371 1.1 yamt hshift = RADIX_TREE_BITS_PER_HEIGHT * t->t_height;
372 1.1 yamt }
373 1.1 yamt entry = *vpp;
374 1.1 yamt c = entry_ptr(entry);
375 1.1 yamt if (c == NULL ||
376 1.1 yamt (tagmask != 0 &&
377 1.1 yamt (entry_tagmask(entry) & tagmask) == 0)) {
378 1.1 yamt if (!alloc) {
379 1.1 yamt if (path != NULL) {
380 1.1 yamt path->p_lastidx = refs - path->p_refs;
381 1.1 yamt }
382 1.1 yamt return NULL;
383 1.1 yamt }
384 1.1 yamt c = radix_tree_alloc_node();
385 1.1 yamt if (c == NULL) {
386 1.1 yamt return NULL;
387 1.1 yamt }
388 1.1 yamt *vpp = c;
389 1.1 yamt if (n != NULL) {
390 1.1 yamt KASSERT(n->n_nptrs < RADIX_TREE_PTR_PER_NODE);
391 1.1 yamt n->n_nptrs++;
392 1.1 yamt }
393 1.1 yamt }
394 1.1 yamt n = c;
395 1.1 yamt vpp = &n->n_ptrs[i];
396 1.1 yamt if (path != NULL) {
397 1.1 yamt refs++;
398 1.1 yamt refs->pptr = vpp;
399 1.1 yamt }
400 1.1 yamt shift -= RADIX_TREE_BITS_PER_HEIGHT;
401 1.1 yamt }
402 1.1 yamt if (alloc) {
403 1.1 yamt KASSERT(*vpp == NULL);
404 1.1 yamt if (n != NULL) {
405 1.1 yamt KASSERT(n->n_nptrs < RADIX_TREE_PTR_PER_NODE);
406 1.1 yamt n->n_nptrs++;
407 1.1 yamt }
408 1.1 yamt }
409 1.1 yamt if (path != NULL) {
410 1.1 yamt path->p_lastidx = refs - path->p_refs;
411 1.1 yamt }
412 1.1 yamt return vpp;
413 1.1 yamt }
414 1.1 yamt
415 1.1 yamt /*
416 1.1 yamt * radix_tree_insert_node:
417 1.1 yamt *
418 1.1 yamt * insert the node at idx.
419 1.1 yamt * it's illegal to insert NULL.
420 1.1 yamt * it's illegal to insert a non-aligned pointer.
421 1.1 yamt *
422 1.1 yamt * this function returns ENOMEM if necessary memory allocation failed.
423 1.1 yamt * otherwise, this function returns 0.
424 1.1 yamt *
425 1.1 yamt * note that inserting a node can involves memory allocation for intermediate
426 1.1 yamt * nodes. if _KERNEL, it's done with non-blocking IPL_NONE memory allocation.
427 1.4 yamt *
428 1.4 yamt * for the newly inserted node, all tags are cleared.
429 1.1 yamt */
430 1.1 yamt
431 1.1 yamt int
432 1.1 yamt radix_tree_insert_node(struct radix_tree *t, uint64_t idx, void *p)
433 1.1 yamt {
434 1.1 yamt void **vpp;
435 1.1 yamt
436 1.1 yamt KASSERT(p != NULL);
437 1.1 yamt KASSERT(entry_compose(p, 0) == p);
438 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, NULL, true, 0);
439 1.1 yamt if (vpp == NULL) {
440 1.1 yamt return ENOMEM;
441 1.1 yamt }
442 1.1 yamt KASSERT(*vpp == NULL);
443 1.1 yamt *vpp = p;
444 1.1 yamt return 0;
445 1.1 yamt }
446 1.1 yamt
447 1.4 yamt /*
448 1.4 yamt * radix_tree_replace_node:
449 1.4 yamt *
450 1.4 yamt * replace a node at the given index with the given node.
451 1.4 yamt * return the old node.
452 1.4 yamt * it's illegal to try to replace a node which has not been inserted.
453 1.4 yamt *
454 1.4 yamt * this function doesn't change tags.
455 1.4 yamt */
456 1.4 yamt
457 1.1 yamt void *
458 1.1 yamt radix_tree_replace_node(struct radix_tree *t, uint64_t idx, void *p)
459 1.1 yamt {
460 1.1 yamt void **vpp;
461 1.1 yamt void *oldp;
462 1.1 yamt
463 1.1 yamt KASSERT(p != NULL);
464 1.1 yamt KASSERT(entry_compose(p, 0) == p);
465 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, NULL, false, 0);
466 1.1 yamt KASSERT(vpp != NULL);
467 1.1 yamt oldp = *vpp;
468 1.1 yamt KASSERT(oldp != NULL);
469 1.1 yamt *vpp = entry_compose(p, entry_tagmask(*vpp));
470 1.1 yamt return entry_ptr(oldp);
471 1.1 yamt }
472 1.1 yamt
473 1.1 yamt /*
474 1.1 yamt * radix_tree_remove_node:
475 1.1 yamt *
476 1.1 yamt * remove the node at idx.
477 1.1 yamt * it's illegal to try to remove a node which has not been inserted.
478 1.1 yamt */
479 1.1 yamt
480 1.1 yamt void *
481 1.1 yamt radix_tree_remove_node(struct radix_tree *t, uint64_t idx)
482 1.1 yamt {
483 1.1 yamt struct radix_tree_path path;
484 1.1 yamt void **vpp;
485 1.1 yamt void *oldp;
486 1.1 yamt int i;
487 1.1 yamt
488 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, &path, false, 0);
489 1.1 yamt KASSERT(vpp != NULL);
490 1.1 yamt oldp = *vpp;
491 1.1 yamt KASSERT(oldp != NULL);
492 1.1 yamt KASSERT(path.p_lastidx == t->t_height);
493 1.1 yamt KASSERT(vpp == path_pptr(t, &path, path.p_lastidx));
494 1.1 yamt *vpp = NULL;
495 1.1 yamt for (i = t->t_height - 1; i >= 0; i--) {
496 1.1 yamt void *entry;
497 1.1 yamt struct radix_tree_node ** const pptr =
498 1.1 yamt (struct radix_tree_node **)path_pptr(t, &path, i);
499 1.1 yamt struct radix_tree_node *n;
500 1.1 yamt
501 1.1 yamt KASSERT(pptr != NULL);
502 1.1 yamt entry = *pptr;
503 1.1 yamt n = entry_ptr(entry);
504 1.1 yamt KASSERT(n != NULL);
505 1.1 yamt KASSERT(n->n_nptrs > 0);
506 1.1 yamt n->n_nptrs--;
507 1.1 yamt if (n->n_nptrs > 0) {
508 1.1 yamt break;
509 1.1 yamt }
510 1.1 yamt radix_tree_free_node(n);
511 1.1 yamt *pptr = NULL;
512 1.1 yamt }
513 1.1 yamt /*
514 1.1 yamt * fix up height
515 1.1 yamt */
516 1.1 yamt if (i < 0) {
517 1.1 yamt KASSERT(t->t_root == NULL);
518 1.1 yamt t->t_height = 0;
519 1.1 yamt }
520 1.1 yamt /*
521 1.1 yamt * update tags
522 1.1 yamt */
523 1.1 yamt for (; i >= 0; i--) {
524 1.1 yamt void *entry;
525 1.1 yamt struct radix_tree_node ** const pptr =
526 1.1 yamt (struct radix_tree_node **)path_pptr(t, &path, i);
527 1.1 yamt struct radix_tree_node *n;
528 1.1 yamt unsigned int newmask;
529 1.1 yamt
530 1.1 yamt KASSERT(pptr != NULL);
531 1.1 yamt entry = *pptr;
532 1.1 yamt n = entry_ptr(entry);
533 1.1 yamt KASSERT(n != NULL);
534 1.1 yamt KASSERT(n->n_nptrs > 0);
535 1.1 yamt newmask = any_children_tagmask(n);
536 1.1 yamt if (newmask == entry_tagmask(entry)) {
537 1.1 yamt break;
538 1.1 yamt }
539 1.1 yamt *pptr = entry_compose(n, newmask);
540 1.1 yamt }
541 1.1 yamt /*
542 1.1 yamt * XXX is it worth to try to reduce height?
543 1.1 yamt * if we do that, make radix_tree_grow rollback its change as well.
544 1.1 yamt */
545 1.1 yamt return entry_ptr(oldp);
546 1.1 yamt }
547 1.1 yamt
548 1.1 yamt /*
549 1.1 yamt * radix_tree_lookup_node:
550 1.1 yamt *
551 1.1 yamt * returns the node at idx.
552 1.1 yamt * returns NULL if nothing is found at idx.
553 1.1 yamt */
554 1.1 yamt
555 1.1 yamt void *
556 1.1 yamt radix_tree_lookup_node(struct radix_tree *t, uint64_t idx)
557 1.1 yamt {
558 1.1 yamt void **vpp;
559 1.1 yamt
560 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, NULL, false, 0);
561 1.1 yamt if (vpp == NULL) {
562 1.1 yamt return NULL;
563 1.1 yamt }
564 1.1 yamt return entry_ptr(*vpp);
565 1.1 yamt }
566 1.1 yamt
567 1.1 yamt static inline void
568 1.1 yamt gang_lookup_init(struct radix_tree *t, uint64_t idx,
569 1.1 yamt struct radix_tree_path *path, const unsigned int tagmask)
570 1.1 yamt {
571 1.1 yamt void **vpp;
572 1.1 yamt
573 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, path, false, tagmask);
574 1.1 yamt KASSERT(vpp == NULL ||
575 1.1 yamt vpp == path_pptr(t, path, path->p_lastidx));
576 1.1 yamt KASSERT(&t->t_root == path_pptr(t, path, 0));
577 1.1 yamt }
578 1.1 yamt
579 1.1 yamt static inline unsigned int
580 1.1 yamt gang_lookup_scan(struct radix_tree *t, struct radix_tree_path *path,
581 1.1 yamt void **results, unsigned int maxresults, const unsigned int tagmask)
582 1.1 yamt {
583 1.1 yamt void **vpp;
584 1.1 yamt int nfound;
585 1.1 yamt unsigned int lastidx;
586 1.1 yamt
587 1.1 yamt KASSERT(maxresults > 0);
588 1.1 yamt lastidx = path->p_lastidx;
589 1.1 yamt if (lastidx == 0) {
590 1.1 yamt return 0;
591 1.1 yamt }
592 1.1 yamt nfound = 0;
593 1.1 yamt vpp = path_pptr(t, path, lastidx);
594 1.1 yamt while (/*CONSTCOND*/true) {
595 1.1 yamt struct radix_tree_node *n;
596 1.1 yamt int i;
597 1.1 yamt
598 1.1 yamt if (entry_match_p(*vpp, tagmask)) {
599 1.1 yamt KASSERT(lastidx == t->t_height);
600 1.1 yamt /*
601 1.1 yamt * record the non-NULL leaf.
602 1.1 yamt */
603 1.1 yamt results[nfound] = entry_ptr(*vpp);
604 1.1 yamt nfound++;
605 1.1 yamt if (nfound == maxresults) {
606 1.1 yamt return nfound;
607 1.1 yamt }
608 1.1 yamt }
609 1.1 yamt scan_siblings:
610 1.1 yamt /*
611 1.1 yamt * try to find the next non-NULL sibling.
612 1.1 yamt */
613 1.1 yamt n = path_node(t, path, lastidx - 1);
614 1.1 yamt if (*vpp != NULL && n->n_nptrs == 1) {
615 1.1 yamt /*
616 1.1 yamt * optimization
617 1.1 yamt */
618 1.1 yamt goto no_siblings;
619 1.1 yamt }
620 1.1 yamt for (i = path_idx(t, path, lastidx - 1) + 1;
621 1.1 yamt i < RADIX_TREE_PTR_PER_NODE;
622 1.1 yamt i++) {
623 1.1 yamt if (entry_match_p(n->n_ptrs[i], tagmask)) {
624 1.1 yamt vpp = &n->n_ptrs[i];
625 1.1 yamt path->p_refs[lastidx].pptr = vpp;
626 1.1 yamt KASSERT(path_idx(t, path, lastidx - 1)
627 1.1 yamt == i);
628 1.1 yamt break;
629 1.1 yamt }
630 1.1 yamt }
631 1.1 yamt if (i == RADIX_TREE_PTR_PER_NODE) {
632 1.1 yamt no_siblings:
633 1.1 yamt /*
634 1.1 yamt * not found. go to parent.
635 1.1 yamt */
636 1.1 yamt lastidx--;
637 1.1 yamt if (lastidx == 0) {
638 1.1 yamt return nfound;
639 1.1 yamt }
640 1.1 yamt vpp = path_pptr(t, path, lastidx);
641 1.1 yamt goto scan_siblings;
642 1.1 yamt }
643 1.1 yamt /*
644 1.1 yamt * descending the left-most child node, upto the leaf or NULL.
645 1.1 yamt */
646 1.1 yamt while (entry_match_p(*vpp, tagmask) && lastidx < t->t_height) {
647 1.1 yamt n = entry_ptr(*vpp);
648 1.1 yamt vpp = &n->n_ptrs[0];
649 1.1 yamt lastidx++;
650 1.1 yamt path->p_refs[lastidx].pptr = vpp;
651 1.1 yamt }
652 1.1 yamt }
653 1.1 yamt }
654 1.1 yamt
655 1.1 yamt /*
656 1.1 yamt * radix_tree_gang_lookup_node:
657 1.1 yamt *
658 1.1 yamt * search nodes starting from idx in the ascending order.
659 1.1 yamt * results should be an array large enough to hold maxresults pointers.
660 1.1 yamt * returns the number of nodes found, up to maxresults.
661 1.1 yamt * returning less than maxresults means there are no more nodes.
662 1.1 yamt *
663 1.1 yamt * the result of this function is semantically equivalent to what could be
664 1.1 yamt * obtained by repeated calls of radix_tree_lookup_node with increasing index.
665 1.1 yamt * but this function is much faster when node indexes are distributed sparsely.
666 1.1 yamt *
667 1.1 yamt * note that this function doesn't return exact values of node indexes of
668 1.1 yamt * found nodes. if they are important for a caller, it's the caller's
669 1.1 yamt * responsibility to check them, typically by examinining the returned nodes
670 1.1 yamt * using some caller-specific knowledge about them.
671 1.1 yamt */
672 1.1 yamt
673 1.1 yamt unsigned int
674 1.1 yamt radix_tree_gang_lookup_node(struct radix_tree *t, uint64_t idx,
675 1.1 yamt void **results, unsigned int maxresults)
676 1.1 yamt {
677 1.1 yamt struct radix_tree_path path;
678 1.1 yamt
679 1.1 yamt gang_lookup_init(t, idx, &path, 0);
680 1.1 yamt return gang_lookup_scan(t, &path, results, maxresults, 0);
681 1.1 yamt }
682 1.1 yamt
683 1.1 yamt /*
684 1.1 yamt * radix_tree_gang_lookup_tagged_node:
685 1.1 yamt *
686 1.1 yamt * same as radix_tree_gang_lookup_node except that this one only returns
687 1.1 yamt * nodes tagged with tagid.
688 1.1 yamt */
689 1.1 yamt
690 1.1 yamt unsigned int
691 1.1 yamt radix_tree_gang_lookup_tagged_node(struct radix_tree *t, uint64_t idx,
692 1.1 yamt void **results, unsigned int maxresults, radix_tree_tagid_t tagid)
693 1.1 yamt {
694 1.1 yamt struct radix_tree_path path;
695 1.1 yamt const unsigned int tagmask = tagid_to_mask(tagid);
696 1.1 yamt
697 1.1 yamt gang_lookup_init(t, idx, &path, tagmask);
698 1.1 yamt return gang_lookup_scan(t, &path, results, maxresults, tagmask);
699 1.1 yamt }
700 1.1 yamt
701 1.4 yamt /*
702 1.4 yamt * radix_tree_get_tag:
703 1.4 yamt *
704 1.4 yamt * return if the tag is set for the node at the given index. (true if set)
705 1.4 yamt * it's illegal to call this function for a node which has not been inserted.
706 1.4 yamt */
707 1.4 yamt
708 1.1 yamt bool
709 1.1 yamt radix_tree_get_tag(struct radix_tree *t, uint64_t idx,
710 1.1 yamt radix_tree_tagid_t tagid)
711 1.1 yamt {
712 1.1 yamt #if 1
713 1.1 yamt const unsigned int tagmask = tagid_to_mask(tagid);
714 1.1 yamt void **vpp;
715 1.1 yamt
716 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, NULL, false, tagmask);
717 1.1 yamt if (vpp == NULL) {
718 1.1 yamt return false;
719 1.1 yamt }
720 1.1 yamt KASSERT(*vpp != NULL);
721 1.1 yamt return (entry_tagmask(*vpp) & tagmask) != 0;
722 1.1 yamt #else
723 1.1 yamt const unsigned int tagmask = tagid_to_mask(tagid);
724 1.1 yamt void **vpp;
725 1.1 yamt
726 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, NULL, false, 0);
727 1.1 yamt KASSERT(vpp != NULL);
728 1.1 yamt return (entry_tagmask(*vpp) & tagmask) != 0;
729 1.1 yamt #endif
730 1.1 yamt }
731 1.1 yamt
732 1.4 yamt /*
733 1.4 yamt * radix_tree_set_tag:
734 1.4 yamt *
735 1.4 yamt * set the tag for the node at the given index.
736 1.4 yamt * it's illegal to call this function for a node which has not been inserted.
737 1.4 yamt */
738 1.4 yamt
739 1.1 yamt void
740 1.1 yamt radix_tree_set_tag(struct radix_tree *t, uint64_t idx,
741 1.1 yamt radix_tree_tagid_t tagid)
742 1.1 yamt {
743 1.1 yamt struct radix_tree_path path;
744 1.1 yamt const unsigned int tagmask = tagid_to_mask(tagid);
745 1.1 yamt void **vpp;
746 1.1 yamt int i;
747 1.1 yamt
748 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, &path, false, 0);
749 1.1 yamt KASSERT(vpp != NULL);
750 1.1 yamt KASSERT(*vpp != NULL);
751 1.1 yamt KASSERT(path.p_lastidx == t->t_height);
752 1.1 yamt KASSERT(vpp == path_pptr(t, &path, path.p_lastidx));
753 1.1 yamt for (i = t->t_height; i >= 0; i--) {
754 1.1 yamt void ** const pptr = (void **)path_pptr(t, &path, i);
755 1.1 yamt void *entry;
756 1.1 yamt
757 1.1 yamt KASSERT(pptr != NULL);
758 1.1 yamt entry = *pptr;
759 1.1 yamt if ((entry_tagmask(entry) & tagmask) != 0) {
760 1.1 yamt break;
761 1.1 yamt }
762 1.1 yamt *pptr = (void *)((uintptr_t)entry | tagmask);
763 1.1 yamt }
764 1.1 yamt }
765 1.1 yamt
766 1.4 yamt /*
767 1.4 yamt * radix_tree_clear_tag:
768 1.4 yamt *
769 1.4 yamt * clear the tag for the node at the given index.
770 1.4 yamt * it's illegal to call this function for a node which has not been inserted.
771 1.4 yamt */
772 1.4 yamt
773 1.1 yamt void
774 1.1 yamt radix_tree_clear_tag(struct radix_tree *t, uint64_t idx,
775 1.1 yamt radix_tree_tagid_t tagid)
776 1.1 yamt {
777 1.1 yamt struct radix_tree_path path;
778 1.1 yamt const unsigned int tagmask = tagid_to_mask(tagid);
779 1.1 yamt void **vpp;
780 1.1 yamt int i;
781 1.1 yamt
782 1.1 yamt vpp = radix_tree_lookup_ptr(t, idx, &path, false, 0);
783 1.1 yamt KASSERT(vpp != NULL);
784 1.1 yamt KASSERT(*vpp != NULL);
785 1.1 yamt KASSERT(path.p_lastidx == t->t_height);
786 1.1 yamt KASSERT(vpp == path_pptr(t, &path, path.p_lastidx));
787 1.1 yamt if ((entry_tagmask(*vpp) & tagmask) == 0) {
788 1.1 yamt return;
789 1.1 yamt }
790 1.1 yamt for (i = t->t_height; i >= 0; i--) {
791 1.1 yamt void ** const pptr = (void **)path_pptr(t, &path, i);
792 1.1 yamt void *entry;
793 1.1 yamt
794 1.1 yamt KASSERT(pptr != NULL);
795 1.1 yamt entry = *pptr;
796 1.1 yamt KASSERT((entry_tagmask(entry) & tagmask) != 0);
797 1.1 yamt *pptr = entry_compose(entry_ptr(entry),
798 1.1 yamt entry_tagmask(entry) & ~tagmask);
799 1.1 yamt if (0 < i && i < t->t_height - 1) {
800 1.1 yamt struct radix_tree_node *n = path_node(t, &path, i - 1);
801 1.1 yamt
802 1.1 yamt if ((any_children_tagmask(n) & tagmask) != 0) {
803 1.1 yamt break;
804 1.1 yamt }
805 1.1 yamt }
806 1.1 yamt }
807 1.1 yamt }
808 1.1 yamt
809 1.1 yamt #if defined(UNITTEST)
810 1.1 yamt
811 1.1 yamt #include <inttypes.h>
812 1.1 yamt #include <stdio.h>
813 1.1 yamt
814 1.1 yamt static void
815 1.1 yamt radix_tree_dump_node(const struct radix_tree *t, void *vp,
816 1.1 yamt uint64_t offset, unsigned int height)
817 1.1 yamt {
818 1.1 yamt struct radix_tree_node *n;
819 1.1 yamt unsigned int i;
820 1.1 yamt
821 1.1 yamt for (i = 0; i < t->t_height - height; i++) {
822 1.1 yamt printf(" ");
823 1.1 yamt }
824 1.1 yamt if (entry_tagmask(vp) == 0) {
825 1.1 yamt printf("[%" PRIu64 "] %p", offset, entry_ptr(vp));
826 1.1 yamt } else {
827 1.1 yamt printf("[%" PRIu64 "] %p (tagmask=0x%x)", offset, entry_ptr(vp),
828 1.1 yamt entry_tagmask(vp));
829 1.1 yamt }
830 1.1 yamt if (height == 0) {
831 1.1 yamt printf(" (leaf)\n");
832 1.1 yamt return;
833 1.1 yamt }
834 1.1 yamt n = entry_ptr(vp);
835 1.1 yamt assert(any_children_tagmask(n) == entry_tagmask(vp));
836 1.1 yamt printf(" (%u children)\n", n->n_nptrs);
837 1.1 yamt for (i = 0; i < __arraycount(n->n_ptrs); i++) {
838 1.1 yamt void *c;
839 1.1 yamt
840 1.1 yamt c = n->n_ptrs[i];
841 1.1 yamt if (c == NULL) {
842 1.1 yamt continue;
843 1.1 yamt }
844 1.1 yamt radix_tree_dump_node(t, c,
845 1.1 yamt offset + i * (UINT64_C(1) <<
846 1.1 yamt (RADIX_TREE_BITS_PER_HEIGHT * (height - 1))), height - 1);
847 1.1 yamt }
848 1.1 yamt }
849 1.1 yamt
850 1.1 yamt void radix_tree_dump(const struct radix_tree *);
851 1.1 yamt
852 1.1 yamt void
853 1.1 yamt radix_tree_dump(const struct radix_tree *t)
854 1.1 yamt {
855 1.1 yamt
856 1.1 yamt printf("tree %p height=%u\n", t, t->t_height);
857 1.1 yamt radix_tree_dump_node(t, t->t_root, 0, t->t_height);
858 1.1 yamt }
859 1.1 yamt
860 1.1 yamt static void
861 1.1 yamt test1(void)
862 1.1 yamt {
863 1.1 yamt struct radix_tree s;
864 1.1 yamt struct radix_tree *t = &s;
865 1.1 yamt void *results[3];
866 1.1 yamt
867 1.1 yamt radix_tree_init_tree(t);
868 1.1 yamt radix_tree_dump(t);
869 1.1 yamt assert(radix_tree_lookup_node(t, 0) == NULL);
870 1.1 yamt assert(radix_tree_lookup_node(t, 1000) == NULL);
871 1.1 yamt assert(radix_tree_insert_node(t, 1000, (void *)0xdeadbea0) == 0);
872 1.1 yamt radix_tree_dump(t);
873 1.1 yamt assert(!radix_tree_get_tag(t, 1000, 0));
874 1.1 yamt assert(!radix_tree_get_tag(t, 1000, 1));
875 1.1 yamt radix_tree_set_tag(t, 1000, 1);
876 1.1 yamt assert(!radix_tree_get_tag(t, 1000, 0));
877 1.1 yamt assert(radix_tree_get_tag(t, 1000, 1));
878 1.1 yamt radix_tree_dump(t);
879 1.1 yamt assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
880 1.1 yamt assert(radix_tree_insert_node(t, 0, (void *)0xbea0) == 0);
881 1.1 yamt radix_tree_dump(t);
882 1.1 yamt assert(radix_tree_lookup_node(t, 0) == (void *)0xbea0);
883 1.1 yamt assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
884 1.1 yamt assert(radix_tree_insert_node(t, UINT64_C(10000000000), (void *)0xdea0)
885 1.1 yamt == 0);
886 1.1 yamt radix_tree_dump(t);
887 1.1 yamt assert(radix_tree_lookup_node(t, 0) == (void *)0xbea0);
888 1.1 yamt assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
889 1.1 yamt assert(radix_tree_lookup_node(t, UINT64_C(10000000000)) ==
890 1.1 yamt (void *)0xdea0);
891 1.1 yamt radix_tree_dump(t);
892 1.1 yamt assert(!radix_tree_get_tag(t, 0, 1));
893 1.1 yamt assert(radix_tree_get_tag(t, 1000, 1));
894 1.1 yamt assert(!radix_tree_get_tag(t, UINT64_C(10000000000), 1));
895 1.1 yamt radix_tree_set_tag(t, 0, 1);;
896 1.1 yamt radix_tree_set_tag(t, UINT64_C(10000000000), 1);
897 1.1 yamt radix_tree_dump(t);
898 1.1 yamt assert(radix_tree_get_tag(t, 0, 1));
899 1.1 yamt assert(radix_tree_get_tag(t, 1000, 1));
900 1.1 yamt assert(radix_tree_get_tag(t, UINT64_C(10000000000), 1));
901 1.1 yamt radix_tree_clear_tag(t, 0, 1);;
902 1.1 yamt radix_tree_clear_tag(t, UINT64_C(10000000000), 1);
903 1.1 yamt radix_tree_dump(t);
904 1.1 yamt assert(!radix_tree_get_tag(t, 0, 1));
905 1.1 yamt assert(radix_tree_get_tag(t, 1000, 1));
906 1.1 yamt assert(!radix_tree_get_tag(t, UINT64_C(10000000000), 1));
907 1.1 yamt radix_tree_dump(t);
908 1.1 yamt assert(radix_tree_replace_node(t, 1000, (void *)0x12345678) ==
909 1.1 yamt (void *)0xdeadbea0);
910 1.1 yamt assert(!radix_tree_get_tag(t, 1000, 0));
911 1.1 yamt assert(radix_tree_get_tag(t, 1000, 1));
912 1.1 yamt assert(radix_tree_gang_lookup_node(t, 0, results, 3) == 3);
913 1.1 yamt assert(results[0] == (void *)0xbea0);
914 1.1 yamt assert(results[1] == (void *)0x12345678);
915 1.1 yamt assert(results[2] == (void *)0xdea0);
916 1.1 yamt assert(radix_tree_gang_lookup_node(t, 1, results, 3) == 2);
917 1.1 yamt assert(results[0] == (void *)0x12345678);
918 1.1 yamt assert(results[1] == (void *)0xdea0);
919 1.1 yamt assert(radix_tree_gang_lookup_node(t, 1001, results, 3) == 1);
920 1.1 yamt assert(results[0] == (void *)0xdea0);
921 1.1 yamt assert(radix_tree_gang_lookup_node(t, UINT64_C(10000000001), results, 3)
922 1.1 yamt == 0);
923 1.1 yamt assert(radix_tree_gang_lookup_node(t, UINT64_C(1000000000000), results,
924 1.1 yamt 3) == 0);
925 1.1 yamt assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 100, 1) == 1);
926 1.1 yamt assert(results[0] == (void *)0x12345678);
927 1.1 yamt assert(entry_tagmask(t->t_root) != 0);
928 1.1 yamt assert(radix_tree_remove_node(t, 1000) == (void *)0x12345678);
929 1.1 yamt assert(entry_tagmask(t->t_root) == 0);
930 1.1 yamt radix_tree_dump(t);
931 1.1 yamt assert(radix_tree_remove_node(t, UINT64_C(10000000000)) ==
932 1.1 yamt (void *)0xdea0);
933 1.1 yamt radix_tree_dump(t);
934 1.1 yamt assert(radix_tree_remove_node(t, 0) == (void *)0xbea0);
935 1.1 yamt radix_tree_dump(t);
936 1.1 yamt radix_tree_fini_tree(t);
937 1.1 yamt }
938 1.1 yamt
939 1.1 yamt #include <sys/time.h>
940 1.1 yamt
941 1.1 yamt struct testnode {
942 1.1 yamt uint64_t idx;
943 1.1 yamt };
944 1.1 yamt
945 1.1 yamt static void
946 1.1 yamt printops(const char *name, unsigned int n, const struct timeval *stv,
947 1.1 yamt const struct timeval *etv)
948 1.1 yamt {
949 1.1 yamt uint64_t s = stv->tv_sec * 1000000 + stv->tv_usec;
950 1.1 yamt uint64_t e = etv->tv_sec * 1000000 + etv->tv_usec;
951 1.1 yamt
952 1.1 yamt printf("%lf %s/s\n", (double)n / (e - s) * 1000000, name);
953 1.1 yamt }
954 1.1 yamt
955 1.1 yamt #define TEST2_GANG_LOOKUP_NODES 16
956 1.1 yamt
957 1.1 yamt static bool
958 1.1 yamt test2_should_tag(unsigned int i, radix_tree_tagid_t tagid)
959 1.1 yamt {
960 1.1 yamt
961 1.1 yamt if (tagid == 0) {
962 1.1 yamt return (i & 0x3) == 0;
963 1.1 yamt } else {
964 1.1 yamt return (i % 7) == 0;
965 1.1 yamt }
966 1.1 yamt }
967 1.1 yamt
968 1.1 yamt static void
969 1.1 yamt test2(bool dense)
970 1.1 yamt {
971 1.1 yamt struct radix_tree s;
972 1.1 yamt struct radix_tree *t = &s;
973 1.1 yamt struct testnode *n;
974 1.1 yamt unsigned int i;
975 1.1 yamt unsigned int nnodes = 100000;
976 1.1 yamt unsigned int removed;
977 1.1 yamt radix_tree_tagid_t tag;
978 1.1 yamt unsigned int ntagged[RADIX_TREE_TAG_ID_MAX];
979 1.1 yamt struct testnode *nodes;
980 1.1 yamt struct timeval stv;
981 1.1 yamt struct timeval etv;
982 1.1 yamt
983 1.1 yamt nodes = malloc(nnodes * sizeof(*nodes));
984 1.1 yamt for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
985 1.1 yamt ntagged[tag] = 0;
986 1.1 yamt }
987 1.1 yamt radix_tree_init_tree(t);
988 1.1 yamt for (i = 0; i < nnodes; i++) {
989 1.1 yamt n = &nodes[i];
990 1.1 yamt n->idx = random();
991 1.1 yamt if (sizeof(long) == 4) {
992 1.1 yamt n->idx <<= 32;
993 1.1 yamt n->idx |= (uint32_t)random();
994 1.1 yamt }
995 1.1 yamt if (dense) {
996 1.1 yamt n->idx %= nnodes * 2;
997 1.1 yamt }
998 1.1 yamt while (radix_tree_lookup_node(t, n->idx) != NULL) {
999 1.1 yamt n->idx++;
1000 1.1 yamt }
1001 1.1 yamt radix_tree_insert_node(t, n->idx, n);
1002 1.1 yamt for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
1003 1.1 yamt if (test2_should_tag(i, tag)) {
1004 1.1 yamt radix_tree_set_tag(t, n->idx, tag);
1005 1.1 yamt ntagged[tag]++;
1006 1.1 yamt }
1007 1.1 yamt assert(test2_should_tag(i, tag) ==
1008 1.1 yamt radix_tree_get_tag(t, n->idx, tag));
1009 1.1 yamt }
1010 1.1 yamt }
1011 1.1 yamt
1012 1.1 yamt gettimeofday(&stv, NULL);
1013 1.1 yamt for (i = 0; i < nnodes; i++) {
1014 1.1 yamt n = &nodes[i];
1015 1.1 yamt assert(radix_tree_lookup_node(t, n->idx) == n);
1016 1.1 yamt }
1017 1.1 yamt gettimeofday(&etv, NULL);
1018 1.1 yamt printops("lookup", nnodes, &stv, &etv);
1019 1.1 yamt
1020 1.1 yamt for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
1021 1.1 yamt gettimeofday(&stv, NULL);
1022 1.1 yamt for (i = 0; i < nnodes; i++) {
1023 1.1 yamt n = &nodes[i];
1024 1.1 yamt assert(test2_should_tag(i, tag) ==
1025 1.1 yamt radix_tree_get_tag(t, n->idx, tag));
1026 1.1 yamt }
1027 1.1 yamt gettimeofday(&etv, NULL);
1028 1.1 yamt printops("get_tag", ntagged[tag], &stv, &etv);
1029 1.1 yamt }
1030 1.1 yamt
1031 1.1 yamt gettimeofday(&stv, NULL);
1032 1.1 yamt for (i = 0; i < nnodes; i++) {
1033 1.1 yamt n = &nodes[i];
1034 1.1 yamt radix_tree_remove_node(t, n->idx);
1035 1.1 yamt }
1036 1.1 yamt gettimeofday(&etv, NULL);
1037 1.1 yamt printops("remove", nnodes, &stv, &etv);
1038 1.1 yamt
1039 1.1 yamt gettimeofday(&stv, NULL);
1040 1.1 yamt for (i = 0; i < nnodes; i++) {
1041 1.1 yamt n = &nodes[i];
1042 1.1 yamt radix_tree_insert_node(t, n->idx, n);
1043 1.1 yamt }
1044 1.1 yamt gettimeofday(&etv, NULL);
1045 1.1 yamt printops("insert", nnodes, &stv, &etv);
1046 1.1 yamt
1047 1.1 yamt for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
1048 1.1 yamt ntagged[tag] = 0;
1049 1.1 yamt gettimeofday(&stv, NULL);
1050 1.1 yamt for (i = 0; i < nnodes; i++) {
1051 1.1 yamt n = &nodes[i];
1052 1.1 yamt if (test2_should_tag(i, tag)) {
1053 1.1 yamt radix_tree_set_tag(t, n->idx, tag);
1054 1.1 yamt ntagged[tag]++;
1055 1.1 yamt }
1056 1.1 yamt }
1057 1.1 yamt gettimeofday(&etv, NULL);
1058 1.1 yamt printops("set_tag", ntagged[tag], &stv, &etv);
1059 1.1 yamt }
1060 1.1 yamt
1061 1.1 yamt gettimeofday(&stv, NULL);
1062 1.1 yamt {
1063 1.1 yamt struct testnode *results[TEST2_GANG_LOOKUP_NODES];
1064 1.1 yamt uint64_t nextidx;
1065 1.1 yamt unsigned int nfound;
1066 1.1 yamt unsigned int total;
1067 1.1 yamt
1068 1.1 yamt nextidx = 0;
1069 1.1 yamt total = 0;
1070 1.1 yamt while ((nfound = radix_tree_gang_lookup_node(t, nextidx,
1071 1.1 yamt (void *)results, __arraycount(results))) > 0) {
1072 1.1 yamt nextidx = results[nfound - 1]->idx + 1;
1073 1.1 yamt total += nfound;
1074 1.1 yamt }
1075 1.1 yamt assert(total == nnodes);
1076 1.1 yamt }
1077 1.1 yamt gettimeofday(&etv, NULL);
1078 1.1 yamt printops("ganglookup", nnodes, &stv, &etv);
1079 1.1 yamt
1080 1.1 yamt for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
1081 1.1 yamt gettimeofday(&stv, NULL);
1082 1.1 yamt {
1083 1.1 yamt struct testnode *results[TEST2_GANG_LOOKUP_NODES];
1084 1.1 yamt uint64_t nextidx;
1085 1.1 yamt unsigned int nfound;
1086 1.1 yamt unsigned int total;
1087 1.1 yamt
1088 1.1 yamt nextidx = 0;
1089 1.1 yamt total = 0;
1090 1.1 yamt while ((nfound = radix_tree_gang_lookup_tagged_node(t,
1091 1.1 yamt nextidx, (void *)results, __arraycount(results),
1092 1.1 yamt tag)) > 0) {
1093 1.1 yamt nextidx = results[nfound - 1]->idx + 1;
1094 1.1 yamt total += nfound;
1095 1.1 yamt }
1096 1.1 yamt assert(total == ntagged[tag]);
1097 1.1 yamt }
1098 1.1 yamt gettimeofday(&etv, NULL);
1099 1.1 yamt printops("ganglookup_tag", ntagged[tag], &stv, &etv);
1100 1.1 yamt }
1101 1.1 yamt
1102 1.1 yamt removed = 0;
1103 1.1 yamt for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
1104 1.1 yamt unsigned int total;
1105 1.1 yamt
1106 1.1 yamt total = 0;
1107 1.1 yamt gettimeofday(&stv, NULL);
1108 1.1 yamt {
1109 1.1 yamt struct testnode *results[TEST2_GANG_LOOKUP_NODES];
1110 1.1 yamt uint64_t nextidx;
1111 1.1 yamt unsigned int nfound;
1112 1.1 yamt
1113 1.1 yamt nextidx = 0;
1114 1.1 yamt while ((nfound = radix_tree_gang_lookup_tagged_node(t,
1115 1.1 yamt nextidx, (void *)results, __arraycount(results),
1116 1.1 yamt tag)) > 0) {
1117 1.1 yamt for (i = 0; i < nfound; i++) {
1118 1.1 yamt radix_tree_remove_node(t,
1119 1.1 yamt results[i]->idx);
1120 1.1 yamt }
1121 1.1 yamt nextidx = results[nfound - 1]->idx + 1;
1122 1.1 yamt total += nfound;
1123 1.1 yamt }
1124 1.1 yamt assert(tag != 0 || total == ntagged[tag]);
1125 1.1 yamt assert(total <= ntagged[tag]);
1126 1.1 yamt }
1127 1.1 yamt gettimeofday(&etv, NULL);
1128 1.1 yamt printops("ganglookup_tag+remove", total, &stv, &etv);
1129 1.1 yamt removed += total;
1130 1.1 yamt }
1131 1.1 yamt
1132 1.1 yamt gettimeofday(&stv, NULL);
1133 1.1 yamt {
1134 1.1 yamt struct testnode *results[TEST2_GANG_LOOKUP_NODES];
1135 1.1 yamt uint64_t nextidx;
1136 1.1 yamt unsigned int nfound;
1137 1.1 yamt unsigned int total;
1138 1.1 yamt
1139 1.1 yamt nextidx = 0;
1140 1.1 yamt total = 0;
1141 1.1 yamt while ((nfound = radix_tree_gang_lookup_node(t, nextidx,
1142 1.1 yamt (void *)results, __arraycount(results))) > 0) {
1143 1.1 yamt for (i = 0; i < nfound; i++) {
1144 1.1 yamt assert(results[i] == radix_tree_remove_node(t,
1145 1.1 yamt results[i]->idx));
1146 1.1 yamt }
1147 1.1 yamt nextidx = results[nfound - 1]->idx + 1;
1148 1.1 yamt total += nfound;
1149 1.1 yamt }
1150 1.1 yamt assert(total == nnodes - removed);
1151 1.1 yamt }
1152 1.1 yamt gettimeofday(&etv, NULL);
1153 1.1 yamt printops("ganglookup+remove", nnodes - removed, &stv, &etv);
1154 1.1 yamt
1155 1.1 yamt radix_tree_fini_tree(t);
1156 1.1 yamt free(nodes);
1157 1.1 yamt }
1158 1.1 yamt
1159 1.1 yamt int
1160 1.1 yamt main(int argc, char *argv[])
1161 1.1 yamt {
1162 1.1 yamt
1163 1.1 yamt test1();
1164 1.1 yamt printf("dense distribution:\n");
1165 1.1 yamt test2(true);
1166 1.1 yamt printf("sparse distribution:\n");
1167 1.1 yamt test2(false);
1168 1.1 yamt return 0;
1169 1.1 yamt }
1170 1.1 yamt
1171 1.1 yamt #endif /* defined(UNITTEST) */
1172