Searched refs:consumer_head (Results 1 – 4 of 4) sorted by relevance
33 int consumer_head ____cacheline_aligned_in_smp; /* next valid entry */172 return READ_ONCE(r->queue[r->consumer_head]); in __ptr_ring_peek()197 return !r->queue[READ_ONCE(r->consumer_head)]; in __ptr_ring_empty()249 static inline void __ptr_ring_zero_tail(struct ptr_ring *r, int consumer_head) in __ptr_ring_zero_tail() argument251 int head = consumer_head; in __ptr_ring_zero_tail()261 r->consumer_tail = consumer_head; in __ptr_ring_zero_tail()282 int consumer_head = r->consumer_head + 1; in __ptr_ring_discard_one() local289 if (unlikely(consumer_head - r->consumer_tail >= r->batch || in __ptr_ring_discard_one()290 consumer_head >= r->size)) in __ptr_ring_discard_one()291 __ptr_ring_zero_tail(r, consumer_head); in __ptr_ring_discard_one()[all …]
503 u64 consumer_head; /* Offset in peer queue. */ member854 return vmci_q_read_pointer(&qh->consumer_head); in vmci_q_header_consumer_head()878 vmci_qp_add_pointer(&q_header->consumer_head, add, queue_size); in vmci_q_header_add_consumer_head()889 u64 *consumer_head) in vmci_q_header_get_pointers() argument894 if (consumer_head) in vmci_q_header_get_pointers()895 *consumer_head = vmci_q_header_consumer_head(consume_q_header); in vmci_q_header_get_pointers()903 q_header->consumer_head = 0; in vmci_q_header_init()
55 u64 *consumer_head);
2824 u64 *consumer_head) in vmci_qpair_get_produce_indexes() argument2838 producer_tail, consumer_head); in vmci_qpair_get_produce_indexes()2843 (consumer_head && *consumer_head >= qpair->produce_q_size))) in vmci_qpair_get_produce_indexes()