Lines Matching refs:r
90 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels() local
91 tbb::flow::make_edge( exe_vec[node_idx], *receivers[r] ); in buffered_levels()
107 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels() local
108 receivers[r]->initialize_map( N, num_senders ); in buffered_levels()
122 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels() local
123 receivers[r]->validate(); in buffered_levels()
126 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels() local
127 tbb::flow::remove_edge( exe_vec[node_idx], *receivers[r] ); in buffered_levels()
131 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels() local
133 receivers[r]->validate(); in buffered_levels()
179 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels_with_copy() local
180 tbb::flow::make_edge( exe_node, *receivers[r] ); in buffered_levels_with_copy()
192 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels_with_copy() local
193 receivers[r]->initialize_map( N, num_senders ); in buffered_levels_with_copy()
204 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels_with_copy() local
205 receivers[r]->validate(); in buffered_levels_with_copy()
208 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels_with_copy() local
209 tbb::flow::remove_edge( exe_node, *receivers[r] ); in buffered_levels_with_copy()
213 for (size_t r = 0; r < num_receivers; ++r ) { in buffered_levels_with_copy() local
214 receivers[r]->validate(); in buffered_levels_with_copy()
273 for (size_t r = 0; r < num_receivers; ++r ) { in concurrency_levels() local
274 tbb::flow::make_edge( exe_node, *receivers[r] ); in concurrency_levels()
312 for (size_t r = 0; r < num_receivers; ++r ) { in concurrency_levels() local
313 size_t n = receivers[r]->my_count; in concurrency_levels()
315 receivers[r]->my_count = 0; in concurrency_levels()
318 for (size_t r = 0; r < num_receivers; ++r ) { in concurrency_levels() local
319 tbb::flow::remove_edge( exe_node, *receivers[r] ); in concurrency_levels()
323 for (size_t r = 0; r < num_receivers; ++r ) { in concurrency_levels() local
324 CHECK( int(receivers[r]->my_count) == 0 ); in concurrency_levels()
385 for (size_t r = 0; r < num_receivers; ++r ) { in unlimited_concurrency() local
386 tbb::flow::make_edge( exe_node, *receivers[r] ); in unlimited_concurrency()
395 for (size_t r = 0; r < num_receivers; ++r ) { in unlimited_concurrency() local
396 size_t c = receivers[r]->my_count; in unlimited_concurrency()
400 for (size_t r = 0; r < num_receivers; ++r ) { in unlimited_concurrency() local
401 tbb::flow::remove_edge( exe_node, *receivers[r] ); in unlimited_concurrency()