Lines Matching refs:b
85 tbb::flow::broadcast_node<T> b(g); in test_serial_broadcasts() local
93 tbb::flow::make_edge( b, *receivers[r] ); in test_serial_broadcasts()
97 CHECK_MESSAGE( b.try_put( (T)n ), "" ); in test_serial_broadcasts()
104 tbb::flow::remove_edge( b, *receivers[r] ); in test_serial_broadcasts()
106 CHECK_MESSAGE( b.try_put( (T)0 ), "" ); in test_serial_broadcasts()
120 native_body( tbb::flow::broadcast_node<T> &b ) : my_b(b) {} in native_body() argument
131 void run_parallel_broadcasts(tbb::flow::graph& g, int p, tbb::flow::broadcast_node<T>& b) { in run_parallel_broadcasts() argument
138 tbb::flow::make_edge( b, *receivers[r] ); in run_parallel_broadcasts()
141 utils::NativeParallelFor( p, native_body<T>( b ) ); in run_parallel_broadcasts()
147 tbb::flow::remove_edge( b, *receivers[r] ); in run_parallel_broadcasts()
149 CHECK_MESSAGE( b.try_put( (T)0 ), "" ); in run_parallel_broadcasts()
159 tbb::flow::broadcast_node<T> b(g); in test_parallel_broadcasts() local
160 run_parallel_broadcasts(g, p, b); in test_parallel_broadcasts()
163 tbb::flow::broadcast_node<T> b_copy(b); in test_parallel_broadcasts()