| /oneTBB/test/conformance/ |
| H A D | conformance_continue_node.cpp | 186 continue_node<output_msg> node1(g, 2, fun2); variable
190 oneapi::tbb::flow::make_edge(node0, node1);
191 oneapi::tbb::flow::make_edge(node1, node2);
193 continue_node<output_msg> node_copy(node1);
211 node1.try_put(oneapi::tbb::flow::continue_msg());
212 node1.try_put(oneapi::tbb::flow::continue_msg());
231 oneapi::tbb::flow::make_edge(node1, node2);
233 oneapi::tbb::flow::make_edge(node1, node3);
234 oneapi::tbb::flow::make_edge(node1, node3);
235 oneapi::tbb::flow::remove_edge(node1, node3);
[all …]
|
| H A D | conformance_broadcast_node.cpp | 57 broadcast_node<int> node1(g);
61 oneapi::tbb::flow::make_edge(node0, node1);
62 oneapi::tbb::flow::make_edge(node1, node2);
64 broadcast_node<int> node_copy(node1);
|
| H A D | conformance_limiter_node.cpp | 34 oneapi::tbb::flow::limiter_node<input_msg> node1(g, limit);
37 oneapi::tbb::flow::make_edge(node1, node2);
40 node1.try_put(input_msg(1));
68 limiter_node<int> node1(g, 1); variable
72 oneapi::tbb::flow::make_edge(node0, node1);
73 oneapi::tbb::flow::make_edge(node1, node2);
75 limiter_node<int> node_copy(node1);
|
| H A D | conformance_input_node.cpp | 96 input_node<output_msg> node1(g, fun2);
100 oneapi::tbb::flow::make_edge(node1, node2);
102 input_node<output_msg> node_copy(node1);
115 node1.activate();
150 oneapi::tbb::flow::input_node<output_msg> node1(g, fun);
153 oneapi::tbb::flow::make_edge(node1, node2);
155 node1.activate();
|
| H A D | conformance_split_node.cpp | 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);
|
| H A D | conformance_indexer_node.cpp | 137 my_indexer_type node1(g);
141 oneapi::tbb::flow::make_edge(node0, oneapi::tbb::flow::input_port<0>(node1));
142 oneapi::tbb::flow::make_edge(node1, node2);
144 my_indexer_type node_copy(node1);
|
| H A D | conformance_join_node.cpp | 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);
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);
|
| H A D | conformance_flowgraph.h | 557 Node node1(g, unlimited, fun2); in test_copy_ctor()
561 oneapi::tbb::flow::make_edge(node0, node1); in test_copy_ctor()
562 oneapi::tbb::flow::make_edge(node1, suc_node1); in test_copy_ctor()
564 Node node_copy(node1); in test_copy_ctor()
721 Node node1(g, unlimited, fun); in test_output_input_class()
723 make_edge(node1, suc_node); in test_output_input_class()
726 node1.try_put(b1); in test_output_input_class()
740 Node node1(g, fun); in test_output_class()
742 make_edge(node1, suc_node); in test_output_class()
745 node1.activate(); in test_output_class()
[all …]
|
| /oneTBB/test/tbb/ |
| H A D | test_partitioner.h | 388 bool are_nodes_equal(TreeNode *node1, TreeNode *node2) const { in are_nodes_equal() argument
389 return node1->m_range_begin == node2->m_range_begin && in are_nodes_equal()
390 node1->m_range_end == node2->m_range_end; in are_nodes_equal()
417 bool compare_nodes(TreeNode* node1, TreeNode* node2) const { in compare_nodes() argument
418 if (node1 == nullptr && node2 == nullptr) return true; in compare_nodes()
419 if (node1 == nullptr || node2 == nullptr) return false; in compare_nodes()
420 return are_nodes_equal(node1, node2) && compare_nodes(node1->m_left, node2->m_left) in compare_nodes()
421 && compare_nodes(node1->m_right, node2->m_right); in compare_nodes()
|
| H A D | test_continue_node.cpp | 278 node1(g, lightweight_policy_body(count1)); in test_lightweight_policy() local
282 tbb::flow::make_edge(node1, node2); in test_lightweight_policy()
285 node1.try_put(tbb::flow::continue_msg()); in test_lightweight_policy()
289 lightweight_policy_body body1 = tbb::flow::copy_body<lightweight_policy_body>(node1); in test_lightweight_policy()
|
| H A D | test_profiling.cpp | 135 tbb::flow::indexer_node<int> node1(g);
136 tbb::profiling::set_name(node1, "indexer_node");
|