Lines Matching refs:ticket
33 ticket_type ticket{}; in internal_try_pop_impl()
36 ticket = queue.head_counter.load(std::memory_order_acquire); in internal_try_pop_impl()
38 …ast<std::ptrdiff_t>(queue.tail_counter.load(std::memory_order_relaxed) - ticket) <= 0) { // queue … in internal_try_pop_impl()
40 return { false, ticket }; in internal_try_pop_impl()
44 } while (!queue.head_counter.compare_exchange_strong(ticket, ticket + 1)); in internal_try_pop_impl()
45 } while (!queue.choose(ticket).pop(dst, ticket, queue, alloc)); in internal_try_pop_impl()
46 return { true, ticket }; in internal_try_pop_impl()
310 , std::size_t ticket );
559 ticket_type ticket = my_queue_representation->tail_counter++; in internal_push() local
560 std::ptrdiff_t target = ticket - my_capacity; in internal_push()
574 …my_queue_representation->choose(ticket).abort_push(ticket, *my_queue_representation, my_allocator); in internal_push()
579 …my_queue_representation->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::… in internal_push()
580 r1::notify_bounded_queue_monitor(my_monitors, cbq_items_avail_tag, ticket); in internal_push()
585 ticket_type ticket = my_queue_representation->tail_counter.load(std::memory_order_relaxed); in internal_push_if_not_full() local
587 …if (static_cast<std::ptrdiff_t>(ticket - my_queue_representation->head_counter.load(std::memory_or… in internal_push_if_not_full()
593 … } while (!my_queue_representation->tail_counter.compare_exchange_strong(ticket, ticket + 1)); in internal_push_if_not_full()
595 …my_queue_representation->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::… in internal_push_if_not_full()
596 r1::notify_bounded_queue_monitor(my_monitors, cbq_items_avail_tag, ticket); in internal_push_if_not_full()
630 ticket_type ticket{}; in internal_pop_if_present()
631 … std::tie(present, ticket) = internal_try_pop_impl(dst, *my_queue_representation, my_allocator); in internal_pop_if_present()
634 r1::notify_bounded_queue_monitor(my_monitors, cbq_slots_avail_tag, ticket); in internal_pop_if_present()