X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=urcu%2Fstatic%2Fwfcqueue.h;h=2c8c447fd591f46fa213bb6573c79d2a8293316f;hb=207e8061ddfafbdd0502fb6da4896b4c40a49253;hp=a989984b4030b52f79cc737604aed997f2163d4a;hpb=8ad4ce587f001ae026d5560ac509c2e48986130b;p=urcu.git diff --git a/urcu/static/wfcqueue.h b/urcu/static/wfcqueue.h index a989984..2c8c447 100644 --- a/urcu/static/wfcqueue.h +++ b/urcu/static/wfcqueue.h @@ -41,15 +41,18 @@ extern "C" { /* * Concurrent queue with wait-free enqueue/blocking dequeue. * - * Inspired from half-wait-free/half-blocking queue implementation done by - * Paul E. McKenney. + * This queue has been designed and implemented collaboratively by + * Mathieu Desnoyers and Lai Jiangshan. Inspired from + * half-wait-free/half-blocking queue implementation done by Paul E. + * McKenney. * * Mutual exclusion of __cds_wfcq_* API * * Unless otherwise stated, the caller must ensure mutual exclusion of * queue update operations "dequeue" and "splice" (for source queue). - * Queue read operations "first" and "next" need to be protected against - * concurrent "dequeue" and "splice" (for source queue) by the caller. + * Queue read operations "first" and "next", which are used by + * "for_each" iterations, need to be protected against concurrent + * "dequeue" and "splice" (for source queue) by the caller. * "enqueue", "splice" (for destination queue), and "empty" are the only * operations that can be used without any mutual exclusion. * Mutual exclusion can be ensured by holding cds_wfcq_dequeue_lock(). @@ -190,6 +193,10 @@ ___cds_wfcq_node_sync_next(struct cds_wfcq_node *node) * Content written into the node before enqueue is guaranteed to be * consistent, but no other memory ordering is ensured. * Should be called with cds_wfcq_dequeue_lock() held. + * + * Used by for-like iteration macros in urcu/wfqueue.h: + * __cds_wfcq_for_each_blocking() + * __cds_wfcq_for_each_blocking_safe() */ static inline struct cds_wfcq_node * ___cds_wfcq_first_blocking(struct cds_wfcq_head *head, @@ -211,6 +218,10 @@ ___cds_wfcq_first_blocking(struct cds_wfcq_head *head, * Content written into the node before enqueue is guaranteed to be * consistent, but no other memory ordering is ensured. * Should be called with cds_wfcq_dequeue_lock() held. + * + * Used by for-like iteration macros in urcu/wfqueue.h: + * __cds_wfcq_for_each_blocking() + * __cds_wfcq_for_each_blocking_safe() */ static inline struct cds_wfcq_node * ___cds_wfcq_next_blocking(struct cds_wfcq_head *head,