77                 std::vector< std::shared_ptr<harness_mapped_receiver<OutputType>> > receivers;  in buffered_levels()  local
79                     receivers.push_back( std::make_shared<harness_mapped_receiver<OutputType>>(g) );  in buffered_levels()
83 …               tbb::flow::make_edge( tbb::flow::output_port<0>(exe_vec[node_idx]), *receivers[r] );  in buffered_levels()
100                         receivers[r]->initialize_map( N, num_senders );  in buffered_levels()
115                         receivers[r]->validate();  in buffered_levels()
119 …             tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_vec[node_idx]), *receivers[r] );  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
167                 receivers.push_back( std::make_shared<harness_mapped_receiver<OutputType>>(g) );  in buffered_levels_with_copy()
171                tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in buffered_levels_with_copy()
184                     receivers[r]->initialize_map( N, num_senders );  in buffered_levels_with_copy()
196                     receivers[r]->validate();  in buffered_levels_with_copy()
200                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in buffered_levels_with_copy()
205                 receivers[r]->validate();  in buffered_levels_with_copy()
255             std::vector< std::shared_ptr<harness_counting_receiver<OutputType>> > receivers;  in concurrency_levels()  local
257                 receivers.push_back( std::make_shared<harness_counting_receiver<OutputType>>(g) );  in concurrency_levels()
261                 tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in concurrency_levels()
299                     size_t n = receivers[r]->my_count;  in concurrency_levels()
301                     receivers[r]->my_count = 0;  in concurrency_levels()
305                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in concurrency_levels()
310                 CHECK_MESSAGE( int(receivers[r]->my_count) == 0, "" );  in concurrency_levels()
365             std::vector< std::shared_ptr<harness_counting_receiver<OutputType>> > receivers;  in unlimited_concurrency()  local
367                 receivers.push_back( std::make_shared<harness_counting_receiver<OutputType>>(g) );  in unlimited_concurrency()
373                 tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in unlimited_concurrency()
383                 size_t c = receivers[r]->my_count;  in unlimited_concurrency()
388                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in unlimited_concurrency()