Lines Matching refs:continue_msg
62 broadcast_node<continue_msg> b(g); in test_deduction_guides_common()
93 int continue_body_f(const tbb::flow::continue_msg&) { return 1; } in continue_body_f() argument
94 void continue_void_body_f(const tbb::flow::continue_msg&) {} in continue_void_body_f() argument
97 using tbb::flow::continue_msg; in test_deduction_guides()
98 test_deduction_guides_common<int>([](const continue_msg&)->int { return 1; } ); in test_deduction_guides() argument
99 test_deduction_guides_common<continue_msg>([](const continue_msg&) {}); in test_deduction_guides() argument
101 test_deduction_guides_common<int>([](const continue_msg&) mutable ->int { return 1; }); in test_deduction_guides() argument
102 test_deduction_guides_common<continue_msg>([](const continue_msg&) mutable {}); in test_deduction_guides() argument
105 test_deduction_guides_common<continue_msg>(continue_void_body_f); in test_deduction_guides()
114 …_exec<oneapi::tbb::flow::continue_node<output_msg>, oneapi::tbb::flow::continue_msg, output_msg>();
120 …e::test_inheritance<oneapi::tbb::flow::continue_node<int>, oneapi::tbb::flow::continue_msg, int>();
121 …est_inheritance<oneapi::tbb::flow::continue_node<void*>, oneapi::tbb::flow::continue_msg, void*>();
122 …tance<oneapi::tbb::flow::continue_node<output_msg>, oneapi::tbb::flow::continue_msg, output_msg>();
129 …ow::continue_node<int>, conformance::copy_counting_object<int, oneapi::tbb::flow::continue_msg>>();
144 …st_forwarding<oneapi::tbb::flow::continue_node<int>, oneapi::tbb::flow::continue_msg, int>(1, fun);
151 …mance::test_buffering<oneapi::tbb::flow::continue_node<int>, oneapi::tbb::flow::continue_msg>(fun);
181 conformance::dummy_functor<oneapi::tbb::flow::continue_msg> fun1;
182 …ing counting_body = conformance::copy_counting_object<output_msg, oneapi::tbb::flow::continue_msg>;
185 continue_node<oneapi::tbb::flow::continue_msg> node0(g, fun1);
201 node_copy.try_put(oneapi::tbb::flow::continue_msg());
206 node_copy.try_put(oneapi::tbb::flow::continue_msg());
211 node1.try_put(oneapi::tbb::flow::continue_msg());
212 node1.try_put(oneapi::tbb::flow::continue_msg());
213 node0.try_put(oneapi::tbb::flow::continue_msg());
226 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node1(g, fun);
227 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node2(g, 1, fun);
228 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node3(g, 1, fun);
237 node3.try_put(oneapi::tbb::flow::continue_msg());
238 node2.try_put(oneapi::tbb::flow::continue_msg());
239 node1.try_put(oneapi::tbb::flow::continue_msg());
248 …neapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg, int>, oneapi::tbb::flow::continue…
254 …g_object<int, oneapi::tbb::flow::continue_msg>>, conformance::copy_counting_object<int, oneapi::tb…
263 oneapi::tbb::flow::continue_node<oneapi::tbb::flow::continue_msg> node1(g, body);
264 node1.try_put(oneapi::tbb::flow::continue_msg());