Home
last modified time | relevance | path

Searched refs:receivers (Results 1 – 4 of 4) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_function_node.cpp108 receivers[r]->initialize_map( N, num_senders ); in buffered_levels()
123 receivers[r]->validate(); in buffered_levels()
133 receivers[r]->validate(); in buffered_levels()
180 tbb::flow::make_edge( exe_node, *receivers[r] ); in buffered_levels_with_copy()
205 receivers[r]->validate(); in buffered_levels_with_copy()
214 receivers[r]->validate(); in buffered_levels_with_copy()
274 tbb::flow::make_edge( exe_node, *receivers[r] ); in concurrency_levels()
313 size_t n = receivers[r]->my_count; in concurrency_levels()
315 receivers[r]->my_count = 0; in concurrency_levels()
324 CHECK( int(receivers[r]->my_count) == 0 ); in concurrency_levels()
[all …]
H A Dtest_broadcast_node.cpp88 std::vector< std::shared_ptr<counting_array_receiver<T>> > receivers; in test_serial_broadcasts() local
90 receivers.push_back( std::make_shared<counting_array_receiver<T>>(g) ); in test_serial_broadcasts()
93 tbb::flow::make_edge( b, *receivers[r] ); in test_serial_broadcasts()
102 CHECK_MESSAGE( (*receivers[r])[n] == 1, "" ); in test_serial_broadcasts()
104 tbb::flow::remove_edge( b, *receivers[r] ); in test_serial_broadcasts()
108 CHECK_MESSAGE( (*receivers[0])[0] == 1, "" ); in test_serial_broadcasts()
133 std::vector< std::shared_ptr<counting_array_receiver<T>> > receivers; in run_parallel_broadcasts() local
138 tbb::flow::make_edge( b, *receivers[r] ); in run_parallel_broadcasts()
145 CHECK_MESSAGE( (int)(*receivers[r])[n] == p, "" ); in run_parallel_broadcasts()
147 tbb::flow::remove_edge( b, *receivers[r] ); in run_parallel_broadcasts()
[all …]
H A Dtest_multifunction_node.cpp100 receivers[r]->initialize_map( N, num_senders ); in buffered_levels()
115 receivers[r]->validate(); in buffered_levels()
125 receivers[r]->validate(); in buffered_levels()
165 std::vector< std::shared_ptr<harness_mapped_receiver<OutputType>> > receivers; in buffered_levels_with_copy() local
184 receivers[r]->initialize_map( N, num_senders ); in buffered_levels_with_copy()
196 receivers[r]->validate(); in buffered_levels_with_copy()
205 receivers[r]->validate(); in buffered_levels_with_copy()
299 size_t n = receivers[r]->my_count; in concurrency_levels()
301 receivers[r]->my_count = 0; in concurrency_levels()
310 CHECK_MESSAGE( int(receivers[r]->my_count) == 0, "" ); in concurrency_levels()
[all …]
H A Dtest_continue_node.cpp70 std::vector< std::shared_ptr<harness_counting_receiver<OutputType>> > receivers; in run_continue_nodes() local
72 receivers.push_back( std::make_shared<harness_counting_receiver<OutputType>>(g) ); in run_continue_nodes()
77 tbb::flow::make_edge( n, *receivers[r] ); in run_continue_nodes()
87 size_t c = receivers[r]->my_count; in run_continue_nodes()
93 tbb::flow::remove_edge( n, *receivers[r] ); in run_continue_nodes()
145 std::vector< std::shared_ptr<harness_counting_receiver<OutputType>> > receivers; in continue_nodes_with_copy() local
147 receivers.push_back( std::make_shared<harness_counting_receiver<OutputType>>(g) ); in continue_nodes_with_copy()
151 tbb::flow::make_edge( exe_node, *receivers[r] ); in continue_nodes_with_copy()
159 size_t c = receivers[r]->my_count; in continue_nodes_with_copy()
164 tbb::flow::remove_edge( exe_node, *receivers[r] ); in continue_nodes_with_copy()