Home
last modified time | relevance | path

Searched refs:testing_node (Results 1 – 12 of 12) sorted by relevance

/oneTBB/test/conformance/
H A Dconformance_overwrite_node.cpp34 oneapi::tbb::flow::overwrite_node<int> testing_node(g);
37 testing_node.try_put(1);
40 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message");
43 testing_node.try_put(2);
46 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message");
80 oneapi::tbb::flow::overwrite_node<int> testing_node(g);
83 CHECK_MESSAGE((!testing_node.is_valid()), "Constructed node has invalid internal buffer item");
91 oneapi::tbb::flow::overwrite_node<int> testing_node(g);
95 testing_node.try_put(1);
97 CHECK_MESSAGE((testing_node.is_valid()), "Buffer must be valid after try_put call");
[all …]
H A Dconformance_write_once_node.cpp59 oneapi::tbb::flow::overwrite_node<int> testing_node(g);
62 CHECK_MESSAGE((!testing_node.is_valid()), "Constructed node has invalid internal buffer item");
63 …CHECK_MESSAGE((!testing_node.try_get(tmp)), "Gets from the node are non-destructive, but the first…
70 oneapi::tbb::flow::write_once_node<int> testing_node(g);
72 CHECK_MESSAGE((!testing_node.is_valid()), "Constructed node has invalid internal buffer item");
74 testing_node.try_put(1);
76 CHECK_MESSAGE((testing_node.is_valid()), "Buffer must be valid after try_put call");
78 testing_node.clear();
80 …CHECK_MESSAGE((!testing_node.is_valid()), "call `clear` invalidates the value held in the buffer."…
H A Dconformance_indexer_node.cpp35 my_indexer_type testing_node(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));
75 my_indexer_type testing_node(g);
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);
100 my_indexer_type testing_node(g);
[all …]
H A Dconformance_split_node.cpp35 my_split_type testing_node(g);
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);
46 testing_node.try_put(my_tuple);
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
66 my_split_type testing_node(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);
[all …]
H A Dconformance_priority_queue_node.cpp60 oneapi::tbb::flow::priority_queue_node<int, std::greater<int>> testing_node(g);
62 testing_node.try_put(2);
63 testing_node.try_put(3);
64 testing_node.try_put(1);
68 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed");
70 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed");
72 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed");
H A Dconformance_queue_node.cpp59 oneapi::tbb::flow::queue_node<int> testing_node(g);
64 …CHECK_MESSAGE((!testing_node.try_get(tmp1) && tmp1 == -1), "`try_get` must returns false if there …
66 testing_node.try_put(1);
67 testing_node.try_put(2);
70 testing_node.try_get(tmp1);
73 testing_node.try_get(tmp2);
H A Dconformance_buffer_node.cpp58 oneapi::tbb::flow::buffer_node<int> testing_node(g);
63 …CHECK_MESSAGE((!testing_node.try_get(tmp1) && tmp1 == -1), "`try_get` must returns false if there …
65 testing_node.try_put(1);
66 testing_node.try_put(2);
69 testing_node.try_get(tmp1);
72 testing_node.try_get(tmp2);
H A Dconformance_graph.cpp89 Node testing_node(g, node_body...); in test_buffering_nodes_rf_reset_protocol() local
95 testing_node.try_put(1); in test_buffering_nodes_rf_reset_protocol()
109 Node testing_node(g, node_args..., counting_body); in test_nodes_with_body_rf_reset_bodies() local
111 testing_node.try_put(InputType()); in test_nodes_with_body_rf_reset_bodies()
117 testing_node.try_put(InputType()); in test_nodes_with_body_rf_reset_bodies()
133 testing_node.try_put(1); in test_limiter_node_rf_reset_protocol()
141 testing_node.try_put(1); in test_limiter_node_rf_reset_protocol()
260 input_node<int> testing_node(g,counting_body);
263 make_edge(testing_node, q_node);
265 testing_node.activate();
[all …]
H A Dconformance_flowgraph.h439 Node testing_node(g, node_args..., base_body); in test_copy_body_function()
441 Body b2 = copy_body<Body, Node>(testing_node); in test_copy_body_function()
450 Node testing_node(g, node_args...); in test_buffering()
478 Node testing_node(g, node_args...); in test_forwarding()
504 Node testing_node(g, node_args...); in test_forwarding_single_push()
511 testing_node.try_put(0); in test_forwarding_single_push()
519 testing_node.try_put(1); in test_forwarding_single_push()
589 Node testing_node(g, node_args...); in test_copy_ctor_for_buffering_nodes()
598 testing_node.try_put(1); in test_copy_ctor_for_buffering_nodes()
601 Node node_copy(testing_node); in test_copy_ctor_for_buffering_nodes()
[all …]
H A Dconformance_join_node.cpp145 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));
148 make_edge(testing_node, f3);
180 oneapi::tbb::flow::remove_edge(testing_node, f3);
219 oneapi::tbb::flow::key_matching<int, MyHash<int>>> testing_node(g, body1, body2);
222 oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.3f);
227 CHECK_MESSAGE((testing_node.try_get(tmp)), "Mapped keys should match.\
240 oneapi::tbb::flow::tag_matching> testing_node(g, body1, body2);
243 oneapi::tbb::flow::input_port<1>(testing_node).try_put(1.3f);
[all …]
H A Dconformance_input_node.cpp180 oneapi::tbb::flow::input_node<int> testing_node(g, counter);
184 make_edge(testing_node, sink);
185 testing_node.activate();
234 oneapi::tbb::flow::input_node<int> testing_node(g, fun1);
236 make_edge(testing_node, fnode);
237 testing_node.activate();
H A Dconformance_async_node.cpp123 async_node_type testing_node{ variable
135 testing_node.try_put(1);