27     using namespace oneapi::tbb::flow;  in test_continue_node_rf_reset_protocol()
50     oneapi::tbb::flow::graph g;  in test_input_node_rf_reset_protocol()
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()
57     oneapi::tbb::flow::make_edge(node, rejecter);  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()
72 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…  in test_functional_nodes_rf_reset_protocol()
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()
88     oneapi::tbb::flow::graph g;  in test_buffering_nodes_rf_reset_protocol()
97     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_buffering_nodes_rf_reset_protocol()
107     oneapi::tbb::flow::graph g;  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()
124     oneapi::tbb::flow::graph g;  in test_limiter_node_rf_reset_protocol()
127     oneapi::tbb::flow::limiter_node<int> testing_node(g, limit);  in test_limiter_node_rf_reset_protocol()
130     oneapi::tbb::flow::make_edge(testing_node, suc_node);  in test_limiter_node_rf_reset_protocol()
138     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_limiter_node_rf_reset_protocol()
148     oneapi::tbb::flow::graph g;  in test_join_node_rf_reset_protocol()
150     oneapi::tbb::flow::join_node<std::tuple<int>, oneapi::tbb::flow::queueing> testing_node(g);  in test_join_node_rf_reset_protocol()
152     oneapi::tbb::flow::input_port<0>(testing_node).try_put(1);  in test_join_node_rf_reset_protocol()
155     g.reset(oneapi::tbb::flow::rf_reset_protocol);  in test_join_node_rf_reset_protocol()
164     using namespace oneapi::tbb::flow;
186     oneapi::tbb::flow::graph g;
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>());
209     oneapi::tbb::flow::make_edge(ct, successor);
210     oneapi::tbb::flow::make_edge(s, successor);
211     oneapi::tbb::flow::make_edge(src, successor);
212     oneapi::tbb::flow::make_edge(fxn, successor);
213     oneapi::tbb::flow::make_edge(m_fxn, successor);
214     oneapi::tbb::flow::make_edge(bc, successor);
215     oneapi::tbb::flow::make_edge(lim, successor);
216     oneapi::tbb::flow::make_edge(ind, successor3);
217     oneapi::tbb::flow::make_edge(j, successor2);
218     oneapi::tbb::flow::make_edge(bf, successor);
219     oneapi::tbb::flow::make_edge(pq, successor);
220     oneapi::tbb::flow::make_edge(wo, successor);
221     oneapi::tbb::flow::make_edge(ovw, successor);
222     oneapi::tbb::flow::make_edge(seq, successor);
225     g.reset(oneapi::tbb::flow::rf_clear_edges);
227     ct.try_put(oneapi::tbb::flow::continue_msg());
234     oneapi::tbb::flow::input_port<0>(ind).try_put(1);
235     oneapi::tbb::flow::input_port<0>(j).try_put(1);
252     using namespace oneapi::tbb::flow;
280     oneapi::tbb::flow::graph g;
294     oneapi::tbb::flow::function_node<int> f(g, oneapi::tbb::flow::serial, [&](int) {  in __anon8ef3c1da0202()