X-Git-Url: https://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=tests%2Ftest_urcu_lfq.c;h=82a90b0cdecc23f05c3572cf6b6819f00ac72531;hp=b61a7d4815788af2bcd9e197dc319a8eb053791a;hb=7618919ae496bda84a2efa4f2ad0abe569892a9e;hpb=4a0b347ad068737b5ab0565cd4506f2f3b21e1f2 diff --git a/tests/test_urcu_lfq.c b/tests/test_urcu_lfq.c index b61a7d4..82a90b0 100644 --- a/tests/test_urcu_lfq.c +++ b/tests/test_urcu_lfq.c @@ -180,9 +180,7 @@ void *thr_enqueuer(void *_count) if (!node) goto fail; cds_lfq_node_init_rcu(node); - rcu_read_lock(); cds_lfq_enqueue_rcu(&q, node); - rcu_read_unlock(); nr_successful_enqueues++; if (unlikely(wdelay)) @@ -230,10 +228,7 @@ void *thr_dequeuer(void *_count) for (;;) { struct cds_lfq_node_rcu *node; - rcu_read_lock(); node = cds_lfq_dequeue_rcu(&q); - rcu_read_unlock(); - if (node) { defer_rcu(free, node); nr_successful_dequeues++; @@ -262,9 +257,7 @@ void test_end(struct cds_lfq_queue_rcu *q, unsigned long long *nr_dequeues) struct cds_lfq_node_rcu *node; do { - rcu_read_lock(); node = cds_lfq_dequeue_rcu(q); - rcu_read_unlock(); if (node) { free(node); /* no more concurrent access */ (*nr_dequeues)++; @@ -363,7 +356,7 @@ int main(int argc, char **argv) tid_dequeuer = malloc(sizeof(*tid_dequeuer) * nr_dequeuers); count_enqueuer = malloc(2 * sizeof(*count_enqueuer) * nr_enqueuers); count_dequeuer = malloc(2 * sizeof(*count_dequeuer) * nr_dequeuers); - cds_lfq_init_rcu(&q, call_rcu); + cds_lfq_init_rcu(&q); next_aff = 0;