projects
/
urcu.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
rculfhash: simplify lfht_new API with inline wrapper
[urcu.git]
/
tests
/
test_urcu_hash.c
diff --git
a/tests/test_urcu_hash.c
b/tests/test_urcu_hash.c
index 49239609d30ef1f8c33f7e0207312c3193ae820b..273283ed5b61d0535fb7281d17d4cf6cb6253aea 100644
(file)
--- a/
tests/test_urcu_hash.c
+++ b/
tests/test_urcu_hash.c
@@
-400,11
+400,12
@@
void *thr_reader(void *_count)
for (;;) {
rcu_read_lock();
node = cds_lfht_lookup(test_ht,
for (;;) {
rcu_read_lock();
node = cds_lfht_lookup(test_ht,
- (void *)(
unsigned long)((
rand_r(&rand_lookup) % lookup_pool_size) + lookup_pool_offset),
+ (void *)(
((unsigned long)
rand_r(&rand_lookup) % lookup_pool_size) + lookup_pool_offset),
sizeof(void *));
if (node == NULL) {
if (validate_lookup) {
printf("[ERROR] Lookup cannot find initial node.\n");
sizeof(void *));
if (node == NULL) {
if (validate_lookup) {
printf("[ERROR] Lookup cannot find initial node.\n");
+ exit(-1);
}
lookup_fail++;
} else {
}
lookup_fail++;
} else {
@@
-464,7
+465,7
@@
void *thr_writer(void *_count)
node = malloc(sizeof(struct cds_lfht_node));
rcu_read_lock();
cds_lfht_node_init(node,
node = malloc(sizeof(struct cds_lfht_node));
rcu_read_lock();
cds_lfht_node_init(node,
- (void *)(
unsigned long)((
rand_r(&rand_lookup) % write_pool_size) + write_pool_offset),
+ (void *)(
((unsigned long)
rand_r(&rand_lookup) % write_pool_size) + write_pool_offset),
sizeof(void *));
if (add_unique)
ret_node = cds_lfht_add_unique(test_ht, node);
sizeof(void *));
if (add_unique)
ret_node = cds_lfht_add_unique(test_ht, node);
@@
-480,7
+481,7
@@
void *thr_writer(void *_count)
/* May delete */
rcu_read_lock();
node = cds_lfht_lookup(test_ht,
/* May delete */
rcu_read_lock();
node = cds_lfht_lookup(test_ht,
- (void *)(
unsigned long)((
rand_r(&rand_lookup) % write_pool_size) + write_pool_offset),
+ (void *)(
((unsigned long)
rand_r(&rand_lookup) % write_pool_size) + write_pool_offset),
sizeof(void *));
if (node)
ret = cds_lfht_remove(test_ht, node);
sizeof(void *));
if (node)
ret = cds_lfht_remove(test_ht, node);
@@
-544,7
+545,7
@@
static int populate_hash(void)
while (nr_add < init_populate) {
node = malloc(sizeof(struct cds_lfht_node));
cds_lfht_node_init(node,
while (nr_add < init_populate) {
node = malloc(sizeof(struct cds_lfht_node));
cds_lfht_node_init(node,
- (void *)(
unsigned long)((
rand_r(&rand_lookup) % init_pool_size) + init_pool_offset),
+ (void *)(
((unsigned long)
rand_r(&rand_lookup) % init_pool_size) + init_pool_offset),
sizeof(void *));
if (add_unique)
ret_node = cds_lfht_add_unique(test_ht, node);
sizeof(void *));
if (add_unique)
ret_node = cds_lfht_add_unique(test_ht, node);
@@
-749,10
+750,7
@@
int main(int argc, char **argv)
count_writer = malloc(sizeof(*count_writer) * nr_writers);
test_ht = cds_lfht_new(test_hash, test_compare, 0x42UL,
init_hash_size,
count_writer = malloc(sizeof(*count_writer) * nr_writers);
test_ht = cds_lfht_new(test_hash, test_compare, 0x42UL,
init_hash_size,
- opt_auto_resize ? CDS_LFHT_AUTO_RESIZE : 0,
- call_rcu, synchronize_rcu, rcu_read_lock,
- rcu_read_unlock, rcu_thread_offline,
- rcu_thread_online);
+ opt_auto_resize ? CDS_LFHT_AUTO_RESIZE : 0);
ret = populate_hash();
assert(!ret);
err = create_all_cpu_call_rcu_data(0);
ret = populate_hash();
assert(!ret);
err = create_all_cpu_call_rcu_data(0);
This page took
0.0253 seconds
and
4
git commands to generate.