projects
/
urcu.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add `urcu_posix_assert()` as `assert()` replacement
[urcu.git]
/
include
/
urcu
/
static
/
wfqueue.h
diff --git
a/include/urcu/static/wfqueue.h
b/include/urcu/static/wfqueue.h
index df9f62f28bafa189a5b2f0d61fcbfce8b978b7b4..d04f66f35c895d4184e5056d7172ce8d865f69e3 100644
(file)
--- a/
include/urcu/static/wfqueue.h
+++ b/
include/urcu/static/wfqueue.h
@@
-27,8
+27,8
@@
*/
#include <pthread.h>
*/
#include <pthread.h>
-#include <assert.h>
#include <poll.h>
#include <poll.h>
+#include <urcu/assert.h>
#include <urcu/compiler.h>
#include <urcu/uatomic.h>
#include <urcu/compiler.h>
#include <urcu/uatomic.h>
@@
-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);
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);
}
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,
}
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);
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);
retnode = ___cds_wfq_dequeue_blocking(q);
ret = pthread_mutex_unlock(&q->lock);
- assert(!ret);
+
urcu_posix_
assert(!ret);
return retnode;
}
return retnode;
}
This page took
0.024182 seconds
and
4
git commands to generate.