131 void run_parallel_broadcasts(tbb::flow::graph& g, int p, tbb::flow::broadcast_node<T>& b) {  in run_parallel_broadcasts()  argument
141         utils::NativeParallelFor( p, native_body<T>( b ) );  in run_parallel_broadcasts()
145                 CHECK_MESSAGE( (int)(*receivers[r])[n] == p, "" );  in run_parallel_broadcasts()
151             CHECK_MESSAGE( (int)(*receivers[r])[0] == p, "" );  in run_parallel_broadcasts()
156 void test_parallel_broadcasts(int p) {  in test_parallel_broadcasts()  argument
160     run_parallel_broadcasts(g, p, b);  in test_parallel_broadcasts()
164     run_parallel_broadcasts(g, p, b_copy);  in test_parallel_broadcasts()
255     for( unsigned int p=utils::MinThread; p<=utils::MaxThread; ++p ) {  variable
256        test_parallel_broadcasts<int>(p);
257        test_parallel_broadcasts<float>(p);
258        test_parallel_broadcasts<int_convertable_type>(p);