39     tbb::flow::graph * const my_graph;
42 …  decrement_wait( tbb::flow::graph &h, bool *done_flag ) : my_graph(&h), my_done_flag(done_flag) {}  in decrement_wait()
53     tbb::flow::graph h;  in test_wait_count()
73     tbb::flow::buffer_node<int> *b;
74     tbb::flow::graph& my_graph;
76 …my_int_buffer(tbb::flow::graph &g) : my_graph(g) { b = new tbb::flow::buffer_node<int>(my_graph); }  in my_int_buffer()
78         b = new tbb::flow::buffer_node<int>(my_graph);  in my_int_buffer()
88     tbb::flow::graph g;  in test_iterator()
97     for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) {  in test_iterator()
105     for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) {  in test_iterator()
113     for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) {  in test_iterator()
120     tbb::flow::graph& g;
124     AddRemoveBody(int nthr, utils::SpinBarrier &barrier_, tbb::flow::graph& _g) :  in AddRemoveBody()
134             for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) {  in operator ()()
143         for (tbb::flow::graph::iterator it = g.begin(); it != g.end(); ++it) {  in operator ()()
152     tbb::flow::graph g;  in test_parallel()
162 inline void check_arena(tbb::task_arena* midway_arena) {  in check_arena()
164     CHECK_MESSAGE(tbb::this_task_arena::max_concurrency() == 1, "");  in check_arena()
168     tbb::task_arena* midway_arena;
170     run_functor(tbb::task_arena* a) : midway_arena(a), return_value(1) {}  in run_functor()
179     tbb::task_arena* midway_arena;
180     function_body(tbb::task_arena* a) : midway_arena(a) {}  in function_body()
181     tbb::flow::continue_msg operator()(const T& /*arg*/) {  in operator ()()
183         return tbb::flow::continue_msg();  in operator ()()
187 typedef tbb::flow::multifunction_node< int, std::tuple< int > > mf_node;
190     tbb::task_arena* midway_arena;
191     multifunction_body(tbb::task_arena* a) : midway_arena(a) {}  in multifunction_body()
198     tbb::task_arena* midway_arena;
200     input_body(tbb::task_arena* a) : midway_arena(a), counter(0) {}  in input_body()
201     int operator()(tbb::flow_control &fc) {  in operator ()()
211     tbb::task_arena* midway_arena;
212     tbb::flow::graph& my_graph;
214     nodes_test_functor(tbb::task_arena* a, tbb::flow::graph& g) : midway_arena(a), my_graph(g) {}  in nodes_test_functor()
219 …tbb::flow::continue_node< tbb::flow::continue_msg > c_n(my_graph, function_body<tbb::flow::continu…  in operator ()()
220 …tbb::flow::function_node< int > f_n(my_graph, tbb::flow::unlimited, function_body<int>(midway_aren…  in operator ()()
221         tbb::flow::input_node< int > s_n(my_graph, input_body(midway_arena));  in operator ()()
224         mf_node m_n(my_graph, tbb::flow::unlimited, multifunction_body(midway_arena));  in operator ()()
227         tbb::flow::function_node< std::tuple< int, int > > join_f_n(  in operator ()()
228             my_graph, tbb::flow::unlimited, function_body< std::tuple< int, int > >(midway_arena)  in operator ()()
230         tbb::flow::join_node< std::tuple< int, int > > j_n(my_graph);  in operator ()()
234         tbb::flow::function_node< int > split_f_n1 = f_n;  in operator ()()
235         tbb::flow::function_node< int > split_f_n2 = f_n;  in operator ()()
236         tbb::flow::split_node< std::tuple< int, int > > sp_n(my_graph);  in operator ()()
237         make_edge(tbb::flow::output_port<0>(sp_n), split_f_n1);  in operator ()()
238         make_edge(tbb::flow::output_port<1>(sp_n), split_f_n2);  in operator ()()
241         tbb::flow::function_node< int > ow_f_n = f_n;  in operator ()()
242         tbb::flow::overwrite_node< int > ow_n(my_graph);  in operator ()()
246         tbb::flow::function_node< int > w_f_n = f_n;  in operator ()()
247         tbb::flow::write_once_node< int > w_n(my_graph);  in operator ()()
251         tbb::flow::function_node< int > buf_f_n = f_n;  in operator ()()
252         tbb::flow::buffer_node< int > buf_n(my_graph);  in operator ()()
256         tbb::flow::function_node< int > l_f_n = f_n;  in operator ()()
257         tbb::flow::limiter_node< int > l_n(my_graph, 1);  in operator ()()
261         c_n.try_put( tbb::flow::continue_msg() );  in operator ()()
266         tbb::flow::input_port<0>(j_n).try_put(1);  in operator ()()
267         tbb::flow::input_port<1>(j_n).try_put(1);  in operator ()()
286     tbb::task_arena arena(1);  in test_graph_arena()
289             tbb::flow::graph g;  in test_graph_arena()
290             tbb::task_arena midway_arena;  in test_graph_arena()
302         tbb::task_arena arena(p);
315         tbb::task_arena arena(p);
328         tbb::task_arena arena(p);
346     using namespace tbb::flow;