37 template< typename R >
40     tbb::flow::write_once_node<R> n(g);  in simple_read_write_tests()
43         R v0(0);  in simple_read_write_tests()
44         std::vector< std::shared_ptr<harness_counting_receiver<R>> > r;  in simple_read_write_tests()
46             r.push_back( std::make_shared<harness_counting_receiver<R>>(g) );  in simple_read_write_tests()
54             CHECK_MESSAGE( n.try_put( static_cast<R>(N+1) ), "" );  in simple_read_write_tests()
57             CHECK_MESSAGE( v0 == R(N+1), "" );  in simple_read_write_tests()
72             R v1(static_cast<R>(i));  in simple_read_write_tests()
83                 R v2(0);  in simple_read_write_tests()
86                     CHECK_MESSAGE( R(N+1) == v2, "" );  in simple_read_write_tests()
88                     CHECK_MESSAGE( R(1) == v2, "" );  in simple_read_write_tests()
98         CHECK_MESSAGE( n.try_put( R(0) ) == false, "" );  in simple_read_write_tests()
109 template< typename R >
111     tbb::flow::write_once_node<R> &my_node;
115     native_body( tbb::flow::write_once_node<R> &n ) : my_node(n) {}  in native_body()
118         R v1(static_cast<R>(i));  in operator ()()
122         CHECK_MESSAGE( v1 == R(-1), "" );  in operator ()()
126 template< typename R >
129     tbb::flow::write_once_node<R> n(g);  in parallel_read_write_tests()
131     std::vector< tbb::flow::write_once_node<R> > wo_vec(2, n);  in parallel_read_write_tests()
135             std::vector< std::shared_ptr<harness_counting_receiver<R>> > r;  in parallel_read_write_tests()
137                 r.push_back( std::make_shared<harness_counting_receiver<R>>(g) );  in parallel_read_write_tests()
144             R v0;  in parallel_read_write_tests()
148             CHECK_MESSAGE( wo_vec[node_idx].try_put( R(-1) ), "" );  in parallel_read_write_tests()
154             utils::NativeParallelFor( nthreads, native_body<R>( wo_vec[node_idx] ) );  in parallel_read_write_tests()
163             CHECK_MESSAGE( wo_vec[node_idx].try_put( R(0) ) == false, "" );  in parallel_read_write_tests()