Lines Matching refs:r1
77 …my_queue_representation = static_cast<queue_representation_type*>(r1::cache_aligned_allocate(sizeo… in concurrent_queue()
136 r1::cache_aligned_deallocate(my_queue_representation); in ~concurrent_queue()
303 namespace r1 {
329 …void internal_wait(r1::concurrent_monitor* monitors, std::size_t monitor_tag, std::ptrdiff_t targe… in internal_wait()
331 r1::wait_bounded_queue_monitor(monitors, monitor_tag, target, func); in internal_wait()
353 r1::allocate_bounded_queue_rep(sizeof(queue_representation_type))); in concurrent_bounded_queue()
354 my_monitors = reinterpret_cast<r1::concurrent_monitor*>(my_queue_representation + 1); in concurrent_bounded_queue()
414 r1::deallocate_bounded_queue_rep(reinterpret_cast<std::uint8_t*>(my_queue_representation), in ~concurrent_bounded_queue()
580 r1::notify_bounded_queue_monitor(my_monitors, cbq_items_avail_tag, ticket); in internal_push()
596 r1::notify_bounded_queue_monitor(my_monitors, cbq_items_avail_tag, ticket); in internal_push_if_not_full()
625 r1::notify_bounded_queue_monitor(my_monitors, cbq_slots_avail_tag, target); in internal_pop()
634 r1::notify_bounded_queue_monitor(my_monitors, cbq_slots_avail_tag, ticket); in internal_pop_if_present()
641 r1::abort_bounded_queue_monitors(my_monitors); in internal_abort()
662 r1::concurrent_monitor* my_monitors;
694 using detail::r1::user_abort;
695 using detail::r1::bad_last_alloc;