69    tbb::flow::function_node< InputType, OutputType > exe_node( g, lc, body );  in buffered_levels()  local
73    std::vector< tbb::flow::function_node< InputType, OutputType > > exe_vec(2, exe_node);  in buffered_levels()
170         tbb::flow::function_node< InputType, OutputType > exe_node( g, lc, cf );  in buffered_levels_with_copy()  local
180                 tbb::flow::make_edge( exe_node, *receivers[r] );  in buffered_levels_with_copy()
189                     tbb::flow::make_edge( *senders.back(), exe_node );  in buffered_levels_with_copy()
202                     CHECK( senders[s]->my_receiver.load(std::memory_order_relaxed) == &exe_node );  in buffered_levels_with_copy()
209                 tbb::flow::remove_edge( exe_node, *receivers[r] );  in buffered_levels_with_copy()
211             CHECK( exe_node.try_put( InputType() ) == true );  in buffered_levels_with_copy()
219         inc_functor body_copy = tbb::flow::copy_body<inc_functor>( exe_node );  in buffered_levels_with_copy()
226         body_copy = tbb::flow::copy_body<inc_functor>( exe_node );  in buffered_levels_with_copy()
264         fnode_type exe_node( g, lc, body );  in concurrency_levels()  local
274                 tbb::flow::make_edge( exe_node, *receivers[r] );  in concurrency_levels()
289                         CHECK( exe_node.try_put( InputType() ) == true );  in concurrency_levels()
292                     CHECK( exe_node.try_put( InputType() ) == false );  in concurrency_levels()
298                         exe_node.register_predecessor( *senders.back() );  in concurrency_levels()
309                     CHECK( senders[s]->my_receiver.load(std::memory_order_relaxed) == &exe_node );  in concurrency_levels()
319                 tbb::flow::remove_edge( exe_node, *receivers[r] );  in concurrency_levels()
321             CHECK( exe_node.try_put( InputType() ) == true );  in concurrency_levels()
350     parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {}  in parallel_puts()
374 …tbb::flow::function_node< InputType, OutputType, tbb::flow::rejecting > exe_node( g, tbb::flow::un…  in unlimited_concurrency()  local
386                 tbb::flow::make_edge( exe_node, *receivers[r] );  in unlimited_concurrency()
389             utils::NativeParallelFor( p, parallel_puts<InputType>(exe_node) );  in unlimited_concurrency()
401                 tbb::flow::remove_edge( exe_node, *receivers[r] );  in unlimited_concurrency()