X-Git-Url: https://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=tests%2Ftest_urcu_wfq.c;h=bcdd4c0c461b434dec90d6f69159feb77924b9ed;hp=cb49454e7b06d995f77af55321fc55a385180097;hb=16aa9ee87cf4364921c36025359be01390338d87;hpb=06f22bdbb0c4c4d5db42a2e2dc35818aa61415be diff --git a/tests/test_urcu_wfq.c b/tests/test_urcu_wfq.c index cb49454..bcdd4c0 100644 --- a/tests/test_urcu_wfq.c +++ b/tests/test_urcu_wfq.c @@ -153,7 +153,7 @@ static unsigned long long __thread nr_successful_enqueues; static unsigned int nr_enqueuers; static unsigned int nr_dequeuers; -static struct wfq_queue q; +static struct cds_wfq_queue q; void *thr_enqueuer(void *_count) { @@ -170,11 +170,11 @@ void *thr_enqueuer(void *_count) cmm_smp_mb(); for (;;) { - struct wfq_node *node = malloc(sizeof(*node)); + struct cds_wfq_node *node = malloc(sizeof(*node)); if (!node) goto fail; - wfq_node_init(node); - wfq_enqueue(&q, node); + cds_wfq_node_init(node); + cds_wfq_enqueue(&q, node); nr_successful_enqueues++; if (unlikely(wdelay)) @@ -210,7 +210,7 @@ void *thr_dequeuer(void *_count) cmm_smp_mb(); for (;;) { - struct wfq_node *node = wfq_dequeue_blocking(&q); + struct cds_wfq_node *node = cds_wfq_dequeue_blocking(&q); if (node) { free(node); @@ -233,12 +233,12 @@ void *thr_dequeuer(void *_count) return ((void*)2); } -void test_end(struct wfq_queue *q, unsigned long long *nr_dequeues) +void test_end(struct cds_wfq_queue *q, unsigned long long *nr_dequeues) { - struct wfq_node *node; + struct cds_wfq_node *node; do { - node = wfq_dequeue_blocking(q); + node = cds_wfq_dequeue_blocking(q); if (node) { free(node); (*nr_dequeues)++; @@ -337,7 +337,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); - wfq_init(&q); + cds_wfq_init(&q); next_aff = 0;