Searched refs:ow_vec (Results 1 – 1 of 1) sorted by relevance
109 std::vector< tbb::flow::overwrite_node<R> > ow_vec(2, n); in parallel_read_write_tests() local111 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()[all …]