68         tbb::flow::multifunction_node< InputType, OutputTuple > exe_node( g, lc, body );  in buffered_levels()  local
71         std::vector< tbb::flow::multifunction_node< InputType, OutputTuple > > exe_vec(2, exe_node);  in buffered_levels()
161         tbb::flow::multifunction_node< InputType, OutputTuple > exe_node( g, lc, cf );  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()
180                     tbb::flow::make_edge( *senders.back(), exe_node );  in buffered_levels_with_copy()
193 …         CHECK_MESSAGE( senders[s]->my_receiver.load(std::memory_order_relaxed) == &exe_node, "" );  in buffered_levels_with_copy()
200                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in buffered_levels_with_copy()
202             CHECK_MESSAGE( exe_node.try_put( InputType() ) == true, "" );  in buffered_levels_with_copy()
210         inc_functor body_copy = tbb::flow::copy_body<inc_functor>( exe_node );  in buffered_levels_with_copy()
251 …tbb::flow::multifunction_node< InputType, OutputTuple, tbb::flow::rejecting > exe_node( g, lc, bod…  in concurrency_levels()  local
261                 tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in concurrency_levels()
275                         CHECK_MESSAGE( exe_node.try_put( InputType() ) == true, "" );  in concurrency_levels()
278                     CHECK_MESSAGE( exe_node.try_put( InputType() ) == false, "" );  in concurrency_levels()
284                         exe_node.register_predecessor( *senders.back() );  in concurrency_levels()
295 …         CHECK_MESSAGE( senders[s]->my_receiver.load(std::memory_order_relaxed) == &exe_node, "" );  in concurrency_levels()
305                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in concurrency_levels()
307             CHECK_MESSAGE( exe_node.try_put( InputType() ) == true, "" );  in concurrency_levels()
337     parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {}  in parallel_puts()
362 …tbb::flow::multifunction_node< InputType, OutputTuple, tbb::flow::rejecting > exe_node( g, tbb::fl…  in unlimited_concurrency()  local
373                 tbb::flow::make_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in unlimited_concurrency()
376             utils::NativeParallelFor( p, parallel_puts<InputType>(exe_node) );  in unlimited_concurrency()
388                 tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_node), *receivers[r] );  in unlimited_concurrency()