X-Git-Url: https://git.lttng.org/?p=urcu.git;a=blobdiff_plain;f=include%2Furcu%2Fstatic%2Fwfqueue.h;fp=include%2Furcu%2Fstatic%2Fwfqueue.h;h=d04f66f35c895d4184e5056d7172ce8d865f69e3;hp=df9f62f28bafa189a5b2f0d61fcbfce8b978b7b4;hb=014775106c60f02818ca755b331f887030bd440f;hpb=2a27e9319bacc9bc98f38afb7e4f050601ab979b diff --git a/include/urcu/static/wfqueue.h b/include/urcu/static/wfqueue.h index df9f62f..d04f66f 100644 --- a/include/urcu/static/wfqueue.h +++ b/include/urcu/static/wfqueue.h @@ -27,8 +27,8 @@ */ #include -#include #include +#include #include #include @@ -62,13 +62,13 @@ static inline void _cds_wfq_init(struct cds_wfq_queue *q) q->head = &q->dummy; q->tail = &q->dummy.next; ret = pthread_mutex_init(&q->lock, NULL); - assert(!ret); + urcu_posix_assert(!ret); } static inline void _cds_wfq_destroy(struct cds_wfq_queue *q) { int ret = pthread_mutex_destroy(&q->lock); - assert(!ret); + urcu_posix_assert(!ret); } static inline void _cds_wfq_enqueue(struct cds_wfq_queue *q, @@ -157,10 +157,10 @@ _cds_wfq_dequeue_blocking(struct cds_wfq_queue *q) int ret; ret = pthread_mutex_lock(&q->lock); - assert(!ret); + urcu_posix_assert(!ret); retnode = ___cds_wfq_dequeue_blocking(q); ret = pthread_mutex_unlock(&q->lock); - assert(!ret); + urcu_posix_assert(!ret); return retnode; }