Lines Matching refs:tbb

27 using my_indexer_type = oneapi::tbb::flow::indexer_node<int, float, input_msg>;
33     oneapi::tbb::flow::graph g;
40         oneapi::tbb::flow::make_edge(testing_node, *receiver_nodes.back());
43     oneapi::tbb::flow::input_port<0>(testing_node).try_put(6);
44     oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.5);
45     oneapi::tbb::flow::input_port<2>(testing_node).try_put(input_msg(1));
67 …CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::graph_node, my_indexer_type>::value), "indexer_n…
73     oneapi::tbb::flow::graph g;
77     oneapi::tbb::flow::limiter_node<my_output_type> rejecter(g,0);
78     oneapi::tbb::flow::make_edge(testing_node, rejecter);
80     oneapi::tbb::flow::input_port<0>(testing_node).try_put(6);
81     oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.5);
82     oneapi::tbb::flow::input_port<2>(testing_node).try_put(input_msg(1));
92     oneapi::tbb::flow::graph g;
93     oneapi::tbb::flow::function_node<int, int> f1( g, oneapi::tbb::flow::unlimited,
95     oneapi::tbb::flow::function_node<float, float> f2( g, oneapi::tbb::flow::unlimited,
97     oneapi::tbb::flow::continue_node<input_msg> c1( g,
98                                 [](oneapi::tbb::flow::continue_msg) { return input_msg(5); } );  in __anon3412adbc0302()
102     oneapi::tbb::flow::function_node<my_output_type>
103         f3( g, oneapi::tbb::flow::unlimited,
107 …                CHECK_MESSAGE((oneapi::tbb::flow::cast_to<int>(v) == 6), "Expected to receive 6" );  in __anon3412adbc0402()
110 …          CHECK_MESSAGE((oneapi::tbb::flow::cast_to<float>(v) == 1.5), "Expected to receive 1.5" );  in __anon3412adbc0402()
113 …CHECK_MESSAGE((oneapi::tbb::flow::cast_to<input_msg>(v) == 5), "Expected to receive input_msg(5)" …  in __anon3412adbc0402()
118     oneapi::tbb::flow::make_edge(f1, oneapi::tbb::flow::input_port<0>(testing_node));
119     oneapi::tbb::flow::make_edge(f2, oneapi::tbb::flow::input_port<1>(testing_node));
120     oneapi::tbb::flow::make_edge(c1, oneapi::tbb::flow::input_port<2>(testing_node));
121     oneapi::tbb::flow::make_edge(testing_node, f3);
125     c1.try_put(oneapi::tbb::flow::continue_msg());
133     oneapi::tbb::flow::graph g;
134     oneapi::tbb::flow::continue_node<int> node0( g,
135                                 [](oneapi::tbb::flow::continue_msg) { return 1; } );  in __anon3412adbc0502()
141     oneapi::tbb::flow::make_edge(node0, oneapi::tbb::flow::input_port<0>(node1));
142     oneapi::tbb::flow::make_edge(node1, node2);
146     oneapi::tbb::flow::make_edge(node_copy, node3);
148     oneapi::tbb::flow::input_port<0>(node_copy).try_put(1);
153     node0.try_put(oneapi::tbb::flow::continue_msg());
162 …CHECK_MESSAGE((conformance::check_output_type<my_output_type, oneapi::tbb::flow::tagged_msg<size_t…