X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=tests%2Ftest_urcu_wfq.c;h=e042f5ec115eff39758af279f4d6049761b5d93e;hb=65fcc7e9957a1658327acd121c3d8c3b36f4a94e;hp=cb49454e7b06d995f77af55321fc55a385180097;hpb=06f22bdbb0c4c4d5db42a2e2dc35818aa61415be;p=urcu.git diff --git a/tests/test_urcu_wfq.c b/tests/test_urcu_wfq.c index cb49454..e042f5e 100644 --- a/tests/test_urcu_wfq.c +++ b/tests/test_urcu_wfq.c @@ -34,12 +34,15 @@ #include #include #include -#include #include #include #include +#ifdef __linux__ +#include +#endif + /* hardcoded number of CPUs */ #define NR_CPUS 16384 @@ -153,7 +156,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 +173,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 +213,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 +236,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 +340,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;