42 void spin_try_get( tbb::flow::queue_node<T> &q, T &value ) {  in spin_try_get()  argument
44     while ( q.try_get(value) != true ) {  in spin_try_get()
70     parallel_puts( tbb::flow::queue_node<T> &q ) : my_q(q) {}  in parallel_puts()
156     parallel_gets( tbb::flow::queue_node<T> &q, touches<T> &t) : my_q(q), my_touches(t) {}  in parallel_gets()
174     parallel_put_get( tbb::flow::queue_node<T> &q, touches<T> &t ) : my_q(q), my_touches(t) {}  in parallel_put_get()
206     tbb::flow::queue_node<T> q(g);  in test_reservation()  local
208     q.try_put(T(1));  in test_reservation()
209     q.try_put(T(2));  in test_reservation()
210     q.try_put(T(3));  in test_reservation()
213     CHECK_MESSAGE( q.reserve_item(v) == true, "" );  in test_reservation()
215     CHECK_MESSAGE( q.release_reservation() == true, "" );  in test_reservation()
218     CHECK_MESSAGE( q.reserve_item(v) == true, "" );  in test_reservation()
220     CHECK_MESSAGE( q.consume_reservation() == true, "" );  in test_reservation()
224     CHECK_MESSAGE( q.try_get(v) == true, "" );  in test_reservation()
229     CHECK_MESSAGE( q.reserve_item(v) == true, "" );  in test_reservation()
231     CHECK_MESSAGE( q.release_reservation() == true, "" );  in test_reservation()
234     CHECK_MESSAGE( q.reserve_item(v) == true, "" );  in test_reservation()
236     CHECK_MESSAGE( q.consume_reservation() == true, "" );  in test_reservation()
254     tbb::flow::queue_node<T> q(g);  in test_parallel()  local
261         utils::NativeParallelFor( num_threads, parallel_puts<T>(q) );  in test_parallel()
267             spin_try_get( q, j );  in test_parallel()
278         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_parallel()
281         utils::NativeParallelFor( num_threads, parallel_puts<T>(q) );  in test_parallel()
285             utils::NativeParallelFor( num_threads, parallel_gets<T>(q, t) );  in test_parallel()
290         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_parallel()
296             utils::NativeParallelFor( num_threads, parallel_put_get<T>(q, t2) );  in test_parallel()
301         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_parallel()
304         tbb::flow::make_edge( q, q2 );  in test_parallel()
307         utils::NativeParallelFor( num_threads, parallel_puts<T>(q) );  in test_parallel()
316         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_parallel()
324         CHECK_MESSAGE( remove_successor( q, q2 ), "" );  in test_parallel()
325         utils::NativeParallelFor( num_threads, parallel_puts<T>(q) );  in test_parallel()
326         tbb::flow::queue_node<T> q_copy(q);  in test_parallel()
330         CHECK_MESSAGE( register_successor( q, q_copy ) == true, "" );  in test_parallel()
338         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_parallel()
359     tbb::flow::queue_node<T> q(g);  in test_serial()  local
371         CHECK_MESSAGE( register_predecessor( q, q2 ) == false, "" );  in test_serial()
372         CHECK_MESSAGE( remove_predecessor( q, q2 ) == false, "" );  in test_serial()
373         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_serial()
381             bool msg = q.try_put( T(i) );  in test_serial()
388             spin_try_get( q, j );  in test_serial()
393         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_serial()
396         tbb::flow::make_edge( q, q2 );  in test_serial()
399             bool msg = q.try_put( T(i) );  in test_serial()
411         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_serial()
416         tbb::flow::remove_edge( q, q2 );  in test_serial()
417         CHECK_MESSAGE( q.try_put( 1 ) == true, "" );  in test_serial()
422         CHECK_MESSAGE( q.try_get( j ) == true, "" );  in test_serial()
426         tbb::flow::make_edge( q, q2 );  in test_serial()
430             bool msg = q.try_put( T(i) );  in test_serial()
441         CHECK_MESSAGE( q.try_get( j ) == false, "" );  in test_serial()
448         tbb::flow::remove_edge( q,  q2 );  in test_serial()
449         CHECK_MESSAGE( q.try_put( 1 ) == true, "" );  in test_serial()
457         CHECK_MESSAGE( q.try_get( j ) == true, "" );  in test_serial()
543     tbb::flow::queue_node<int> q(g);
545     bool res = q.try_put(42);
549     res = q.try_reserve(val);
554     CHECK_MESSAGE((q.try_reserve(out_arg) == false), "Reserving a reserved node should fail.");
558     CHECK_MESSAGE((q.try_get(out_arg) == false), "Getting from reserved node should fail.");