X-Git-Url: https://git.lttng.org/?p=urcu.git;a=blobdiff_plain;f=src%2Fworkqueue.c;h=14957a0d3910aa83740d4e22b5420aa48658cf84;hp=6707ffe3b45e2c2226d99c3b163d4e1c820028aa;hb=89d19b437b1467f98ecee4190d1160e99111671f;hpb=d25f25df027b158726f8a361e52f0e3a7529d5eb diff --git a/src/workqueue.c b/src/workqueue.c index 6707ffe..14957a0 100644 --- a/src/workqueue.c +++ b/src/workqueue.c @@ -238,18 +238,18 @@ static void *workqueue_thread(void *arg) if (cds_wfcq_empty(&workqueue->cbs_head, &workqueue->cbs_tail)) { futex_wait(&workqueue->futex); - (void) poll(NULL, 0, 10); uatomic_dec(&workqueue->futex); /* * Decrement futex before reading * urcu_work list. */ cmm_smp_mb(); - } else { - (void) poll(NULL, 0, 10); } } else { - (void) poll(NULL, 0, 10); + if (cds_wfcq_empty(&workqueue->cbs_head, + &workqueue->cbs_tail)) { + (void) poll(NULL, 0, 10); + } } if (workqueue->worker_after_wake_up_fct) workqueue->worker_after_wake_up_fct(workqueue, workqueue->priv);