36 void spin_try_get( tbb::flow::buffer_node<T> &b, T &value ) {  in spin_try_get()  argument
37     while ( b.try_get(value) != true ) {}  in spin_try_get()
50     parallel_puts( tbb::flow::buffer_node<T> &b ) : my_b(b) {}  in parallel_puts()
104     parallel_gets( tbb::flow::buffer_node<T> &b, touches<T> &t) : my_b(b), my_touches(t) {}  in parallel_gets()
122     parallel_put_get( tbb::flow::buffer_node<T> &b, touches<T> &t ) : my_b(b), my_touches(t) {}  in parallel_put_get()
154     tbb::flow::buffer_node<T> b(g);  in test_reservation()  local
156     b.try_put(T(1));  in test_reservation()
157     b.try_put(T(2));  in test_reservation()
158     b.try_put(T(3));  in test_reservation()
161     CHECK_MESSAGE( b.try_reserve(v) == true, "" );  in test_reservation()
162     CHECK_MESSAGE( b.try_release() == true, "" );  in test_reservation()
165     CHECK_MESSAGE( b.try_reserve(v) == true, "" );  in test_reservation()
166     CHECK_MESSAGE( b.try_consume() == true, "" );  in test_reservation()
171     CHECK_MESSAGE( b.try_get(v) == true, "" );  in test_reservation()
176     CHECK_MESSAGE( b.try_reserve(v) == true, "" );  in test_reservation()
177     CHECK_MESSAGE( b.try_release() == true, "" );  in test_reservation()
180     CHECK_MESSAGE( b.try_reserve(v) == true, "" );  in test_reservation()
181     CHECK_MESSAGE( b.try_consume() == true, "" );  in test_reservation()
201     tbb::flow::buffer_node<T> b(g);  in test_parallel()  local
207     NativeParallelFor( num_threads, parallel_puts<T>(b) );  in test_parallel()
213         spin_try_get( b, j );  in test_parallel()
223     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_parallel()
226     NativeParallelFor( num_threads, parallel_puts<T>(b) );  in test_parallel()
230         NativeParallelFor( num_threads, parallel_gets<T>(b, t) );  in test_parallel()
235     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_parallel()
241         NativeParallelFor( num_threads, parallel_put_get<T>(b, t) );  in test_parallel()
246     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_parallel()
249     tbb::flow::make_edge( b, b2 );  in test_parallel()
252     NativeParallelFor( num_threads, parallel_puts<T>(b) );  in test_parallel()
261     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_parallel()
269     CHECK_MESSAGE( b.remove_successor( b2 ), "" );  in test_parallel()
271     NativeParallelFor( num_threads, parallel_puts<T>(b) );  in test_parallel()
273     tbb::flow::buffer_node<T> b_copy(b);  in test_parallel()
281     CHECK_MESSAGE( b.register_successor(b_copy) == true, "" );  in test_parallel()
292     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_parallel()
319     tbb::flow::buffer_node<T> b(g);  in test_serial()  local
327     CHECK_MESSAGE( register_predecessor<T>( b, b2 ) == false, "" );  in test_serial()
328     CHECK_MESSAGE( remove_predecessor<T>( b, b2 ) == false, "" );  in test_serial()
329     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_serial()
337         bool msg = b.try_put( T(i) );  in test_serial()
344         spin_try_get( b, j );  in test_serial()
350     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_serial()
353     tbb::flow::make_edge(b, b2);  in test_serial()
357         bool msg = b.try_put( T(i) );  in test_serial()
369     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_serial()
374     tbb::flow::remove_edge(b, b2);  in test_serial()
375     CHECK_MESSAGE( b.try_put( 1 ) == true, "" );  in test_serial()
380     CHECK_MESSAGE( b.try_get( j ) == true, "" );  in test_serial()
384     tbb::flow::make_edge( b, b2 );  in test_serial()
389         bool msg = b.try_put( T(i) );  in test_serial()
401     CHECK_MESSAGE( b.try_get( j ) == false, "" );  in test_serial()
408     tbb::flow::remove_edge(b, b2);  in test_serial()
409     CHECK_MESSAGE( b.try_put( 1 ) == true, "" );  in test_serial()
417     CHECK_MESSAGE( b.try_get( j ) == true, "" );  in test_serial()