assert(!ret);
}
+static inline void _cds_wfq_destroy(struct cds_wfq_queue *q)
+{
+ int ret = pthread_mutex_destroy(&q->lock);
+ assert(!ret);
+}
+
static inline void _cds_wfq_enqueue(struct cds_wfq_queue *q,
struct cds_wfq_node *node)
{
*/
while ((next = CMM_LOAD_SHARED(node->next)) == NULL) {
if (++attempt >= WFQ_ADAPT_ATTEMPTS) {
- poll(NULL, 0, WFQ_WAIT); /* Wait for 10ms */
+ (void) poll(NULL, 0, WFQ_WAIT); /* Wait for 10ms */
attempt = 0;
} else
caa_cpu_relax();