82                 for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels()  local
83 …               tbb::flow::make_edge( tbb::flow::output_port<0>(exe_vec[node_idx]), *receivers[r] );  in buffered_levels()
99                     for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels()  local
100                         receivers[r]->initialize_map( N, num_senders );  in buffered_levels()
114                     for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels()  local
115                         receivers[r]->validate();  in buffered_levels()
118                 for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels()  local
119 …             tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_vec[node_idx]), *receivers[r] );  in buffered_levels()
123                 for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels()  local
125                     receivers[r]->validate();  in buffered_levels()
170             for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels_with_copy()  local
171                tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in buffered_levels_with_copy()
183                 for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels_with_copy()  local
184                     receivers[r]->initialize_map( N, num_senders );  in buffered_levels_with_copy()
195                 for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels_with_copy()  local
196                     receivers[r]->validate();  in buffered_levels_with_copy()
199             for (size_t r = 0; r < num_receivers; ++r ) {  in buffered_levels_with_copy()  local
200                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  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()
260             for (size_t r = 0; r < num_receivers; ++r ) {  in concurrency_levels()  local
261                 tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in concurrency_levels()
298                 for (size_t r = 0; r < num_receivers; ++r ) {  in concurrency_levels()  local
299                     size_t n = receivers[r]->my_count;  in concurrency_levels()
301                     receivers[r]->my_count = 0;  in concurrency_levels()
304             for (size_t r = 0; r < num_receivers; ++r ) {  in concurrency_levels()  local
305                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in concurrency_levels()
309             for (size_t r = 0; r < num_receivers; ++r ) {  in concurrency_levels()  local
310                 CHECK_MESSAGE( int(receivers[r]->my_count) == 0, "" );  in concurrency_levels()
372             for (size_t r = 0; r < num_receivers; ++r ) {  in unlimited_concurrency()  local
373                 tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in unlimited_concurrency()
382             for (size_t r = 0; r < num_receivers; ++r ) {  in unlimited_concurrency()  local
383                 size_t c = receivers[r]->my_count;  in unlimited_concurrency()
387             for (size_t r = 0; r < num_receivers; ++r ) {  in unlimited_concurrency()  local
388                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in unlimited_concurrency()