162     void operator()( InputType, async_ports_t<InputType, OutputType>& g ) {  in operator()
163         g.try_put(operator()(OutputType(0)));  in operator()
211     void operator()( InputType, async_ports_t<InputType, OutputType>& g ) {  in operator()
213         g.try_put(return_value);  in operator()
237     void operator()( InputType, async_ports_t<InputType, OutputType>& g ) {  in operator()
238         g.try_put(OutputType(0));  in operator()
280     void operator()( InputType argument, async_ports_t<InputType>& g ) {  in operator()
282         g.try_put(argument);  in operator()
326     void operator()( const int& argument , async_ports_t<int>& g ) {  in operator()
331         g.try_put(argument);  in operator()
367     void operator()( InputType , async_ports_t<InputType, OutputType>& g) {  in operator()
368         g.try_put(OutputType(1));  in operator()
408     void operator()( OutputType argument, async_ports_t<OutputType>& g ) {  in operator()
409         g.try_put(argument);  in operator()
415     oneapi::tbb::flow::graph g;  in test_body_exec()  local
419     Node testing_node(g, node_args..., counting_body);  in test_body_exec()
426     g.wait_for_all();  in test_body_exec()
437     graph g;  in test_copy_body_function()  local
439     Node testing_node(g, node_args..., base_body);  in test_copy_body_function()
448     oneapi::tbb::flow::graph g;  in test_buffering()  local
450     Node testing_node(g, node_args...);  in test_buffering()
451     oneapi::tbb::flow::limiter_node<int> rejecter(g, 0);  in test_buffering()
457     g.wait_for_all();  in test_buffering()
476     oneapi::tbb::flow::graph g;  in test_forwarding()  local
478     Node testing_node(g, node_args...);  in test_forwarding()
482         receiver_nodes.emplace_back(new test_push_receiver<OutputType>(g));  in test_forwarding()
492     g.wait_for_all();  in test_forwarding()
502     oneapi::tbb::flow::graph g;  in test_forwarding_single_push()  local
504     Node testing_node(g, node_args...);  in test_forwarding_single_push()
505     test_push_receiver<int> suc_node1(g);  in test_forwarding_single_push()
506     test_push_receiver<int> suc_node2(g);  in test_forwarding_single_push()
512     g.wait_for_all();  in test_forwarding_single_push()
520     g.wait_for_all();  in test_forwarding_single_push()
551     graph g;  in test_copy_ctor()  local
556     Node node0(g, unlimited, fun1);  in test_copy_ctor()
557     Node node1(g, unlimited, fun2);  in test_copy_ctor()
558     test_push_receiver<int> suc_node1(g);  in test_copy_ctor()
559     test_push_receiver<int> suc_node2(g);  in test_copy_ctor()
573     g.wait_for_all();  in test_copy_ctor()
578     g.wait_for_all();  in test_copy_ctor()
585     oneapi::tbb::flow::graph g;  in test_copy_ctor_for_buffering_nodes()  local
589     Node testing_node(g, node_args...);  in test_copy_ctor_for_buffering_nodes()
590     oneapi::tbb::flow::continue_node<int> pred_node(g, fun);  in test_copy_ctor_for_buffering_nodes()
591     test_push_receiver<int> suc_node1(g);  in test_copy_ctor_for_buffering_nodes()
592     test_push_receiver<int> suc_node2(g);  in test_copy_ctor_for_buffering_nodes()
612     g.wait_for_all();  in test_copy_ctor_for_buffering_nodes()
622     g.wait_for_all();  in test_copy_ctor_for_buffering_nodes()
631     oneapi::tbb::flow::graph g;  in test_priority()  local
632     oneapi::tbb::flow::continue_node<InputType> source(g, dummy_functor<InputType>());  in test_priority()
639     Node high(g, node_args..., high_functor, oneapi::tbb::flow::node_priority_t(1));  in test_priority()
640     Node low(g, node_args..., low_functor);  in test_priority()
644         g.reset(); // attach to this arena  in test_priority()
650         g.wait_for_all();  in test_priority()
678         oneapi::tbb::flow::graph g;  in test_concurrency()  local
680         Node fnode(g, num_threads, counter);  in test_concurrency()
682         test_push_receiver<int> suc_node(g);  in test_concurrency()
689         g.wait_for_all();  in test_concurrency()
695     oneapi::tbb::flow::graph g;  in test_rejecting()  local
698     Node fnode(g, oneapi::tbb::flow::serial, body);  in test_rejecting()
700     test_push_receiver<int> suc_node(g);  in test_rejecting()
710     g.wait_for_all();  in test_rejecting()
720     graph g;  in test_output_input_class()  local
721     Node node1(g, unlimited, fun);  in test_output_input_class()
722     test_push_receiver<CountingBody> suc_node(g);  in test_output_input_class()
727     g.wait_for_all();  in test_output_input_class()
739     graph g;  in test_output_class()  local
740     Node node1(g, fun);  in test_output_class()
741     test_push_receiver<Output> suc_node(g);  in test_output_class()
750     g.wait_for_all();  in test_output_class()
760     graph g;  in test_with_reserving_join_node_class()  local
763         g, serial,  in test_with_reserving_join_node_class()
769     Node testing_node(g); // for buffering once computed value  in test_with_reserving_join_node_class()
771     buffer_node<int> buffer_n(g);  in test_with_reserving_join_node_class()
772     join_node<std::tuple<int, int>, reserving> join_n(g);  in test_with_reserving_join_node_class()
777         g, unlimited,  in test_with_reserving_join_node_class()
808     g.wait_for_all();  in test_with_reserving_join_node_class()