36 template< typename R >
39     tbb::flow::overwrite_node<R> n(g);  in simple_read_write_tests()
42         R v0(N+1);  in simple_read_write_tests()
43         std::vector< std::shared_ptr<harness_counting_receiver<R>> > r;  in simple_read_write_tests()
45             r.push_back( std::make_shared<harness_counting_receiver<R>>(g) );  in simple_read_write_tests()
51             CHECK_MESSAGE( n.try_put( static_cast<R>(N) ), "" );  in simple_read_write_tests()
54             CHECK_MESSAGE( v0 == R(N), "" );  in simple_read_write_tests()
62             R v1(static_cast<R>(i));  in simple_read_write_tests()
66                 R v2(0);  in simple_read_write_tests()
78         CHECK_MESSAGE( n.try_put( R(0) ), "" );  in simple_read_write_tests()
89 template< typename R >
91     tbb::flow::overwrite_node<R> &my_node;
95     native_body( tbb::flow::overwrite_node<R> &n ) : my_node(n) {}  in native_body()
98         R v1(static_cast<R>(i));  in operator ()()
104 template< typename R >
107     tbb::flow::overwrite_node<R> n(g);  in parallel_read_write_tests()
109     std::vector< tbb::flow::overwrite_node<R> > ow_vec(2, n);  in parallel_read_write_tests()
113             std::vector< std::shared_ptr<harness_counting_receiver<R>> > r;  in parallel_read_write_tests()
115                 r.push_back( std::make_shared<harness_counting_receiver<R>>(g) );  in parallel_read_write_tests()
121             R v0;  in parallel_read_write_tests()
130             utils::NativeParallelFor( nthreads, native_body<R>( ow_vec[node_idx] ) );  in parallel_read_write_tests()
139             CHECK_MESSAGE( ow_vec[node_idx].try_put( R(0) ), "" );  in parallel_read_write_tests()