Lines Matching refs:target

312 …                                             std::ptrdiff_t target, d1::delegate_base& predicate );
329 …(r1::concurrent_monitor* monitors, std::size_t monitor_tag, std::ptrdiff_t target, FuncType pred) { in internal_wait() argument
331 r1::wait_bounded_queue_monitor(monitors, monitor_tag, target, func); in internal_wait()
560 std::ptrdiff_t target = ticket - my_capacity; in internal_push() local
562 …y_queue_representation->head_counter.load(std::memory_order_relaxed)) <= target) { // queue is full in internal_push()
568 …t<std::ptrdiff_t>(my_queue_representation->head_counter.load(std::memory_order_relaxed)) <= target; in internal_push()
572 internal_wait(my_monitors, cbq_slots_avail_tag, target, pred); in internal_push()
578 …diff_t>(my_queue_representation->head_counter.load(std::memory_order_relaxed)) > target), nullptr); in internal_push()
601 std::ptrdiff_t target; in internal_pop() local
606 target = my_queue_representation->head_counter++; in internal_pop()
607 …std::ptrdiff_t>(my_queue_representation->tail_counter.load(std::memory_order_relaxed)) <= target) { in internal_pop()
613 …t<std::ptrdiff_t>(my_queue_representation->tail_counter.load(std::memory_order_relaxed)) <= target; in internal_pop()
617 internal_wait(my_monitors, cbq_items_avail_tag, target, pred); in internal_pop()
622 …rdiff_t>(my_queue_representation->tail_counter.load(std::memory_order_relaxed)) > target, nullptr); in internal_pop()
623 …} while (!my_queue_representation->choose(target).pop(dst, target, *my_queue_representation, my_al… in internal_pop()
625 r1::notify_bounded_queue_monitor(my_monitors, cbq_slots_avail_tag, target); in internal_pop()