| /oneTBB/test/conformance/ |
| H A D | conformance_async_node.cpp | 27 using input_msg = conformance::message</*default_ctor*/true, /*copy_ctor*/true, /*copy_assign*/fals… typedef
49 …conformance::test_buffering<oneapi::tbb::flow::async_node<input_msg, int>, input_msg>(oneapi::tbb:…
55 …conformance::test_priority<oneapi::tbb::flow::async_node<input_msg, int>, input_msg>(oneapi::tbb::…
68 …conformance::test_body_exec<oneapi::tbb::flow::async_node<input_msg, output_msg>, input_msg, outpu…
76 …conformance::test_inheritance<oneapi::tbb::flow::async_node<input_msg, output_msg>, input_msg, out…
83 …conformance::test_forwarding<oneapi::tbb::flow::async_node<input_msg, int>, input_msg, int>(1, one…
|
| H A D | conformance_function_node.cpp | 24 using input_msg = conformance::message</*default_ctor*/true, /*copy_ctor*/true, /*copy_assign*/fals… typedef
119 …conformance::test_body_exec<oneapi::tbb::flow::function_node<input_msg, output_msg>, input_msg, ou…
162 …formance::test_inheritance<oneapi::tbb::flow::function_node<input_msg, output_msg>, input_msg, out…
169 …test_buffering<oneapi::tbb::flow::function_node<input_msg, int, oneapi::tbb::flow::rejecting>, inp…
170 …:test_buffering<oneapi::tbb::flow::function_node<input_msg, int, oneapi::tbb::flow::queueing>, inp…
177 …conformance::test_forwarding<oneapi::tbb::flow::function_node<input_msg, int>, input_msg, int>(1, …
191 …conformance::test_priority<oneapi::tbb::flow::function_node<input_msg, int>, input_msg>(oneapi::tb…
|
| H A D | conformance_broadcast_node.cpp | 26 using input_msg = conformance::message</*default_ctor*/false, /*copy_ctor*/true/*enable for queue_n… typedef
32 conformance::test_forwarding<oneapi::tbb::flow::broadcast_node<input_msg>, input_msg>(1);
46 …onformance::test_inheritance<oneapi::tbb::flow::broadcast_node<input_msg>, input_msg, input_msg>();
|
| H A D | conformance_multifunction_node.cpp | 29 using input_msg = conformance::message</*default_ctor*/true, /*copy_ctor*/true, /*copy_assign*/fals… typedef
52 …nce::test_priority<oneapi::tbb::flow::multifunction_node<input_msg, std::tuple<int>>, input_msg>(o…
89 conformance::test_buffering<oneapi::tbb::flow::multifunction_node<input_msg, std::tuple<int>,
90 oneapi::tbb::flow::rejecting>, input_msg>(oneapi::tbb::flow::unlimited, fun);
97 …e::test_forwarding<oneapi::tbb::flow::multifunction_node<input_msg, std::tuple<int>>, input_msg, i…
110 …<oneapi::tbb::flow::multifunction_node<input_msg, std::tuple<output_msg>, oneapi::tbb::flow::rejec…
130 test_inheritance<input_msg, std::tuple<output_msg>>();
|
| H A D | conformance_indexer_node.cpp | 26 using input_msg = conformance::message</*default_ctor*/false, /*copy_ctor*/true, /*copy_assign*/fal… typedef
27 using my_indexer_type = oneapi::tbb::flow::indexer_node<int, float, input_msg>;
45 oneapi::tbb::flow::input_port<2>(testing_node).try_put(input_msg(1));
57 … CHECK_MESSAGE((value.cast_to<input_msg>() == 1), "Value passed is the actual one received.");
82 oneapi::tbb::flow::input_port<2>(testing_node).try_put(input_msg(1));
97 oneapi::tbb::flow::continue_node<input_msg> c1( g,
98 [](oneapi::tbb::flow::continue_msg) { return input_msg(5); } ); in __anon3412adbc0302()
112 CHECK_MESSAGE((v.is_a<input_msg>()), "Expected to float" ); in __anon3412adbc0402()
113 …CHECK_MESSAGE((oneapi::tbb::flow::cast_to<input_msg>(v) == 5), "Expected to receive input_msg(5)" … in __anon3412adbc0402()
162 …_type<my_output_type, oneapi::tbb::flow::tagged_msg<size_t, int, float, input_msg>>()), "indexer_n…
|
| H A D | conformance_limiter_node.cpp | 26 using input_msg = conformance::message</*default_ctor*/true, /*copy_ctor*/true/*enable for queue_no… typedef
34 oneapi::tbb::flow::limiter_node<input_msg> node1(g, limit);
35 conformance::test_push_receiver<input_msg> node2(g);
40 node1.try_put(input_msg(1));
50 conformance::test_forwarding<oneapi::tbb::flow::limiter_node<input_msg>, input_msg>(1, 5);
100 … conformance::test_inheritance<oneapi::tbb::flow::limiter_node<input_msg>, input_msg, input_msg>();
|
| H A D | conformance_split_node.cpp | 26 using input_msg = conformance::message</*default_ctor*/true, /*copy_ctor*/true, /*copy_assign*/true… typedef
27 using my_input_tuple = std::tuple<int, float, input_msg>;
39 oneapi::tbb::flow::limiter_node<input_msg> rejecter3(g,0);
45 my_input_tuple my_tuple(1, 1.5f, input_msg(2));
51 input_msg tmp3(-1);
69 conformance::test_push_receiver<input_msg> node4(g);
75 my_input_tuple my_tuple(1, 1.5f, input_msg(2));
|
| H A D | conformance_join_node.cpp | 27 using input_msg = conformance::message</*default_ctor*/true, /*copy_ctor*/true, /*copy_assign*/true… typedef
28 using my_input_tuple = std::tuple<int, float, input_msg>;
32 my_input_tuple tmp(0, 0.f, input_msg(0)); in get_values()
127 oneapi::tbb::flow::continue_node<input_msg> c1( g,
128 [](oneapi::tbb::flow::continue_msg) { return input_msg(1); } ); in __anon798ebb9d0402()
187 my_input_tuple tmp(0, 0.f, input_msg(0));
190 …CHECK_MESSAGE((tmp == my_input_tuple(1, 1.f, input_msg(1))), "If no one successor accepts the tupl…
|