Lines Matching refs:ow_vec
109 std::vector< tbb::flow::overwrite_node<R> > ow_vec(2, n); in parallel_read_write_tests() local
111 for (size_t node_idx=0; node_idx<ow_vec.size(); ++node_idx) { in parallel_read_write_tests()
119 tbb::flow::make_edge( ow_vec[node_idx], *r[i] ); in parallel_read_write_tests()
122 CHECK_MESSAGE( ow_vec[node_idx].is_valid() == false, "" ); in parallel_read_write_tests()
123 CHECK_MESSAGE( ow_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()
130 utils::NativeParallelFor( nthreads, native_body<R>( ow_vec[node_idx] ) ); in parallel_read_write_tests()
137 tbb::flow::remove_edge( ow_vec[node_idx], *r[i] ); in parallel_read_write_tests()
139 CHECK_MESSAGE( ow_vec[node_idx].try_put( R(0) ), "" ); in parallel_read_write_tests()
144 ow_vec[node_idx].clear(); in parallel_read_write_tests()
145 CHECK_MESSAGE( ow_vec[node_idx].is_valid() == false, "" ); in parallel_read_write_tests()
146 CHECK_MESSAGE( ow_vec[node_idx].try_get( v0 ) == false, "" ); in parallel_read_write_tests()