Lines Matching refs:tbb

28 using my_split_type = oneapi::tbb::flow::split_node<my_input_tuple>;
33 oneapi::tbb::flow::graph g;
37 oneapi::tbb::flow::limiter_node<int> rejecter1(g,0);
38 oneapi::tbb::flow::limiter_node<float> rejecter2(g,0);
39 oneapi::tbb::flow::limiter_node<input_msg> rejecter3(g,0);
41 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<0>(testing_node), rejecter1);
42 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<1>(testing_node), rejecter2);
43 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<2>(testing_node), rejecter3);
52 CHECK_MESSAGE((oneapi::tbb::flow::output_port<0>(testing_node).try_get(tmp1) == false
54 CHECK_MESSAGE((oneapi::tbb::flow::output_port<1>(testing_node).try_get(tmp2) == false
56 CHECK_MESSAGE((oneapi::tbb::flow::output_port<2>(testing_node).try_get(tmp3) == false
63 using namespace oneapi::tbb::flow;
64 oneapi::tbb::flow::graph g;
71 oneapi::tbb::flow::make_edge(output_port<0>(testing_node), node2);
72 oneapi::tbb::flow::make_edge(output_port<1>(testing_node), node3);
73 oneapi::tbb::flow::make_edge(output_port<2>(testing_node), node4);
95 oneapi::tbb::flow::graph g;
96 oneapi::tbb::flow::continue_node<std::tuple<int>> node0( g,
97 … [](oneapi::tbb::flow::continue_msg) { return std::tuple<int>(1); } ); in __anoned94b1790102()
99 oneapi::tbb::flow::split_node<std::tuple<int>> node1(g);
103 oneapi::tbb::flow::make_edge(node0, node1);
104 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<0>(node1), node2);
106 oneapi::tbb::flow::split_node<std::tuple<int>> node_copy(node1);
108 oneapi::tbb::flow::make_edge(oneapi::tbb::flow::output_port<0>(node_copy), node3);
115 node0.try_put(oneapi::tbb::flow::continue_msg());
124 …CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::graph_node, my_split_type>::value), "split_node …
125 …CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::receiver<my_input_tuple>, my_split_type>::value)…
131 oneapi::tbb::flow::graph g;