Lines Matching refs:exe_node
50 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts()
102 tbb::flow::continue_node< OutputType > exe_node( g, body ); in continue_nodes() local
103 run_continue_nodes( p, g, exe_node); in continue_nodes()
104 exe_node.try_put(tbb::flow::continue_msg()); in continue_nodes()
105 tbb::flow::continue_node< OutputType > exe_node_copy( exe_node ); in continue_nodes()
138 tbb::flow::continue_node< OutputType > exe_node( g, cf ); in continue_nodes_with_copy() local
141 tbb::detail::d1::register_predecessor(exe_node, fake_sender); in continue_nodes_with_copy()
151 tbb::flow::make_edge( exe_node, *receivers[r] ); in continue_nodes_with_copy()
154 utils::NativeParallelFor( p, parallel_puts<tbb::flow::continue_msg>(exe_node) ); in continue_nodes_with_copy()
164 tbb::flow::remove_edge( exe_node, *receivers[r] ); in continue_nodes_with_copy()
169 … inc_functor<OutputType> body_copy = tbb::flow::copy_body< inc_functor<OutputType> >( exe_node ); in continue_nodes_with_copy()
176 body_copy = tbb::flow::copy_body< inc_functor<OutputType> >( exe_node ); in continue_nodes_with_copy()