| /oneTBB/test/tbb/ |
| H A D | test_function_node.cpp | 70 …tbb::flow::function_node<InputType, InputType> pass_thru( g, tbb::flow::unlimited, pass_through<In… in buffered_levels() 74 std::vector< tbb::flow::function_node< InputType, InputType > > pass_thru_vec(2, pass_thru); in buffered_levels() 159 template< typename InputType, typename OutputType > 234 …buffered_levels<InputType,OutputType>( c, []( InputType i ) -> OutputType { return harness_graph_e… in run_buffered_levels() 235 … buffered_levels<InputType,OutputType>( c, &harness_graph_executor<InputType, OutputType>::func ); in run_buffered_levels() 236 …buffered_levels<InputType,OutputType>( c, typename harness_graph_executor<InputType, OutputType>::… in run_buffered_levels() 333 …concurrency_levels<InputType,OutputType>( c, []( InputType i ) -> OutputType { return harness_grap… in run_concurrency_levels() 345 template< typename InputType > 410 …unlimited_concurrency<InputType,OutputType>( []( InputType i ) -> OutputType { return harness_grap… in run_unlimited_concurrency() 411 …unlimited_concurrency<InputType,OutputType>( &harness_graph_executor<InputType, OutputType>::func … in run_unlimited_concurrency() [all …]
|
| H A D | test_multifunction_node.cpp | 150 template< typename InputType, typename OutputTuple > 221 …buffered_levels<InputType,OutputTuple>( c, []( InputType i, output_ports_type &p ) { harness_graph… in run_buffered_levels() 222 …buffered_levels<InputType,OutputTuple>( c, &harness_graph_multifunction_executor<InputType, Output… in run_buffered_levels() 223 …buffered_levels<InputType,OutputTuple>( c, typename harness_graph_multifunction_executor<InputType… in run_buffered_levels() 319 …concurrency_levels<InputType,OutputTuple>( c, []( InputType i, output_ports_type &p ) { harness_gr… in run_concurrency_levels() 332 template< typename InputType > 398 …limited_concurrency<InputType,OutputTuple>( []( InputType i, output_ports_type &p ) { harness_grap… in run_unlimited_concurrency() 399 …unlimited_concurrency<InputType,OutputTuple>( &harness_graph_multifunction_executor<InputType, Out… in run_unlimited_concurrency() 403 template<typename InputType, typename OutputTuple> 435 for(InputType i = 0; i < N; ++i) { in run_multiport_test() [all …]
|
| H A D | test_eh_flow_graph.cpp | 231 OutputType operator()(const InputType &/*p_in*/) { in operator ()() argument 596 typedef tbb::flow::input_node<Item12> InputType; in run_function_node_test() typedef 605 /*InputNodeType*/ InputType, in run_function_node_test() 702 typedef tbb::flow::input_node<Item12> InputType; in run_multifunction_node_test() typedef 712 /*InputNodeType*/ InputType, in run_multifunction_node_test() 879 /*InputNodeType*/ InputType, in run_continue_node_test() 1002 /*class InputNodeType*/ InputType, in run_buffer_queue_and_overwrite_node_test() 1010 /*class InputNodeType*/ InputType, in run_buffer_queue_and_overwrite_node_test() 1669 class InputType, 1690 InputType input(g, InputBodyType(input_count)); in run_one_split_node_test() [all …]
|
| H A D | test_continue_node.cpp | 45 template< typename InputType > 48 tbb::flow::receiver< InputType > * const my_exe_node; 50 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts() 56 CHECK_MESSAGE( my_exe_node->try_put( InputType() ) == true, "" ); in operator ()()
|
| /oneTBB/test/conformance/ |
| H A D | conformance_flowgraph.h | 162 void operator()( InputType, async_ports_t<InputType, OutputType>& g ) { in operator() 167 void operator()( InputType, multifunc_ports_t<InputType, OutputType>& op ) { in operator() 196 void operator()( InputType, multifunc_ports_t<InputType, OutputType>& op ) { in operator() 211 void operator()( InputType, async_ports_t<InputType, OutputType>& g ) { in operator() 232 void operator()( InputType, multifunc_ports_t<InputType, OutputType>& op ) { in operator() 237 void operator()( InputType, async_ports_t<InputType, OutputType>& g ) { in operator() 264 InputType operator()( InputType ) { in operator() 274 void operator()( InputType argument, multifunc_ports_t<InputType>& op ) { in operator() 280 void operator()( InputType argument, async_ports_t<InputType>& g ) { in operator() 363 void operator()( InputType, multifunc_ports_t<InputType,OutputType>& op ) { in operator() [all …]
|
| H A D | conformance_function_node.cpp | 82 template <typename InputType, typename OutputType1, typename OutputType2, 89 function_node<InputType, OutputType1> f1(g, unlimited, body1); in test_fn_invoke_basic() 96 f1.try_put(InputType{OutputType1{1}}); in test_fn_invoke_basic()
|
| H A D | conformance_graph.cpp | 105 template<typename Node, typename InputType, typename ...Args> 111 testing_node.try_put(InputType()); in test_nodes_with_body_rf_reset_bodies() 117 testing_node.try_put(InputType()); in test_nodes_with_body_rf_reset_bodies()
|
| /oneTBB/test/common/ |
| H A D | graph_utils.h | 43 template<typename InputType, typename OutputType> 50 template<typename InputType> 51 struct converter<InputType,tbb::flow::continue_msg> { 83 template< typename InputType, typename OutputType > 85 static OutputType construct( InputType v ) { 97 template< typename InputType > 111 template<typename InputType, typename OutputSet> 134 static inline OutputType func( InputType v ) { 159 OutputType operator()( InputType i ) { 229 typename harness_graph_executor<InputType, OutputType>::function_ptr_type harness_graph_executor<In… [all …]
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | parallel_pipeline.h | 49 template<typename InputType, typename OutputType> 72 my_root( new(r1::allocate_memory(sizeof(filter_node_leaf<InputType, OutputType, Body>))) in filter() 73 … filter_node_leaf<InputType, OutputType, Body>(static_cast<unsigned int>(mode), body) ) { in filter() 89 template<typename InputType, typename OutputType, typename Body> 90 filter<InputType, OutputType> make_filter( filter_mode mode, const Body& body ) { in make_filter() 91 …return filter_node_ptr( new(r1::allocate_memory(sizeof(filter_node_leaf<InputType, OutputType, Bod… in make_filter() 92 … filter_node_leaf<InputType, OutputType, Body>(static_cast<unsigned int>(mode), body) ); in make_filter()
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _pipeline_filters.h | 124 template<typename Body, typename InputType, typename OutputType > 131 template<typename Body, typename InputType, typename OutputType > friend class concrete_filter; 226 template<typename InputType, typename OutputType, typename Body> 229 using input_helper = token_helper<InputType, use_allocator<InputType >::value>; 276 template<typename InputType, typename Body> 277 class concrete_filter<InputType, void, Body>: public base_filter { 279 using input_helper = token_helper<InputType, use_allocator<InputType >::value>; 432 template<typename InputType, typename OutputType, typename Body> 437 … new(r1::allocate_memory(sizeof(concrete_filter<InputType, OutputType, Body>))) concrete_filter<In…
|
| H A D | _flow_graph_trace_impl.h | 72 template<typename InputType> 73 void alias_input_port(void *node, receiver<InputType>* port, string_resource_index name_index) { in alias_input_port() 125 template<typename InputType> 126 void register_input_port(void *node, receiver<InputType>* port, string_resource_index name_index) {
|