Home
last modified time | relevance | path

Searched refs:exe_node (Results 1 – 3 of 3) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_function_node.cpp180 tbb::flow::make_edge( exe_node, *receivers[r] ); 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()
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()
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()
386 tbb::flow::make_edge( exe_node, *receivers[r] ); in unlimited_concurrency()
[all …]
H A Dtest_multifunction_node.cpp68 tbb::flow::multifunction_node< InputType, OutputTuple > exe_node( g, lc, body ); in buffered_levels() local
161 tbb::flow::multifunction_node< InputType, OutputTuple > exe_node( g, lc, cf ); in buffered_levels_with_copy() local
180 tbb::flow::make_edge( *senders.back(), exe_node ); 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()
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()
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()
[all …]
H A Dtest_continue_node.cpp50 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()
[all …]