#include <sys/cdefs.h>
#if defined(_KERNEL) || defined(_STANDALONE)
__KERNEL_RCSID(0, "$NetBSD: radixtree.c,v 1.34 2024/05/04 17:58:24 chs Exp $");
#include <sys/param.h>
#include <sys/errno.h>
#include <sys/kmem.h>
#include <sys/radixtree.h>
#include <lib/libkern/libkern.h>
#if defined(_STANDALONE)
#include <lib/libsa/stand.h>
#endif
#else
__RCSID("$NetBSD: radixtree.c,v 1.34 2024/05/04 17:58:24 chs Exp $");
#include <assert.h>
#include <errno.h>
#include <stdbool.h>
#include <stdlib.h>
#include <string.h>
#if 1
#define KASSERT assert
#else
#define KASSERT(a)
#endif
#endif
#include <sys/radixtree.h>
#define RADIX_TREE_BITS_PER_HEIGHT 4
#define RADIX_TREE_PTR_PER_NODE (1 << RADIX_TREE_BITS_PER_HEIGHT)
#define RADIX_TREE_MAX_HEIGHT (64 / RADIX_TREE_BITS_PER_HEIGHT)
#define RADIX_TREE_INVALID_HEIGHT (RADIX_TREE_MAX_HEIGHT + 1)
__CTASSERT((64 % RADIX_TREE_BITS_PER_HEIGHT) == 0);
__CTASSERT(((1 << RADIX_TREE_TAG_ID_MAX) & (sizeof(int) - 1)) == 0);
#define RADIX_TREE_TAG_MASK ((1 << RADIX_TREE_TAG_ID_MAX) - 1)
static inline void *
entry_ptr(void *p)
{
return (void *)((uintptr_t)p & ~RADIX_TREE_TAG_MASK);
}
static inline unsigned int
entry_tagmask(void *p)
{
return (uintptr_t)p & RADIX_TREE_TAG_MASK;
}
static inline void *
entry_compose(void *p, unsigned int tagmask)
{
return (void *)((uintptr_t)p | tagmask);
}
static inline bool
entry_match_p(void *p, unsigned int tagmask)
{
KASSERT(entry_ptr(p) != NULL || entry_tagmask(p) == 0);
if (p == NULL) {
return false;
}
if (tagmask == 0) {
return true;
}
return (entry_tagmask(p) & tagmask) != 0;
}
struct radix_tree_node {
void *n_ptrs[RADIX_TREE_PTR_PER_NODE];
};
struct radix_tree_path {
struct radix_tree_node_ref {
void **pptr;
} p_refs[RADIX_TREE_MAX_HEIGHT + 1];
unsigned int p_lastidx;
};
static inline void **
path_pptr(const struct radix_tree *t, const struct radix_tree_path *p,
unsigned int height)
{
KASSERT(height <= t->t_height);
return p->p_refs[height].pptr;
}
static inline struct radix_tree_node *
path_node(const struct radix_tree * t, const struct radix_tree_path *p,
unsigned int height)
{
KASSERT(height <= t->t_height);
return entry_ptr(*path_pptr(t, p, height));
}
void
radix_tree_init_tree(struct radix_tree *t)
{
t->t_height = 0;
t->t_root = NULL;
}
void
radix_tree_fini_tree(struct radix_tree *t)
{
KASSERT(t->t_root == NULL);
KASSERT(t->t_height == 0);
}
bool
radix_tree_empty_tree_p(struct radix_tree *t)
{
return t->t_root == NULL;
}
bool
radix_tree_empty_tagged_tree_p(struct radix_tree *t, unsigned int tagmask)
{
KASSERT(tagmask != 0);
return (entry_tagmask(t->t_root) & tagmask) == 0;
}
static void
radix_tree_node_init(struct radix_tree_node *n)
{
memset(n, 0, sizeof(*n));
}
#if defined(_KERNEL)
void
radix_tree_init(void)
{
}
void
radix_tree_await_memory(void)
{
struct radix_tree_node *nodes[RADIX_TREE_MAX_HEIGHT];
int i;
for (i = 0; i < __arraycount(nodes); i++) {
nodes[i] = kmem_intr_alloc(sizeof(struct radix_tree_node),
KM_SLEEP);
}
while (--i >= 0) {
kmem_intr_free(nodes[i], sizeof(struct radix_tree_node));
}
}
#endif
static uintptr_t
radix_tree_sum_node(const struct radix_tree_node *n)
{
#if RADIX_TREE_PTR_PER_NODE > 16
unsigned int i;
uintptr_t sum;
for (i = 0, sum = 0; i < RADIX_TREE_PTR_PER_NODE; i++) {
sum |= (uintptr_t)n->n_ptrs[i];
}
return sum;
#else
uintptr_t sum;
sum = (uintptr_t)n->n_ptrs[0];
sum |= (uintptr_t)n->n_ptrs[1];
sum |= (uintptr_t)n->n_ptrs[2];
sum |= (uintptr_t)n->n_ptrs[3];
#if RADIX_TREE_PTR_PER_NODE > 4
sum |= (uintptr_t)n->n_ptrs[4];
sum |= (uintptr_t)n->n_ptrs[5];
sum |= (uintptr_t)n->n_ptrs[6];
sum |= (uintptr_t)n->n_ptrs[7];
#endif
#if RADIX_TREE_PTR_PER_NODE > 8
sum |= (uintptr_t)n->n_ptrs[8];
sum |= (uintptr_t)n->n_ptrs[9];
sum |= (uintptr_t)n->n_ptrs[10];
sum |= (uintptr_t)n->n_ptrs[11];
sum |= (uintptr_t)n->n_ptrs[12];
sum |= (uintptr_t)n->n_ptrs[13];
sum |= (uintptr_t)n->n_ptrs[14];
sum |= (uintptr_t)n->n_ptrs[15];
#endif
return sum;
#endif
}
static int __unused
radix_tree_node_count_ptrs(const struct radix_tree_node *n)
{
unsigned int i, c;
for (i = c = 0; i < RADIX_TREE_PTR_PER_NODE; i++) {
c += (n->n_ptrs[i] != NULL);
}
return c;
}
static struct radix_tree_node *
radix_tree_alloc_node(void)
{
struct radix_tree_node *n;
#if defined(_KERNEL)
n = kmem_intr_alloc(sizeof(struct radix_tree_node), KM_NOSLEEP);
#elif defined(_STANDALONE)
n = alloc(sizeof(*n));
#else
n = malloc(sizeof(*n));
#endif
if (n != NULL) {
radix_tree_node_init(n);
}
KASSERT(n == NULL || radix_tree_sum_node(n) == 0);
return n;
}
static void
radix_tree_free_node(struct radix_tree_node *n)
{
KASSERT(radix_tree_sum_node(n) == 0);
#if defined(_KERNEL)
kmem_intr_free(n, sizeof(struct radix_tree_node));
#elif defined(_STANDALONE)
dealloc(n, sizeof(*n));
#else
free(n);
#endif
}
static __noinline int
radix_tree_grow(struct radix_tree *t, unsigned int newheight)
{
const unsigned int tagmask = entry_tagmask(t->t_root);
struct radix_tree_node *newnodes[RADIX_TREE_MAX_HEIGHT];
void *root;
int h;
KASSERT(newheight <= RADIX_TREE_MAX_HEIGHT);
if ((root = t->t_root) == NULL) {
t->t_height = newheight;
return 0;
}
for (h = t->t_height; h < newheight; h++) {
newnodes[h] = radix_tree_alloc_node();
if (__predict_false(newnodes[h] == NULL)) {
while (--h >= (int)t->t_height) {
newnodes[h]->n_ptrs[0] = NULL;
radix_tree_free_node(newnodes[h]);
}
return ENOMEM;
}
newnodes[h]->n_ptrs[0] = root;
root = entry_compose(newnodes[h], tagmask);
}
t->t_root = root;
t->t_height = h;
return 0;
}
static inline void **
radix_tree_lookup_ptr(struct radix_tree *t, uint64_t idx,
struct radix_tree_path *path, bool alloc, const unsigned int tagmask)
{
struct radix_tree_node *n;
int hshift = RADIX_TREE_BITS_PER_HEIGHT * t->t_height;
int shift;
void **vpp;
const uint64_t mask = (UINT64_C(1) << RADIX_TREE_BITS_PER_HEIGHT) - 1;
struct radix_tree_node_ref *refs = NULL;
KASSERT(tagmask == 0 || !alloc);
KASSERT(path == NULL || !alloc);
vpp = &t->t_root;
if (path != NULL) {
refs = path->p_refs;
refs->pptr = vpp;
}
n = NULL;
for (shift = 64 - RADIX_TREE_BITS_PER_HEIGHT; shift >= 0;) {
struct radix_tree_node *c;
void *entry;
const uint64_t i = (idx >> shift) & mask;
if (shift >= hshift) {
unsigned int newheight;
KASSERT(vpp == &t->t_root);
if (i == 0) {
shift -= RADIX_TREE_BITS_PER_HEIGHT;
continue;
}
if (!alloc) {
if (path != NULL) {
KASSERT((refs - path->p_refs) == 0);
path->p_lastidx =
RADIX_TREE_INVALID_HEIGHT;
}
return NULL;
}
newheight = shift / RADIX_TREE_BITS_PER_HEIGHT + 1;
if (radix_tree_grow(t, newheight)) {
return NULL;
}
hshift = RADIX_TREE_BITS_PER_HEIGHT * t->t_height;
}
entry = *vpp;
c = entry_ptr(entry);
if (c == NULL ||
(tagmask != 0 &&
(entry_tagmask(entry) & tagmask) == 0)) {
if (!alloc) {
if (path != NULL) {
path->p_lastidx = refs - path->p_refs;
}
return NULL;
}
c = radix_tree_alloc_node();
if (c == NULL) {
return NULL;
}
*vpp = c;
}
n = c;
vpp = &n->n_ptrs[i];
if (path != NULL) {
refs++;
refs->pptr = vpp;
}
shift -= RADIX_TREE_BITS_PER_HEIGHT;
}
if (alloc) {
KASSERT(*vpp == NULL);
}
if (path != NULL) {
path->p_lastidx = refs - path->p_refs;
}
return vpp;
}
static __noinline void
radix_tree_undo_insert_node(struct radix_tree *t, uint64_t idx)
{
struct radix_tree_path path;
int i;
(void)radix_tree_lookup_ptr(t, idx, &path, false, 0);
if (path.p_lastidx == RADIX_TREE_INVALID_HEIGHT) {
return;
}
for (i = path.p_lastidx - 1; i >= 0; i--) {
struct radix_tree_node ** const pptr =
(struct radix_tree_node **)path_pptr(t, &path, i);
struct radix_tree_node *n;
KASSERT(pptr != NULL);
n = entry_ptr(*pptr);
KASSERT(n != NULL);
if (radix_tree_sum_node(n) != 0) {
break;
}
radix_tree_free_node(n);
*pptr = NULL;
}
if (i < 0) {
KASSERT(t->t_root == NULL);
t->t_height = 0;
}
}
int
radix_tree_insert_node(struct radix_tree *t, uint64_t idx, void *p)
{
void **vpp;
KASSERT(p != NULL);
KASSERT(entry_tagmask(entry_compose(p, 0)) == 0);
vpp = radix_tree_lookup_ptr(t, idx, NULL, true, 0);
if (__predict_false(vpp == NULL)) {
radix_tree_undo_insert_node(t, idx);
return ENOMEM;
}
KASSERT(*vpp == NULL);
*vpp = p;
return 0;
}
void *
radix_tree_replace_node(struct radix_tree *t, uint64_t idx, void *p)
{
void **vpp;
void *oldp;
KASSERT(p != NULL);
KASSERT(entry_tagmask(entry_compose(p, 0)) == 0);
vpp = radix_tree_lookup_ptr(t, idx, NULL, false, 0);
KASSERT(vpp != NULL);
oldp = *vpp;
KASSERT(oldp != NULL);
*vpp = entry_compose(p, entry_tagmask(*vpp));
return entry_ptr(oldp);
}
void *
radix_tree_remove_node(struct radix_tree *t, uint64_t idx)
{
struct radix_tree_path path;
void **vpp;
void *oldp;
int i;
vpp = radix_tree_lookup_ptr(t, idx, &path, false, 0);
KASSERT(vpp != NULL);
oldp = *vpp;
KASSERT(oldp != NULL);
KASSERT(path.p_lastidx == t->t_height);
KASSERT(vpp == path_pptr(t, &path, path.p_lastidx));
*vpp = NULL;
for (i = t->t_height - 1; i >= 0; i--) {
void *entry;
struct radix_tree_node ** const pptr =
(struct radix_tree_node **)path_pptr(t, &path, i);
struct radix_tree_node *n;
KASSERT(pptr != NULL);
entry = *pptr;
n = entry_ptr(entry);
KASSERT(n != NULL);
if (radix_tree_sum_node(n) != 0) {
break;
}
radix_tree_free_node(n);
*pptr = NULL;
}
if (i < 0) {
KASSERT(t->t_root == NULL);
t->t_height = 0;
}
for (; i >= 0; i--) {
void *entry;
struct radix_tree_node ** const pptr =
(struct radix_tree_node **)path_pptr(t, &path, i);
struct radix_tree_node *n;
unsigned int newmask;
KASSERT(pptr != NULL);
entry = *pptr;
n = entry_ptr(entry);
KASSERT(n != NULL);
KASSERT(radix_tree_sum_node(n) != 0);
newmask = radix_tree_sum_node(n) & RADIX_TREE_TAG_MASK;
if (newmask == entry_tagmask(entry)) {
break;
}
*pptr = entry_compose(n, newmask);
}
return entry_ptr(oldp);
}
void *
radix_tree_lookup_node(struct radix_tree *t, uint64_t idx)
{
void **vpp;
vpp = radix_tree_lookup_ptr(t, idx, NULL, false, 0);
if (vpp == NULL) {
return NULL;
}
return entry_ptr(*vpp);
}
static inline void
gang_lookup_init(struct radix_tree *t, uint64_t idx,
struct radix_tree_path *path, const unsigned int tagmask)
{
void **vpp __unused;
vpp = radix_tree_lookup_ptr(t, idx, path, false, tagmask);
KASSERT(vpp == NULL ||
vpp == path_pptr(t, path, path->p_lastidx));
KASSERT(&t->t_root == path_pptr(t, path, 0));
KASSERT(path->p_lastidx == RADIX_TREE_INVALID_HEIGHT ||
path->p_lastidx == t->t_height ||
!entry_match_p(*path_pptr(t, path, path->p_lastidx), tagmask));
}
static inline unsigned int
__attribute__((__always_inline__))
gang_lookup_scan(struct radix_tree *t, struct radix_tree_path *path,
void **results, const unsigned int maxresults, const unsigned int tagmask,
const bool reverse, const bool dense)
{
void **vpp;
unsigned int nfound;
unsigned int lastidx;
const int step = reverse ? -1 : 1;
const unsigned int first = reverse ? RADIX_TREE_PTR_PER_NODE - 1 : 0;
const unsigned int last = reverse ? 0 : RADIX_TREE_PTR_PER_NODE - 1;
const unsigned int guard = last + step;
KASSERT(maxresults > 0);
KASSERT(&t->t_root == path_pptr(t, path, 0));
lastidx = path->p_lastidx;
KASSERT(lastidx == RADIX_TREE_INVALID_HEIGHT ||
lastidx == t->t_height ||
!entry_match_p(*path_pptr(t, path, lastidx), tagmask));
nfound = 0;
if (lastidx == RADIX_TREE_INVALID_HEIGHT) {
if (reverse && !dense) {
lastidx = 0;
vpp = path_pptr(t, path, lastidx);
goto descend;
}
return 0;
}
vpp = path_pptr(t, path, lastidx);
while (true) {
struct radix_tree_node *n;
unsigned int i;
if (entry_match_p(*vpp, tagmask)) {
KASSERT(lastidx == t->t_height);
results[nfound] = entry_ptr(*vpp);
nfound++;
if (nfound == maxresults) {
return nfound;
}
} else if (dense) {
return nfound;
}
scan_siblings:
if (lastidx == 0) {
KASSERT(vpp == &t->t_root);
break;
}
n = path_node(t, path, lastidx - 1);
for (i = vpp - n->n_ptrs + step; i != guard; i += step) {
KASSERT(i < RADIX_TREE_PTR_PER_NODE);
if (entry_match_p(n->n_ptrs[i], tagmask)) {
vpp = &n->n_ptrs[i];
break;
} else if (dense) {
return nfound;
}
}
if (i == guard) {
lastidx--;
vpp = path_pptr(t, path, lastidx);
goto scan_siblings;
}
descend:
while (entry_match_p(*vpp, tagmask) && lastidx < t->t_height) {
path->p_refs[lastidx].pptr = vpp;
n = entry_ptr(*vpp);
vpp = &n->n_ptrs[first];
lastidx++;
}
}
return nfound;
}
unsigned int
radix_tree_gang_lookup_node(struct radix_tree *t, uint64_t idx,
void **results, unsigned int maxresults, bool dense)
{
struct radix_tree_path path;
gang_lookup_init(t, idx, &path, 0);
return gang_lookup_scan(t, &path, results, maxresults, 0, false, dense);
}
unsigned int
radix_tree_gang_lookup_node_reverse(struct radix_tree *t, uint64_t idx,
void **results, unsigned int maxresults, bool dense)
{
struct radix_tree_path path;
gang_lookup_init(t, idx, &path, 0);
return gang_lookup_scan(t, &path, results, maxresults, 0, true, dense);
}
unsigned int
radix_tree_gang_lookup_tagged_node(struct radix_tree *t, uint64_t idx,
void **results, unsigned int maxresults, bool dense, unsigned int tagmask)
{
struct radix_tree_path path;
KASSERT(tagmask != 0);
gang_lookup_init(t, idx, &path, tagmask);
return gang_lookup_scan(t, &path, results, maxresults, tagmask, false,
dense);
}
unsigned int
radix_tree_gang_lookup_tagged_node_reverse(struct radix_tree *t, uint64_t idx,
void **results, unsigned int maxresults, bool dense, unsigned int tagmask)
{
struct radix_tree_path path;
KASSERT(tagmask != 0);
gang_lookup_init(t, idx, &path, tagmask);
return gang_lookup_scan(t, &path, results, maxresults, tagmask, true,
dense);
}
unsigned int
radix_tree_get_tag(struct radix_tree *t, uint64_t idx, unsigned int tagmask)
{
#if 1
void **vpp;
vpp = radix_tree_lookup_ptr(t, idx, NULL, false, tagmask);
if (vpp == NULL) {
return false;
}
KASSERT(*vpp != NULL);
return (entry_tagmask(*vpp) & tagmask);
#else
void **vpp;
vpp = radix_tree_lookup_ptr(t, idx, NULL, false, 0);
KASSERT(vpp != NULL);
return (entry_tagmask(*vpp) & tagmask);
#endif
}
void
radix_tree_set_tag(struct radix_tree *t, uint64_t idx, unsigned int tagmask)
{
struct radix_tree_path path;
void **vpp __unused;
int i;
KASSERT(tagmask != 0);
vpp = radix_tree_lookup_ptr(t, idx, &path, false, 0);
KASSERT(vpp != NULL);
KASSERT(*vpp != NULL);
KASSERT(path.p_lastidx == t->t_height);
KASSERT(vpp == path_pptr(t, &path, path.p_lastidx));
for (i = t->t_height; i >= 0; i--) {
void ** const pptr = (void **)path_pptr(t, &path, i);
void *entry;
KASSERT(pptr != NULL);
entry = *pptr;
if ((entry_tagmask(entry) & tagmask) != 0) {
break;
}
*pptr = (void *)((uintptr_t)entry | tagmask);
}
}
void
radix_tree_clear_tag(struct radix_tree *t, uint64_t idx, unsigned int tagmask)
{
struct radix_tree_path path;
void **vpp;
int i;
KASSERT(tagmask != 0);
vpp = radix_tree_lookup_ptr(t, idx, &path, false, 0);
KASSERT(vpp != NULL);
KASSERT(*vpp != NULL);
KASSERT(path.p_lastidx == t->t_height);
KASSERT(vpp == path_pptr(t, &path, path.p_lastidx));
if ((entry_tagmask(*vpp) & tagmask) == 0) {
return;
}
for (i = t->t_height; i >= 0; i--) {
void ** const pptr = (void **)path_pptr(t, &path, i);
void *entry;
KASSERT(pptr != NULL);
entry = *pptr;
KASSERT((entry_tagmask(entry) & tagmask) != 0);
*pptr = entry_compose(entry_ptr(entry),
entry_tagmask(entry) & ~tagmask);
if (0 < i) {
struct radix_tree_node *n = path_node(t, &path, i - 1);
if ((radix_tree_sum_node(n) & tagmask) != 0) {
break;
}
}
}
}
#if defined(UNITTEST)
#include <inttypes.h>
#include <stdio.h>
static void
radix_tree_dump_node(const struct radix_tree *t, void *vp,
uint64_t offset, unsigned int height)
{
struct radix_tree_node *n;
unsigned int i;
for (i = 0; i < t->t_height - height; i++) {
printf(" ");
}
if (entry_tagmask(vp) == 0) {
printf("[%" PRIu64 "] %p", offset, entry_ptr(vp));
} else {
printf("[%" PRIu64 "] %p (tagmask=0x%x)", offset, entry_ptr(vp),
entry_tagmask(vp));
}
if (height == 0) {
printf(" (leaf)\n");
return;
}
n = entry_ptr(vp);
assert((radix_tree_sum_node(n) & RADIX_TREE_TAG_MASK) ==
entry_tagmask(vp));
printf(" (%u children)\n", radix_tree_node_count_ptrs(n));
for (i = 0; i < __arraycount(n->n_ptrs); i++) {
void *c;
c = n->n_ptrs[i];
if (c == NULL) {
continue;
}
radix_tree_dump_node(t, c,
offset + i * (UINT64_C(1) <<
(RADIX_TREE_BITS_PER_HEIGHT * (height - 1))), height - 1);
}
}
void radix_tree_dump(const struct radix_tree *);
void
radix_tree_dump(const struct radix_tree *t)
{
printf("tree %p height=%u\n", t, t->t_height);
radix_tree_dump_node(t, t->t_root, 0, t->t_height);
}
static void
test1(void)
{
struct radix_tree s;
struct radix_tree *t = &s;
void *results[3];
radix_tree_init_tree(t);
radix_tree_dump(t);
assert(radix_tree_lookup_node(t, 0) == NULL);
assert(radix_tree_lookup_node(t, 1000) == NULL);
assert(radix_tree_gang_lookup_node(t, 0, results, 3, false) == 0);
assert(radix_tree_gang_lookup_node(t, 0, results, 3, true) == 0);
assert(radix_tree_gang_lookup_node(t, 1000, results, 3, false) == 0);
assert(radix_tree_gang_lookup_node(t, 1000, results, 3, true) == 0);
assert(radix_tree_gang_lookup_node_reverse(t, 0, results, 3, false) ==
0);
assert(radix_tree_gang_lookup_node_reverse(t, 0, results, 3, true) ==
0);
assert(radix_tree_gang_lookup_node_reverse(t, 1000, results, 3, false)
== 0);
assert(radix_tree_gang_lookup_node_reverse(t, 1000, results, 3, true)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 3, false, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 3, true, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 1000, results, 3, false, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 1000, results, 3, true, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 0, results, 3,
false, 1) == 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 0, results, 3,
true, 1) == 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 1000, results, 3,
false, 1) == 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 1000, results, 3,
true, 1) == 0);
assert(radix_tree_empty_tree_p(t));
assert(radix_tree_empty_tagged_tree_p(t, 1));
assert(radix_tree_empty_tagged_tree_p(t, 2));
assert(radix_tree_insert_node(t, 0, (void *)0xdeadbea0) == 0);
assert(!radix_tree_empty_tree_p(t));
assert(radix_tree_empty_tagged_tree_p(t, 1));
assert(radix_tree_empty_tagged_tree_p(t, 2));
assert(radix_tree_lookup_node(t, 0) == (void *)0xdeadbea0);
assert(radix_tree_lookup_node(t, 1000) == NULL);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 0, results, 3, false) == 1);
assert(results[0] == (void *)0xdeadbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 0, results, 3, true) == 1);
assert(results[0] == (void *)0xdeadbea0);
assert(radix_tree_gang_lookup_node(t, 1000, results, 3, false) == 0);
assert(radix_tree_gang_lookup_node(t, 1000, results, 3, true) == 0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, 0, results, 3, false) ==
1);
assert(results[0] == (void *)0xdeadbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, 0, results, 3, true) ==
1);
assert(results[0] == (void *)0xdeadbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, 1000, results, 3, false)
== 1);
assert(results[0] == (void *)0xdeadbea0);
assert(radix_tree_gang_lookup_node_reverse(t, 1000, results, 3, true)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 3, false, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 3, true, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 0, results, 3,
false, 1) == 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 0, results, 3,
true, 1) == 0);
assert(radix_tree_insert_node(t, 1000, (void *)0xdeadbea0) == 0);
assert(radix_tree_remove_node(t, 0) == (void *)0xdeadbea0);
assert(!radix_tree_empty_tree_p(t));
radix_tree_dump(t);
assert(radix_tree_lookup_node(t, 0) == NULL);
assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 0, results, 3, false) == 1);
assert(results[0] == (void *)0xdeadbea0);
assert(radix_tree_gang_lookup_node(t, 0, results, 3, true) == 0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 1000, results, 3, false) == 1);
assert(results[0] == (void *)0xdeadbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 1000, results, 3, true) == 1);
assert(results[0] == (void *)0xdeadbea0);
assert(radix_tree_gang_lookup_node_reverse(t, 0, results, 3, false)
== 0);
assert(radix_tree_gang_lookup_node_reverse(t, 0, results, 3, true)
== 0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, 1000, results, 3, false)
== 1);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, 1000, results, 3, true)
== 1);
assert(results[0] == (void *)0xdeadbea0);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 3, false, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 3, true, 1)
== 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 0, results, 3,
false, 1) == 0);
assert(radix_tree_gang_lookup_tagged_node_reverse(t, 0, results, 3,
true, 1) == 0);
assert(!radix_tree_get_tag(t, 1000, 1));
assert(!radix_tree_get_tag(t, 1000, 2));
assert(radix_tree_get_tag(t, 1000, 2 | 1) == 0);
assert(radix_tree_empty_tagged_tree_p(t, 1));
assert(radix_tree_empty_tagged_tree_p(t, 2));
radix_tree_set_tag(t, 1000, 2);
assert(!radix_tree_get_tag(t, 1000, 1));
assert(radix_tree_get_tag(t, 1000, 2));
assert(radix_tree_get_tag(t, 1000, 2 | 1) == 2);
assert(radix_tree_empty_tagged_tree_p(t, 1));
assert(!radix_tree_empty_tagged_tree_p(t, 2));
radix_tree_dump(t);
assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
assert(radix_tree_insert_node(t, 0, (void *)0xbea0) == 0);
radix_tree_dump(t);
assert(radix_tree_lookup_node(t, 0) == (void *)0xbea0);
assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
assert(radix_tree_insert_node(t, UINT64_C(10000000000), (void *)0xdea0)
== 0);
radix_tree_dump(t);
assert(radix_tree_lookup_node(t, 0) == (void *)0xbea0);
assert(radix_tree_lookup_node(t, 1000) == (void *)0xdeadbea0);
assert(radix_tree_lookup_node(t, UINT64_C(10000000000)) ==
(void *)0xdea0);
radix_tree_dump(t);
assert(!radix_tree_get_tag(t, 0, 2));
assert(radix_tree_get_tag(t, 1000, 2));
assert(!radix_tree_get_tag(t, UINT64_C(10000000000), 1));
radix_tree_set_tag(t, 0, 2);
radix_tree_set_tag(t, UINT64_C(10000000000), 2);
radix_tree_dump(t);
assert(radix_tree_get_tag(t, 0, 2));
assert(radix_tree_get_tag(t, 1000, 2));
assert(radix_tree_get_tag(t, UINT64_C(10000000000), 2));
radix_tree_clear_tag(t, 0, 2);
radix_tree_clear_tag(t, UINT64_C(10000000000), 2);
radix_tree_dump(t);
assert(!radix_tree_get_tag(t, 0, 2));
assert(radix_tree_get_tag(t, 1000, 2));
assert(!radix_tree_get_tag(t, UINT64_C(10000000000), 2));
radix_tree_dump(t);
assert(radix_tree_replace_node(t, 1000, (void *)0x12345678) ==
(void *)0xdeadbea0);
assert(!radix_tree_get_tag(t, 1000, 1));
assert(radix_tree_get_tag(t, 1000, 2));
assert(radix_tree_get_tag(t, 1000, 2 | 1) == 2);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 0, results, 3, false) == 3);
assert(results[0] == (void *)0xbea0);
assert(results[1] == (void *)0x12345678);
assert(results[2] == (void *)0xdea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 0, results, 3, true) == 1);
assert(results[0] == (void *)0xbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 1, results, 3, false) == 2);
assert(results[0] == (void *)0x12345678);
assert(results[1] == (void *)0xdea0);
assert(radix_tree_gang_lookup_node(t, 1, results, 3, true) == 0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, 1001, results, 3, false) == 1);
assert(results[0] == (void *)0xdea0);
assert(radix_tree_gang_lookup_node(t, 1001, results, 3, true) == 0);
assert(radix_tree_gang_lookup_node(t, UINT64_C(10000000001), results, 3,
false) == 0);
assert(radix_tree_gang_lookup_node(t, UINT64_C(10000000001), results, 3,
true) == 0);
assert(radix_tree_gang_lookup_node(t, UINT64_C(1000000000000), results,
3, false) == 0);
assert(radix_tree_gang_lookup_node(t, UINT64_C(1000000000000), results,
3, true) == 0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 100, false, 2)
== 1);
assert(results[0] == (void *)0x12345678);
assert(radix_tree_gang_lookup_tagged_node(t, 0, results, 100, true, 2)
== 0);
assert(entry_tagmask(t->t_root) != 0);
assert(radix_tree_remove_node(t, 1000) == (void *)0x12345678);
assert(entry_tagmask(t->t_root) == 0);
radix_tree_dump(t);
assert(radix_tree_insert_node(t, UINT64_C(10000000001), (void *)0xfff0)
== 0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, UINT64_C(10000000000), results, 3,
false) == 2);
assert(results[0] == (void *)0xdea0);
assert(results[1] == (void *)0xfff0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node(t, UINT64_C(10000000000), results, 3,
true) == 2);
assert(results[0] == (void *)0xdea0);
assert(results[1] == (void *)0xfff0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, UINT64_C(10000000001),
results, 3, false) == 3);
assert(results[0] == (void *)0xfff0);
assert(results[1] == (void *)0xdea0);
assert(results[2] == (void *)0xbea0);
memset(results, 0, sizeof(results));
assert(radix_tree_gang_lookup_node_reverse(t, UINT64_C(10000000001),
results, 3, true) == 2);
assert(results[0] == (void *)0xfff0);
assert(results[1] == (void *)0xdea0);
assert(radix_tree_remove_node(t, UINT64_C(10000000000)) ==
(void *)0xdea0);
assert(radix_tree_remove_node(t, UINT64_C(10000000001)) ==
(void *)0xfff0);
radix_tree_dump(t);
assert(radix_tree_remove_node(t, 0) == (void *)0xbea0);
radix_tree_dump(t);
radix_tree_fini_tree(t);
}
#include <sys/time.h>
struct testnode {
uint64_t idx;
bool tagged[RADIX_TREE_TAG_ID_MAX];
};
static void
printops(const char *title, const char *name, int tag, unsigned int n,
const struct timeval *stv, const struct timeval *etv)
{
uint64_t s = stv->tv_sec * 1000000 + stv->tv_usec;
uint64_t e = etv->tv_sec * 1000000 + etv->tv_usec;
printf("RESULT %s %s %d %lf op/s\n", title, name, tag,
(double)n / (e - s) * 1000000);
}
#define TEST2_GANG_LOOKUP_NODES 16
static bool
test2_should_tag(unsigned int i, unsigned int tagid)
{
if (tagid == 0) {
return (i % 4) == 0;
} else {
return (i % 7) == 0;
}
return 1;
}
static void
check_tag_count(const unsigned int *ntagged, unsigned int tagmask,
unsigned int count)
{
unsigned int tag;
for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
if ((tagmask & (1 << tag)) == 0) {
continue;
}
if (((tagmask - 1) & tagmask) == 0) {
assert(count == ntagged[tag]);
} else {
assert(count >= ntagged[tag]);
}
}
}
static void
test2(const char *title, bool dense)
{
struct radix_tree s;
struct radix_tree *t = &s;
struct testnode *n;
unsigned int i;
unsigned int nnodes = 100000;
unsigned int removed;
unsigned int tag;
unsigned int tagmask;
unsigned int ntagged[RADIX_TREE_TAG_ID_MAX];
struct testnode *nodes;
struct timeval stv;
struct timeval etv;
nodes = malloc(nnodes * sizeof(*nodes));
for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
ntagged[tag] = 0;
}
radix_tree_init_tree(t);
for (i = 0; i < nnodes; i++) {
n = &nodes[i];
n->idx = random();
if (sizeof(long) == 4) {
n->idx <<= 32;
n->idx |= (uint32_t)random();
}
if (dense) {
n->idx %= nnodes * 2;
}
while (radix_tree_lookup_node(t, n->idx) != NULL) {
n->idx++;
}
radix_tree_insert_node(t, n->idx, n);
for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
tagmask = 1 << tag;
n->tagged[tag] = test2_should_tag(i, tag);
if (n->tagged[tag]) {
radix_tree_set_tag(t, n->idx, tagmask);
ntagged[tag]++;
}
assert((n->tagged[tag] ? tagmask : 0) ==
radix_tree_get_tag(t, n->idx, tagmask));
}
}
gettimeofday(&stv, NULL);
for (i = 0; i < nnodes; i++) {
n = &nodes[i];
assert(radix_tree_lookup_node(t, n->idx) == n);
}
gettimeofday(&etv, NULL);
printops(title, "lookup", 0, nnodes, &stv, &etv);
for (tagmask = 1; tagmask <= RADIX_TREE_TAG_MASK; tagmask ++) {
unsigned int count = 0;
gettimeofday(&stv, NULL);
for (i = 0; i < nnodes; i++) {
unsigned int tagged;
n = &nodes[i];
tagged = radix_tree_get_tag(t, n->idx, tagmask);
assert((tagged & ~tagmask) == 0);
for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
assert((tagmask & (1 << tag)) == 0 ||
n->tagged[tag] == !!(tagged & (1 << tag)));
}
if (tagged) {
count++;
}
}
gettimeofday(&etv, NULL);
check_tag_count(ntagged, tagmask, count);
printops(title, "get_tag", tagmask, nnodes, &stv, &etv);
}
gettimeofday(&stv, NULL);
for (i = 0; i < nnodes; i++) {
n = &nodes[i];
radix_tree_remove_node(t, n->idx);
}
gettimeofday(&etv, NULL);
printops(title, "remove", 0, nnodes, &stv, &etv);
gettimeofday(&stv, NULL);
for (i = 0; i < nnodes; i++) {
n = &nodes[i];
radix_tree_insert_node(t, n->idx, n);
}
gettimeofday(&etv, NULL);
printops(title, "insert", 0, nnodes, &stv, &etv);
for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
tagmask = 1 << tag;
ntagged[tag] = 0;
gettimeofday(&stv, NULL);
for (i = 0; i < nnodes; i++) {
n = &nodes[i];
if (n->tagged[tag]) {
radix_tree_set_tag(t, n->idx, tagmask);
ntagged[tag]++;
}
}
gettimeofday(&etv, NULL);
printops(title, "set_tag", tag, ntagged[tag], &stv, &etv);
}
gettimeofday(&stv, NULL);
{
struct testnode *results[TEST2_GANG_LOOKUP_NODES];
uint64_t nextidx;
unsigned int nfound;
unsigned int total;
nextidx = 0;
total = 0;
while ((nfound = radix_tree_gang_lookup_node(t, nextidx,
(void *)results, __arraycount(results), false)) > 0) {
nextidx = results[nfound - 1]->idx + 1;
total += nfound;
if (nextidx == 0) {
break;
}
}
assert(total == nnodes);
}
gettimeofday(&etv, NULL);
printops(title, "ganglookup", 0, nnodes, &stv, &etv);
gettimeofday(&stv, NULL);
{
struct testnode *results[TEST2_GANG_LOOKUP_NODES];
uint64_t nextidx;
unsigned int nfound;
unsigned int total;
nextidx = UINT64_MAX;
total = 0;
while ((nfound = radix_tree_gang_lookup_node_reverse(t, nextidx,
(void *)results, __arraycount(results), false)) > 0) {
nextidx = results[nfound - 1]->idx - 1;
total += nfound;
if (nextidx == UINT64_MAX) {
break;
}
}
assert(total == nnodes);
}
gettimeofday(&etv, NULL);
printops(title, "ganglookup_reverse", 0, nnodes, &stv, &etv);
for (tagmask = 1; tagmask <= RADIX_TREE_TAG_MASK; tagmask ++) {
unsigned int total = 0;
gettimeofday(&stv, NULL);
{
struct testnode *results[TEST2_GANG_LOOKUP_NODES];
uint64_t nextidx;
unsigned int nfound;
nextidx = 0;
while ((nfound = radix_tree_gang_lookup_tagged_node(t,
nextidx, (void *)results, __arraycount(results),
false, tagmask)) > 0) {
nextidx = results[nfound - 1]->idx + 1;
total += nfound;
}
}
gettimeofday(&etv, NULL);
check_tag_count(ntagged, tagmask, total);
assert(tagmask != 0 || total == 0);
printops(title, "ganglookup_tag", tagmask, total, &stv, &etv);
}
for (tagmask = 1; tagmask <= RADIX_TREE_TAG_MASK; tagmask ++) {
unsigned int total = 0;
gettimeofday(&stv, NULL);
{
struct testnode *results[TEST2_GANG_LOOKUP_NODES];
uint64_t nextidx;
unsigned int nfound;
nextidx = UINT64_MAX;
while ((nfound =
radix_tree_gang_lookup_tagged_node_reverse(t,
nextidx, (void *)results, __arraycount(results),
false, tagmask)) > 0) {
nextidx = results[nfound - 1]->idx - 1;
total += nfound;
if (nextidx == UINT64_MAX) {
break;
}
}
}
gettimeofday(&etv, NULL);
check_tag_count(ntagged, tagmask, total);
assert(tagmask != 0 || total == 0);
printops(title, "ganglookup_tag_reverse", tagmask, total,
&stv, &etv);
}
removed = 0;
for (tag = 0; tag < RADIX_TREE_TAG_ID_MAX; tag++) {
unsigned int total;
total = 0;
tagmask = 1 << tag;
gettimeofday(&stv, NULL);
{
struct testnode *results[TEST2_GANG_LOOKUP_NODES];
uint64_t nextidx;
unsigned int nfound;
nextidx = 0;
while ((nfound = radix_tree_gang_lookup_tagged_node(t,
nextidx, (void *)results, __arraycount(results),
false, tagmask)) > 0) {
for (i = 0; i < nfound; i++) {
radix_tree_remove_node(t,
results[i]->idx);
}
nextidx = results[nfound - 1]->idx + 1;
total += nfound;
if (nextidx == 0) {
break;
}
}
}
gettimeofday(&etv, NULL);
if (tag == 0) {
check_tag_count(ntagged, tagmask, total);
} else {
assert(total <= ntagged[tag]);
}
printops(title, "ganglookup_tag+remove", tagmask, total, &stv,
&etv);
removed += total;
}
gettimeofday(&stv, NULL);
{
struct testnode *results[TEST2_GANG_LOOKUP_NODES];
uint64_t nextidx;
unsigned int nfound;
unsigned int total;
nextidx = 0;
total = 0;
while ((nfound = radix_tree_gang_lookup_node(t, nextidx,
(void *)results, __arraycount(results), false)) > 0) {
for (i = 0; i < nfound; i++) {
assert(results[i] == radix_tree_remove_node(t,
results[i]->idx));
}
nextidx = results[nfound - 1]->idx + 1;
total += nfound;
if (nextidx == 0) {
break;
}
}
assert(total == nnodes - removed);
}
gettimeofday(&etv, NULL);
printops(title, "ganglookup+remove", 0, nnodes - removed, &stv, &etv);
assert(radix_tree_empty_tree_p(t));
for (tagmask = 1; tagmask <= RADIX_TREE_TAG_MASK; tagmask ++) {
assert(radix_tree_empty_tagged_tree_p(t, tagmask));
}
radix_tree_fini_tree(t);
free(nodes);
}
int
main(int argc, char *argv[])
{
test1();
test2("dense", true);
test2("sparse", false);
return 0;
}
#endif