Home
last modified time | relevance | path

Searched refs:exe_vec (Results 1 – 2 of 2) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_function_node.cpp73 std::vector< tbb::flow::function_node< InputType, OutputType > > exe_vec(2, exe_node); in buffered_levels() local
76 for (size_t node_idx=0; node_idx<exe_vec.size(); ++node_idx) { in buffered_levels()
77 tbb::flow::make_edge(pass_thru_vec[node_idx], exe_vec[node_idx]); in buffered_levels()
81 for (size_t node_idx=0; node_idx<exe_vec.size(); ++node_idx) { in buffered_levels()
91 tbb::flow::make_edge( exe_vec[node_idx], *receivers[r] ); in buffered_levels()
127 tbb::flow::remove_edge( exe_vec[node_idx], *receivers[r] ); in buffered_levels()
129 CHECK( exe_vec[node_idx].try_put( InputType() ) == true ); in buffered_levels()
H A Dtest_multifunction_node.cpp71 std::vector< tbb::flow::multifunction_node< InputType, OutputTuple > > exe_vec(2, exe_node); in buffered_levels() local
74 for (size_t node_idx=0; node_idx<exe_vec.size(); ++node_idx) { in buffered_levels()
83 … tbb::flow::make_edge( tbb::flow::output_port<0>(exe_vec[node_idx]), *receivers[r] ); in buffered_levels()
95 tbb::flow::make_edge( *senders.back(), exe_vec[node_idx] ); in buffered_levels()
111 …CHECK_MESSAGE( senders[s]->my_receiver.load(std::memory_order_relaxed) == &exe_vec[node_idx], "" ); in buffered_levels()
119 … tbb::flow::remove_edge( tbb::flow::output_port<0>(exe_vec[node_idx]), *receivers[r] ); in buffered_levels()
121 CHECK_MESSAGE( exe_vec[node_idx].try_put( InputType() ) == true, "" ); in buffered_levels()