Commit 3e3cdc68 authored by Matthew Wilcox's avatar Matthew Wilcox Committed by Linus Torvalds

radix tree test suite: check multiorder iteration

The random iteration test only inserts order-0 entries currently.
Update it to insert entries of order between 7 and 0.  Also make the
maximum index configurable, make some variables static, make the test
duration variable, remove some useless spinning, and add a fifth thread
which calls tag_tagged_items().

Link: http://lkml.kernel.org/r/1480369871-5271-62-git-send-email-mawilcox@linuxonhyperv.comSigned-off-by: default avatarMatthew Wilcox <mawilcox@microsoft.com>
Tested-by: default avatarKirill A. Shutemov <kirill.shutemov@linux.intel.com>
Cc: Konstantin Khlebnikov <koct9i@gmail.com>
Cc: Ross Zwisler <ross.zwisler@linux.intel.com>
Cc: Matthew Wilcox <mawilcox@microsoft.com>
Signed-off-by: default avatarAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@linux-foundation.org>
parent a90eb3a2
...@@ -16,26 +16,36 @@ ...@@ -16,26 +16,36 @@
#include <pthread.h> #include <pthread.h>
#include "test.h" #include "test.h"
#define NUM_THREADS 4 #define NUM_THREADS 5
#define TAG 0 #define MAX_IDX 100
#define TAG 0
#define NEW_TAG 1
static pthread_mutex_t tree_lock = PTHREAD_MUTEX_INITIALIZER; static pthread_mutex_t tree_lock = PTHREAD_MUTEX_INITIALIZER;
static pthread_t threads[NUM_THREADS]; static pthread_t threads[NUM_THREADS];
static unsigned int seeds[3]; static unsigned int seeds[3];
RADIX_TREE(tree, GFP_KERNEL); static RADIX_TREE(tree, GFP_KERNEL);
bool test_complete; static bool test_complete;
static int max_order;
/* relentlessly fill the tree with tagged entries */ /* relentlessly fill the tree with tagged entries */
static void *add_entries_fn(void *arg) static void *add_entries_fn(void *arg)
{ {
int pgoff;
rcu_register_thread(); rcu_register_thread();
while (!test_complete) { while (!test_complete) {
for (pgoff = 0; pgoff < 100; pgoff++) { unsigned long pgoff;
int order;
for (pgoff = 0; pgoff < MAX_IDX; pgoff++) {
pthread_mutex_lock(&tree_lock); pthread_mutex_lock(&tree_lock);
if (item_insert(&tree, pgoff) == 0) for (order = max_order; order >= 0; order--) {
item_tag_set(&tree, pgoff, TAG); if (item_insert_order(&tree, pgoff, order)
== 0) {
item_tag_set(&tree, pgoff, TAG);
break;
}
}
pthread_mutex_unlock(&tree_lock); pthread_mutex_unlock(&tree_lock);
} }
} }
...@@ -62,14 +72,7 @@ static void *tagged_iteration_fn(void *arg) ...@@ -62,14 +72,7 @@ static void *tagged_iteration_fn(void *arg)
while (!test_complete) { while (!test_complete) {
rcu_read_lock(); rcu_read_lock();
radix_tree_for_each_tagged(slot, &tree, &iter, 0, TAG) { radix_tree_for_each_tagged(slot, &tree, &iter, 0, TAG) {
void *entry; void *entry = radix_tree_deref_slot(slot);
int i;
/* busy wait to let removals happen */
for (i = 0; i < 1000000; i++)
;
entry = radix_tree_deref_slot(slot);
if (unlikely(!entry)) if (unlikely(!entry))
continue; continue;
...@@ -110,14 +113,7 @@ static void *untagged_iteration_fn(void *arg) ...@@ -110,14 +113,7 @@ static void *untagged_iteration_fn(void *arg)
while (!test_complete) { while (!test_complete) {
rcu_read_lock(); rcu_read_lock();
radix_tree_for_each_slot(slot, &tree, &iter, 0) { radix_tree_for_each_slot(slot, &tree, &iter, 0) {
void *entry; void *entry = radix_tree_deref_slot(slot);
int i;
/* busy wait to let removals happen */
for (i = 0; i < 1000000; i++)
;
entry = radix_tree_deref_slot(slot);
if (unlikely(!entry)) if (unlikely(!entry))
continue; continue;
...@@ -152,7 +148,7 @@ static void *remove_entries_fn(void *arg) ...@@ -152,7 +148,7 @@ static void *remove_entries_fn(void *arg)
while (!test_complete) { while (!test_complete) {
int pgoff; int pgoff;
pgoff = rand_r(&seeds[2]) % 100; pgoff = rand_r(&seeds[2]) % MAX_IDX;
pthread_mutex_lock(&tree_lock); pthread_mutex_lock(&tree_lock);
item_delete(&tree, pgoff); item_delete(&tree, pgoff);
...@@ -164,36 +160,54 @@ static void *remove_entries_fn(void *arg) ...@@ -164,36 +160,54 @@ static void *remove_entries_fn(void *arg)
return NULL; return NULL;
} }
static void *tag_entries_fn(void *arg)
{
rcu_register_thread();
while (!test_complete) {
tag_tagged_items(&tree, &tree_lock, 0, MAX_IDX, 10, TAG,
NEW_TAG);
}
rcu_unregister_thread();
return NULL;
}
/* This is a unit test for a bug found by the syzkaller tester */ /* This is a unit test for a bug found by the syzkaller tester */
void iteration_test(void) void iteration_test(unsigned order, unsigned test_duration)
{ {
int i; int i;
printf("Running iteration tests for 10 seconds\n"); printf("Running %siteration tests for %d seconds\n",
order > 0 ? "multiorder " : "", test_duration);
max_order = order;
test_complete = false; test_complete = false;
for (i = 0; i < 3; i++) for (i = 0; i < 3; i++)
seeds[i] = rand(); seeds[i] = rand();
if (pthread_create(&threads[0], NULL, tagged_iteration_fn, NULL)) { if (pthread_create(&threads[0], NULL, tagged_iteration_fn, NULL)) {
perror("pthread_create"); perror("create tagged iteration thread");
exit(1); exit(1);
} }
if (pthread_create(&threads[1], NULL, untagged_iteration_fn, NULL)) { if (pthread_create(&threads[1], NULL, untagged_iteration_fn, NULL)) {
perror("pthread_create"); perror("create untagged iteration thread");
exit(1); exit(1);
} }
if (pthread_create(&threads[2], NULL, add_entries_fn, NULL)) { if (pthread_create(&threads[2], NULL, add_entries_fn, NULL)) {
perror("pthread_create"); perror("create add entry thread");
exit(1); exit(1);
} }
if (pthread_create(&threads[3], NULL, remove_entries_fn, NULL)) { if (pthread_create(&threads[3], NULL, remove_entries_fn, NULL)) {
perror("pthread_create"); perror("create remove entry thread");
exit(1);
}
if (pthread_create(&threads[4], NULL, tag_entries_fn, NULL)) {
perror("create tag entry thread");
exit(1); exit(1);
} }
sleep(10); sleep(test_duration);
test_complete = true; test_complete = true;
for (i = 0; i < NUM_THREADS; i++) { for (i = 0; i < NUM_THREADS; i++) {
......
...@@ -350,7 +350,8 @@ int main(int argc, char **argv) ...@@ -350,7 +350,8 @@ int main(int argc, char **argv)
regression1_test(); regression1_test();
regression2_test(); regression2_test();
regression3_test(); regression3_test();
iteration_test(); iteration_test(0, 10);
iteration_test(7, 20);
single_thread_tests(long_run); single_thread_tests(long_run);
/* Free any remaining preallocated nodes */ /* Free any remaining preallocated nodes */
......
...@@ -75,8 +75,27 @@ static void __multiorder_tag_test(int index, int order) ...@@ -75,8 +75,27 @@ static void __multiorder_tag_test(int index, int order)
item_kill_tree(&tree); item_kill_tree(&tree);
} }
static void __multiorder_tag_test2(unsigned order, unsigned long index2)
{
RADIX_TREE(tree, GFP_KERNEL);
unsigned long index = (1 << order);
index2 += index;
assert(item_insert_order(&tree, 0, order) == 0);
assert(item_insert(&tree, index2) == 0);
assert(radix_tree_tag_set(&tree, 0, 0));
assert(radix_tree_tag_set(&tree, index2, 0));
assert(tag_tagged_items(&tree, NULL, 0, ~0UL, 10, 0, 1) == 2);
item_kill_tree(&tree);
}
static void multiorder_tag_tests(void) static void multiorder_tag_tests(void)
{ {
int i, j;
/* test multi-order entry for indices 0-7 with no sibling pointers */ /* test multi-order entry for indices 0-7 with no sibling pointers */
__multiorder_tag_test(0, 3); __multiorder_tag_test(0, 3);
__multiorder_tag_test(5, 3); __multiorder_tag_test(5, 3);
...@@ -116,6 +135,10 @@ static void multiorder_tag_tests(void) ...@@ -116,6 +135,10 @@ static void multiorder_tag_tests(void)
__multiorder_tag_test(300, 8); __multiorder_tag_test(300, 8);
__multiorder_tag_test(0x12345678UL, 8); __multiorder_tag_test(0x12345678UL, 8);
for (i = 1; i < 10; i++)
for (j = 0; j < (10 << i); j++)
__multiorder_tag_test2(i, j);
} }
static void multiorder_check(unsigned long index, int order) static void multiorder_check(unsigned long index, int order)
......
...@@ -32,7 +32,7 @@ unsigned long find_item(struct radix_tree_root *, void *item); ...@@ -32,7 +32,7 @@ unsigned long find_item(struct radix_tree_root *, void *item);
void tag_check(void); void tag_check(void);
void multiorder_checks(void); void multiorder_checks(void);
void iteration_test(void); void iteration_test(unsigned order, unsigned duration);
void benchmark(void); void benchmark(void);
struct item * struct item *
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment