49    serial_receiver(tbb::flow::graph& g) : next_value(T(0)), my_graph(g) {}  in serial_receiver()
67     parallel_receiver(tbb::flow::graph& g) : my_graph(g) { my_count = 0; }  in parallel_receiver()
130 …t_puts_with_decrements( int num_threads, tbb::flow::limiter_node< T >& lim , tbb::flow::graph& g) {  in test_puts_with_decrements()  argument
131     parallel_receiver<T> r(g);  in test_puts_with_decrements()
157        tbb::flow::graph g;  in test_parallel()  local
158        tbb::flow::limiter_node< T > lim(g, i);  in test_parallel()
159        parallel_receiver<T> r(g);  in test_parallel()
165        g.wait_for_all();  in test_parallel()
172        tbb::flow::graph g;  in test_parallel()  local
173        tbb::flow::limiter_node< T > lim(g, i);  in test_parallel()
174        test_puts_with_decrements(num_threads, lim, g);  in test_parallel()
176        test_puts_with_decrements(num_threads, lim_copy, g);  in test_parallel()
193        tbb::flow::graph g;  in test_serial()  local
194        tbb::flow::limiter_node< T > lim(g, i);  in test_serial()
195        serial_receiver<T> r(g);  in test_serial()
201        g.wait_for_all();  in test_serial()
206        tbb::flow::graph g;  in test_serial()  local
207        tbb::flow::limiter_node< T > lim(g, i);  in test_serial()
208        serial_receiver<T> r(g);  in test_serial()
278     tbb::flow::graph g;  in test_multifunction_to_limiter()  local
285     mfnode_type mf_node(g, tbb::flow::unlimited, mfnode_body(_max, local_cnt));  in test_multifunction_to_limiter()
286     tbb::flow::function_node<int, int> fn_node(g, tbb::flow::unlimited, fn_body());  in test_multifunction_to_limiter()
287     tbb::flow::limiter_node<int> lim_node(g, _nparallel);  in test_multifunction_to_limiter()
294     g.wait_for_all();  in test_multifunction_to_limiter()
299     g.reset();  in test_multifunction_to_limiter()
306     g.wait_for_all();  in test_multifunction_to_limiter()
314     tbb::flow::graph g;  in test_continue_msg_reception()  local
315     tbb::flow::limiter_node<int> ln(g,2);  in test_continue_msg_reception()
316     tbb::flow::queue_node<int>   qn(g);  in test_continue_msg_reception()
320     g.wait_for_all();  in test_continue_msg_reception()
333     graph g;  in test_reserve_release_messages()  local
336     queue_node<int> input_queue(g);  in test_reserve_release_messages()
337     queue_node<int> output_queue(g);  in test_reserve_release_messages()
338     broadcast_node<int> broad(g);  in test_reserve_release_messages()
339     limiter_node<int, int> limit(g,2); //threshold of 2  in test_reserve_release_messages()
351     g.wait_for_all();  in test_reserve_release_messages()
357     g.wait_for_all();  in test_reserve_release_messages()
364     g.wait_for_all();  in test_reserve_release_messages()
371         g.wait_for_all();  in test_reserve_release_messages()
377     tbb::flow::graph g;  in test_decrementer()  local
378     tbb::flow::limiter_node<int, int> limit(g, threshold);  in test_decrementer()
379     tbb::flow::queue_node<int> queue(g);  in test_decrementer()
391     g.wait_for_all();  in test_decrementer()
397     g.wait_for_all();  in test_decrementer()
400     tbb::flow::limiter_node<int, long long> limit2(g, threshold2);  in test_decrementer()
415     g.wait_for_all();  in test_decrementer()
418     tbb::flow::limiter_node<int, long long> limit3(g, threshold3);  in test_decrementer()
433     g.wait_for_all();  in test_decrementer()
438     tbb::flow::graph g;  in test_try_put_without_successors()  local
440     tbb::flow::buffer_node<int> bn(g);  in test_try_put_without_successors()
441     tbb::flow::limiter_node<int> ln(g, try_put_num);  in test_try_put_without_successors()
450     tbb::flow::function_node<int, int> fn(g, tbb::flow::unlimited,  in test_try_put_without_successors()
459     g.wait_for_all();  in test_try_put_without_successors()
466     g.wait_for_all();  in test_try_put_without_successors()
492     graph g;  in test_deduction_guides()  local
493     broadcast_node<int> br(g);  in test_deduction_guides()
494     limiter_node<int> l0(g, 100);  in test_deduction_guides()