X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=wfcqueue.c;h=7f8b588e997b31c0d199ace6c14a4507d9b6b02a;hb=refs%2Fheads%2Fstable-0.8;hp=207df95a5b7a4c3347de699f2fc37886120ac346;hpb=23773356a9fd12bf12627df437d0c7bd20e8ef01;p=userspace-rcu.git diff --git a/wfcqueue.c b/wfcqueue.c index 207df95..7f8b588 100644 --- a/wfcqueue.c +++ b/wfcqueue.c @@ -1,7 +1,7 @@ /* * wfcqueue.c * - * Userspace RCU library - Concurrent queue with Wait-Free Enqueue/Blocking Dequeue + * Userspace RCU library - Concurrent Queue with Wait-Free Enqueue/Blocking Dequeue * * Copyright 2010-2012 - Mathieu Desnoyers * Copyright 2011-2012 - Lai Jiangshan @@ -40,9 +40,14 @@ void cds_wfcq_init(struct cds_wfcq_head *head, _cds_wfcq_init(head, tail); } -bool cds_wfcq_empty(struct cds_wfcq_head *head, +void cds_wfcq_destroy(struct cds_wfcq_head *head, struct cds_wfcq_tail *tail) +{ + _cds_wfcq_destroy(head, tail); +} +bool cds_wfcq_empty(struct cds_wfcq_head *head, + struct cds_wfcq_tail *tail) { return _cds_wfcq_empty(head, tail); } @@ -73,6 +78,14 @@ struct cds_wfcq_node *cds_wfcq_dequeue_blocking( return _cds_wfcq_dequeue_blocking(head, tail); } +struct cds_wfcq_node *cds_wfcq_dequeue_with_state_blocking( + struct cds_wfcq_head *head, + struct cds_wfcq_tail *tail, + int *state) +{ + return _cds_wfcq_dequeue_with_state_blocking(head, tail, state); +} + enum cds_wfcq_ret cds_wfcq_splice_blocking( struct cds_wfcq_head *dest_q_head, struct cds_wfcq_tail *dest_q_tail, @@ -90,6 +103,14 @@ struct cds_wfcq_node *__cds_wfcq_dequeue_blocking( return ___cds_wfcq_dequeue_blocking(head, tail); } +struct cds_wfcq_node *__cds_wfcq_dequeue_with_state_blocking( + struct cds_wfcq_head *head, + struct cds_wfcq_tail *tail, + int *state) +{ + return ___cds_wfcq_dequeue_with_state_blocking(head, tail, state); +} + struct cds_wfcq_node *__cds_wfcq_dequeue_nonblocking( struct cds_wfcq_head *head, struct cds_wfcq_tail *tail) @@ -97,6 +118,14 @@ struct cds_wfcq_node *__cds_wfcq_dequeue_nonblocking( return ___cds_wfcq_dequeue_nonblocking(head, tail); } +struct cds_wfcq_node *__cds_wfcq_dequeue_with_state_nonblocking( + struct cds_wfcq_head *head, + struct cds_wfcq_tail *tail, + int *state) +{ + return ___cds_wfcq_dequeue_with_state_nonblocking(head, tail, state); +} + enum cds_wfcq_ret __cds_wfcq_splice_blocking( struct cds_wfcq_head *dest_q_head, struct cds_wfcq_tail *dest_q_tail,