X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fworkqueue.c;h=14957a0d3910aa83740d4e22b5420aa48658cf84;hb=803e59362b6d94edff3a36f47a9da3e8dca4bde2;hp=6707ffe3b45e2c2226d99c3b163d4e1c820028aa;hpb=9e19a6b0d350ffb70e9f29d8eea371c6b7ffad72;p=urcu.git 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);