Home
last modified time | relevance | path

Searched refs:my_queue_representation (Results 1 – 3 of 3) sorted by relevance

/oneTBB/include/oneapi/tbb/
H A Dconcurrent_queue.h101my_queue_representation->assign(*src.my_queue_representation, my_allocator, copy_construct_item); in concurrent_queue()
107my_queue_representation->assign(*src.my_queue_representation, my_allocator, copy_construct_item); in concurrent_queue()
141 if (my_queue_representation != other.my_queue_representation) {
151 if (my_queue_representation != other.my_queue_representation) {
173my_queue_representation->assign(*src.my_queue_representation, my_allocator, move_construct_item); in assign()
240 swap(my_queue_representation, src.my_queue_representation); in internal_swap()
379my_queue_representation->assign(*src.my_queue_representation, my_allocator, copy_construct_item); in concurrent_bounded_queue()
385my_queue_representation->assign(*src.my_queue_representation, my_allocator, copy_construct_item); in concurrent_bounded_queue()
420 if (my_queue_representation != other.my_queue_representation) {
430 if (my_queue_representation != other.my_queue_representation) {
[all …]
/oneTBB/test/tbb/
H A Dtest_concurrent_queue_whitebox.cpp66 std::size_t nq = q.my_queue_representation->n_queue; in test_flogger_help()
70 q.my_queue_representation->head_counter = hack_val; in test_flogger_help()
71 q.my_queue_representation->tail_counter = hack_val; in test_flogger_help()
73 std::size_t k = q.my_queue_representation->tail_counter & -(std::ptrdiff_t)nq; in test_flogger_help()
76 q.my_queue_representation->array[i].head_counter = k; in test_flogger_help()
77 q.my_queue_representation->array[i].tail_counter = k; in test_flogger_help()
84 REQUIRE_MESSAGE(q.my_queue_representation->head_counter < hack_val, "Failed wraparound test"); in test_flogger_help()
91 test_flogger_help(q, q.my_queue_representation->items_per_page);
99 test_flogger_help(q, q.my_queue_representation->items_per_page);
/oneTBB/include/oneapi/tbb/detail/
H A D_concurrent_queue_base.h611 : base_type(container.my_queue_representation) {} in concurrent_queue_iterator()