Lines Matching refs:wo_vec
131 std::vector< tbb::flow::write_once_node<R> > wo_vec(2, n); in parallel_read_write_tests() local
133 for (size_t node_idx=0; node_idx<wo_vec.size(); ++node_idx) { in parallel_read_write_tests()
142 tbb::flow::make_edge( wo_vec[node_idx], *r[i] ); in parallel_read_write_tests()
145 CHECK_MESSAGE( wo_vec[node_idx].is_valid() == false, "" ); in parallel_read_write_tests()
146 CHECK_MESSAGE( wo_vec[node_idx].try_get( v0 ) == false, "" ); 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()
161 tbb::flow::remove_edge( wo_vec[node_idx], *r[i] ); in parallel_read_write_tests()
163 CHECK_MESSAGE( wo_vec[node_idx].try_put( R(0) ) == false, "" ); in parallel_read_write_tests()
168 wo_vec[node_idx].clear(); in parallel_read_write_tests()
169 CHECK_MESSAGE( wo_vec[node_idx].is_valid() == false, "" ); in parallel_read_write_tests()
170 CHECK_MESSAGE( wo_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()