Lines Matching refs:consumer_index
98 cons = smp_load_acquire(&q->buf->consumer_index); in queue_empty()
102 cons = q->buf->consumer_index; in queue_empty()
123 cons = smp_load_acquire(&q->buf->consumer_index); in queue_full()
127 cons = q->buf->consumer_index; in queue_full()
149 cons = smp_load_acquire(&q->buf->consumer_index); in queue_count()
153 cons = q->buf->consumer_index; in queue_count()
193 q->buf->consumer_index = q->index; in advance_consumer()
198 cons = smp_load_acquire(&q->buf->consumer_index); in advance_consumer()
201 smp_store_release(&q->buf->consumer_index, cons); in advance_consumer()
204 cons = q->buf->consumer_index; in advance_consumer()
205 q->buf->consumer_index = (cons + 1) & q->index_mask; in advance_consumer()
241 cons = smp_load_acquire(&q->buf->consumer_index); in consumer_addr()
245 cons = q->buf->consumer_index; in consumer_addr()
274 static inline unsigned int consumer_index(struct rxe_queue *q, in consumer_index() function
285 cons = smp_load_acquire(&q->buf->consumer_index); in consumer_index()
289 cons = q->buf->consumer_index; in consumer_index()