94     put_body( tbb::flow::limiter_node<T> &lim, std::atomic<int> &accept_count ) :  in put_body()
95         my_lim(lim), my_accept_count(accept_count) {}  in put_body()
112     put_dec_body( tbb::flow::limiter_node<T> &lim, std::atomic<int> &accept_count ) :  in put_dec_body()
113         my_lim(lim), my_accept_count(accept_count) {}  in put_dec_body()
130 void test_puts_with_decrements( int num_threads, tbb::flow::limiter_node< T >& lim , tbb::flow::gra…  in test_puts_with_decrements()  argument
135     tbb::flow::make_edge( lim, r );  in test_puts_with_decrements()
136     tbb::flow::make_edge(s, lim.decrementer());  in test_puts_with_decrements()
139     utils::NativeParallelFor( num_threads, put_dec_body<T>(lim, accept_count) );  in test_puts_with_decrements()
158        tbb::flow::limiter_node< T > lim(g, i);  in test_parallel()  local
162        tbb::flow::make_edge( lim, r );  in test_parallel()
164        utils::NativeParallelFor( num_threads, put_body<T>(lim, accept_count) );  in test_parallel()
173        tbb::flow::limiter_node< T > lim(g, i);  in test_parallel()  local
174        test_puts_with_decrements(num_threads, lim, g);  in test_parallel()
175        tbb::flow::limiter_node< T > lim_copy( lim );  in test_parallel()
194        tbb::flow::limiter_node< T > lim(g, i);  in test_serial()  local
196        tbb::flow::make_edge( lim, r );  in test_serial()
198            bool msg = lim.try_put( T(j) );  in test_serial()
207        tbb::flow::limiter_node< T > lim(g, i);  in test_serial()  local
210        tbb::flow::make_edge( lim, r );  in test_serial()
211        tbb::flow::make_edge(s, lim.decrementer());  in test_serial()
213            bool msg = lim.try_put( T(j) );  in test_serial()
216                lim.decrementer().try_put( tbb::flow::continue_msg() );  in test_serial()
217                msg = lim.try_put( T(j) );  in test_serial()