| /oneTBB/test/conformance/ |
| H A D | conformance_async_node.cpp | 38 async_node<int, int> fn1(g, unlimited, fun); 39 async_node<int, int> fn2(g, unlimited, fun, oneapi::tbb::flow::node_priority_t(1)); 41 async_node<int, int, lightweight> lw_node1(g, serial, fun, lightweight()); 62 conformance::test_copy_ctor<oneapi::tbb::flow::async_node<int, int>>(); 74 conformance::test_inheritance<oneapi::tbb::flow::async_node<int, int>, int, int>(); 75 conformance::test_inheritance<oneapi::tbb::flow::async_node<void*, float>, void*, float>(); 91 conformance::test_concurrency<oneapi::tbb::flow::async_node<int, int>>(); 104 …conformance::test_rejecting<oneapi::tbb::flow::async_node<int, int, oneapi::tbb::flow::rejecting>>… 111 conformance::test_output_input_class<oneapi::tbb::flow::async_node<Body, Body>, Body>(); 117 using async_node_type = tbb::flow::async_node<int, int>; [all …]
|
| H A D | conformance_graph.cpp | 169 test_functional_nodes_rf_reset_protocol<async_node<int, int, queueing>>(); 256 test_nodes_with_body_rf_reset_bodies<async_node<int, int>, int>(serial);
|
| H A D | conformance_flowgraph.h | 42 typename oneapi::tbb::flow::async_node<Input, Output>::gateway_type;
|
| /oneTBB/test/tbb/ |
| H A D | test_async_node.cpp | 106 typedef tbb::flow::async_node< int, int, tbb::flow::queueing > counting_async_node_type; 316 typedef tbb::flow::async_node< input_type, output_type > async_node_type; 409 typedef tbb::flow::async_node< input_type, output_type > async_node_type; 512 typedef tbb::flow::async_node< input_type, output_type > async_node_type; 612 typedef tbb::flow::async_node<Input, Output> async_node_type; 718 using node_t = async_node<input_t, output_t>; in test_follows() 756 using node_t = async_node<input_t, output_t>; in test_precedes() 806 lightweight_testing::test<tbb::flow::async_node>(NUMBER_OF_MSGS); 858 tbb::flow::async_node<Input, Output>(graph, concurrency, body); 859 tbb::flow::async_node<Input, Output>(graph, concurrency, body, priority); [all …]
|
| H A D | test_flow_graph_priorities.cpp | 252 typedef async_node<data_type, data_type> async_node_type; 374 async_node_type async_node(g, unlimited, AsyncSubmissionBody(&activity)); in test() local 383 make_edge(starter_node, async_node); in test() 384 make_edge(async_node, async_restarter_node); in test() 385 make_edge(output_port<0>(async_restarter_node), async_node); in test()
|
| H A D | test_profiling.cpp | 83 tbb::flow::async_node<int, int> node(g, 1, async_body{});
|
| H A D | test_tbb_header.cpp | 208 TestTypeDefinitionPresence3(flow::async_node<int, int, tbb::flow::queueing_lightweight> ); in DefinitionPresence()
|
| /oneTBB/doc/main/reference/ |
| H A D | constructors_for_nodes.rst | 54 // async_node 55 async_node(follows(...), std::size_t concurrency, Body body); 56 async_node(precedes(...), std::size_t concurrency, Body body);
|
| /oneTBB/examples/graph/fgbzip2/ |
| H A D | README.md | 27 * `-async` - use graph `async_node`-based implementation.
|
| H A D | fgbzip2.cpp | 140 typedef oneapi::tbb::flow::async_node<oneapi::tbb::flow::continue_msg, BufferMsg> 142 typedef oneapi::tbb::flow::async_node<BufferMsg, oneapi::tbb::flow::continue_msg>
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | flow_graph.h | 2871 class async_node in __TBB_requires() 2891 receiver_gateway_impl(async_node* node): my_node(node) {} in __TBB_requires() 2898 async_node* n = my_node; in __TBB_requires() 2910 async_node* my_node; in __TBB_requires() 2914 async_node* self() { return this; } in __TBB_requires() 2937 __TBB_NOINLINE_SYM async_node( in __TBB_requires() 2954 : async_node(g, concurrency, body, Policy(), a_priority) {} in __TBB_requires() 2959 __TBB_NOINLINE_SYM async_node( in __TBB_requires() 2969 : async_node(nodes, concurrency, body, Policy(), a_priority) {} in __TBB_requires() 2972 …__TBB_NOINLINE_SYM async_node( const async_node &other ) : base_type(other), sender<Output>(), my_… in __TBB_requires() [all …]
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | Predefined_Node_Types.rst | 50 * - async_node (preview feature) 51 …an use a special interface to return a generic type and put it to all successors of async_node.
|
| H A D | std_invoke.rst | 215 * `async_node <https://oneapi-src.github.io/oneAPI-spec/spec/elements/oneTBB/source/flow_graph/asyn…
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _flow_graph_node_set_impl.h | 104 struct is_async_node<async_node<Args...>> : std::true_type {};
|
| /oneTBB/test/common/ |
| H A D | concepts_common.h | 622 using gateway_type = typename tbb::flow::async_node<Input, Output>::gateway_type;
|