85            std::vector< std::shared_ptr<harness_mapped_receiver<OutputType>> > receivers;  in buffered_levels()  local
87                receivers.push_back( std::make_shared<harness_mapped_receiver<OutputType>>(g) );  in buffered_levels()
91                tbb::flow::make_edge( exe_vec[node_idx], *receivers[r] );  in buffered_levels()
108                    receivers[r]->initialize_map( N, num_senders );  in buffered_levels()
123                    receivers[r]->validate();  in buffered_levels()
127                tbb::flow::remove_edge( exe_vec[node_idx], *receivers[r] );  in buffered_levels()
133                receivers[r]->validate();  in buffered_levels()
174             std::vector< std::shared_ptr<harness_mapped_receiver<OutputType>> > receivers;  in buffered_levels_with_copy()  local
176                 receivers.push_back( std::make_shared<harness_mapped_receiver<OutputType>>(g) );  in buffered_levels_with_copy()
180                 tbb::flow::make_edge( exe_node, *receivers[r] );  in buffered_levels_with_copy()
193                     receivers[r]->initialize_map( N, num_senders );  in buffered_levels_with_copy()
205                     receivers[r]->validate();  in buffered_levels_with_copy()
209                 tbb::flow::remove_edge( exe_node, *receivers[r] );  in buffered_levels_with_copy()
214                 receivers[r]->validate();  in buffered_levels_with_copy()
268             std::vector< std::shared_ptr<harness_counting_receiver<OutputType>> > receivers;  in concurrency_levels()  local
270                 receivers.push_back( std::make_shared<harness_counting_receiver<OutputType>>(g) );  in concurrency_levels()
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()
319                 tbb::flow::remove_edge( exe_node, *receivers[r] );  in concurrency_levels()
324                 CHECK( int(receivers[r]->my_count) == 0 );  in concurrency_levels()
378             std::vector< std::shared_ptr<harness_counting_receiver<OutputType>> > receivers;  in unlimited_concurrency()  local
380                 receivers.push_back( std::make_shared<harness_counting_receiver<OutputType>>(g) );  in unlimited_concurrency()
386                 tbb::flow::make_edge( exe_node, *receivers[r] );  in unlimited_concurrency()
396                 size_t c = receivers[r]->my_count;  in unlimited_concurrency()
401                 tbb::flow::remove_edge( exe_node, *receivers[r] );  in unlimited_concurrency()