Lines Matching refs:q
47 : q(queue), elem_num(el_num) {} in FloggerBody()
53 q.push(elem); in operator ()()
54 bool res = q.try_pop(elem); in operator ()()
60 Q& q; member in FloggerBody
65 void test_flogger_help( Q& q, std::size_t items_per_page ) { in test_flogger_help() argument
66 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()
81 …elFor(static_cast<typename Q::value_type>(utils::MaxThread), FloggerBody<Q>(q, reserved_elem_num +… in test_flogger_help()
83 REQUIRE_MESSAGE(q.empty(), "Failed flogger/empty test"); in test_flogger_help()
84 REQUIRE_MESSAGE(q.my_queue_representation->head_counter < hack_val, "Failed wraparound test"); in test_flogger_help()
90 tbb::concurrent_queue<int> q; variable
91 test_flogger_help(q, q.my_queue_representation->items_per_page);
98 tbb::concurrent_bounded_queue<int> q; variable
99 test_flogger_help(q, q.my_queue_representation->items_per_page);