28     graph g;  in test_continue_node_rf_reset_protocol()  local
31     continue_node<int> source(g, 2, [&](const continue_msg&){ flag = true; return 1;});  in test_continue_node_rf_reset_protocol()
34     g.wait_for_all();  in test_continue_node_rf_reset_protocol()
38     g.reset(rf_reset_protocol);  in test_continue_node_rf_reset_protocol()
41     g.wait_for_all();  in test_continue_node_rf_reset_protocol()
45     g.wait_for_all();  in test_continue_node_rf_reset_protocol()
50     oneapi::tbb::flow::graph g;  in test_input_node_rf_reset_protocol()  local
54     oneapi::tbb::flow::input_node<int> node(g, fun);  in test_input_node_rf_reset_protocol()
55     oneapi::tbb::flow::limiter_node<int> rejecter(g, 0);  in test_input_node_rf_reset_protocol()
60     g.wait_for_all();  in test_input_node_rf_reset_protocol()
62     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_input_node_rf_reset_protocol()
70     oneapi::tbb::flow::graph g;  in test_functional_nodes_rf_reset_protocol()  local
75     Node f(g, oneapi::tbb::flow::serial, counting_body);  in test_functional_nodes_rf_reset_protocol()
80     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_functional_nodes_rf_reset_protocol()
82     g.wait_for_all();  in test_functional_nodes_rf_reset_protocol()
88     oneapi::tbb::flow::graph g;  in test_buffering_nodes_rf_reset_protocol()  local
89     Node testing_node(g, node_body...);  in test_buffering_nodes_rf_reset_protocol()
96     g.wait_for_all();  in test_buffering_nodes_rf_reset_protocol()
97     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_buffering_nodes_rf_reset_protocol()
102     g.wait_for_all();  in test_buffering_nodes_rf_reset_protocol()
107     oneapi::tbb::flow::graph g;  in test_nodes_with_body_rf_reset_bodies()  local
109     Node testing_node(g, node_args..., counting_body);  in test_nodes_with_body_rf_reset_bodies()
112     g.wait_for_all();  in test_nodes_with_body_rf_reset_bodies()
116     g.reset(oneapi::tbb::flow::rf_reset_bodies);  in test_nodes_with_body_rf_reset_bodies()
118     g.wait_for_all();  in test_nodes_with_body_rf_reset_bodies()
124     oneapi::tbb::flow::graph g;  in test_limiter_node_rf_reset_protocol()  local
127     oneapi::tbb::flow::limiter_node<int> testing_node(g, limit);  in test_limiter_node_rf_reset_protocol()
128     conformance::test_push_receiver<int> suc_node(g);  in test_limiter_node_rf_reset_protocol()
134     g.wait_for_all();  in test_limiter_node_rf_reset_protocol()
138     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_limiter_node_rf_reset_protocol()
142     g.wait_for_all();  in test_limiter_node_rf_reset_protocol()
148     oneapi::tbb::flow::graph g;  in test_join_node_rf_reset_protocol()  local
150     oneapi::tbb::flow::join_node<std::tuple<int>, oneapi::tbb::flow::queueing> testing_node(g);  in test_join_node_rf_reset_protocol()
154     g.wait_for_all();  in test_join_node_rf_reset_protocol()
155     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_join_node_rf_reset_protocol()
186     oneapi::tbb::flow::graph g;  variable
189     oneapi::tbb::flow::queue_node<int> successor(g);
190     oneapi::tbb::flow::queue_node<std::tuple<int>> successor2(g);
191     oneapi::tbb::flow::queue_node<oneapi::tbb::flow::indexer_node<int>::output_type> successor3(g);
194     oneapi::tbb::flow::continue_node<int> ct(g, body());
195     oneapi::tbb::flow::split_node< std::tuple<int> > s(g);
196     oneapi::tbb::flow::input_node<int> src(g, body());
197     oneapi::tbb::flow::function_node<int, int> fxn(g, oneapi::tbb::flow::unlimited, body());
198 …oneapi::tbb::flow::multifunction_node<int, std::tuple<int, int> > m_fxn(g, oneapi::tbb::flow::unli…
199     oneapi::tbb::flow::broadcast_node<int> bc(g);
200     oneapi::tbb::flow::limiter_node<int> lim(g, 2);
201     oneapi::tbb::flow::indexer_node<int> ind(g);
202     oneapi::tbb::flow::join_node< std::tuple< int >, oneapi::tbb::flow::queueing > j(g);
203     oneapi::tbb::flow::buffer_node<int> bf(g);
204     oneapi::tbb::flow::priority_queue_node<int> pq(g);
205     oneapi::tbb::flow::write_once_node<int> wo(g);
206     oneapi::tbb::flow::overwrite_node<int> ovw(g);
207     oneapi::tbb::flow::sequencer_node<int> seq(g, conformance::sequencer_functor<int>());
224     g.wait_for_all();
225     g.reset(oneapi::tbb::flow::rf_clear_edges);
242     g.wait_for_all();
258     graph g;  variable
260     input_node<int> testing_node(g,counting_body);
261     queue_node<int> q_node(g);
266     g.wait_for_all();
270     g.reset(rf_reset_bodies);
272     g.wait_for_all();
280     oneapi::tbb::flow::graph g;  variable
281     CHECK_MESSAGE(!g.is_cancelled(), "Freshly created graph should not be cancelled." );
283     g.cancel();
284 …CHECK_MESSAGE(!g.is_cancelled(), "Cancelled status should appear only after the wait_for_all() cal…
286     g.wait_for_all();
287     CHECK_MESSAGE(g.is_cancelled(), "Waiting should allow checking the cancellation status." );
289     g.reset();
290     CHECK_MESSAGE(!g.is_cancelled(), "Resetting must reset the cancellation status." );
294     oneapi::tbb::flow::function_node<int> f(g, oneapi::tbb::flow::serial, [&](int) {  in __anon8ef3c1da0202()
307         g.cancel();  in __anon8ef3c1da0302()
310     g.wait_for_all();
312     CHECK_MESSAGE(g.is_cancelled(), "Wait for all should not change the cancellation status." );