Lines Matching refs:tbb
41 using namespace tbb::flow; in test_deduction_guides()
73 oneapi::tbb::flow::graph g;
74 oneapi::tbb::flow::continue_node<int> node0( g,
75 [](oneapi::tbb::flow::continue_msg) { return 1; } ); in __anon798ebb9d0102()
77 oneapi::tbb::flow::join_node<std::tuple<int>> node1(g);
81 oneapi::tbb::flow::make_edge(node0, oneapi::tbb::flow::input_port<0>(node1));
82 oneapi::tbb::flow::make_edge(node1, node2);
83 oneapi::tbb::flow::join_node<std::tuple<int>> node_copy(node1);
85 oneapi::tbb::flow::make_edge(node_copy, node3);
87 oneapi::tbb::flow::input_port<0>(node_copy).try_put(1);
93 node0.try_put(oneapi::tbb::flow::continue_msg());
98 oneapi::tbb::flow::remove_edge(node1, node2);
99 oneapi::tbb::flow::input_port<0>(node1).try_put(1);
101 oneapi::tbb::flow::join_node<std::tuple<int>> node_copy2(node1);
102 oneapi::tbb::flow::make_edge(node_copy2, node3);
103 oneapi::tbb::flow::input_port<0>(node_copy2).try_put(2);
111 CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::graph_node,
112 oneapi::tbb::flow::join_node<my_input_tuple>>::value),
114 CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::sender<my_input_tuple>,
115 oneapi::tbb::flow::join_node<my_input_tuple>>::value),
122 oneapi::tbb::flow::graph g;
123 oneapi::tbb::flow::function_node<int, int>
124 f1( g, oneapi::tbb::flow::unlimited, [](const int &i) { return i; } ); in __anon798ebb9d0202()
125 oneapi::tbb::flow::function_node<float, float>
126 f2( g, oneapi::tbb::flow::unlimited, [](const float &f) { return f; } ); in __anon798ebb9d0302()
127 oneapi::tbb::flow::continue_node<input_msg> c1( g,
128 [](oneapi::tbb::flow::continue_msg) { return input_msg(1); } ); in __anon798ebb9d0402()
130 oneapi::tbb::flow::join_node<my_input_tuple, oneapi::tbb::flow::queueing> testing_node(g);
135 oneapi::tbb::flow::function_node<my_input_tuple, my_input_tuple>
136 f3( g, oneapi::tbb::flow::unlimited,
145 oneapi::tbb::flow::make_edge(f1, oneapi::tbb::flow::input_port<0>(testing_node));
146 oneapi::tbb::flow::make_edge(f2, oneapi::tbb::flow::input_port<1>(testing_node));
147 oneapi::tbb::flow::make_edge(c1, oneapi::tbb::flow::input_port<2>(testing_node));
162 c1.try_put(oneapi::tbb::flow::continue_msg());
167 c1.try_put(oneapi::tbb::flow::continue_msg());
171 c1.try_put(oneapi::tbb::flow::continue_msg());
175 c1.try_put(oneapi::tbb::flow::continue_msg());
180 oneapi::tbb::flow::remove_edge(testing_node, f3);
184 c1.try_put(oneapi::tbb::flow::continue_msg());
197 conformance::test_with_reserving_join_node_class<oneapi::tbb::flow::write_once_node<int>>();
214 oneapi::tbb::flow::graph g;
215 auto body1 = [](const oneapi::tbb::flow::continue_msg &) -> int { return 1; }; in __anon798ebb9d0602()
218 oneapi::tbb::flow::join_node<std::tuple<oneapi::tbb::flow::continue_msg, float>,
219 oneapi::tbb::flow::key_matching<int, MyHash<int>>> testing_node(g, body1, body2);
221 oneapi::tbb::flow::input_port<0>(testing_node).try_put(oneapi::tbb::flow::continue_msg());
222 oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.3f);
226 std::tuple<oneapi::tbb::flow::continue_msg, float> tmp;
235 oneapi::tbb::flow::graph g;
236 …auto body1 = [](const oneapi::tbb::flow::continue_msg &) -> oneapi::tbb::flow::tag_value { return … in __anon798ebb9d0802()
237 …auto body2 = [](const float &val) -> oneapi::tbb::flow::tag_value { return static_cast<oneapi::tbb… in __anon798ebb9d0902()
239 oneapi::tbb::flow::join_node<std::tuple<oneapi::tbb::flow::continue_msg, float>,
240 oneapi::tbb::flow::tag_matching> testing_node(g, body1, body2);
242 oneapi::tbb::flow::input_port<0>(testing_node).try_put(oneapi::tbb::flow::continue_msg());
243 oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.3f);
247 std::tuple<oneapi::tbb::flow::continue_msg, float> tmp;
262 oneapi::tbb::flow::graph g;
263 oneapi::tbb::flow::join_node<std::tuple<int>> node(g);
265 CHECK_MESSAGE((std::is_same<oneapi::tbb::flow::join_node<std::tuple<int>>::input_ports_type&,
274 using namespace oneapi::tbb::flow; in test_invoke_basic()