53 template< typename T >
54 class counting_array_receiver : public tbb::flow::receiver<T> {
71     tbb::task * try_put_task( const T &v ) override {  in try_put_task()
81 template< typename T >
85     tbb::flow::broadcast_node<T> b(g);  in test_serial_broadcasts()
88         std::vector< std::shared_ptr<counting_array_receiver<T>> > receivers;  in test_serial_broadcasts()
90             receivers.push_back( std::make_shared<counting_array_receiver<T>>(g) );  in test_serial_broadcasts()
97             CHECK_MESSAGE( b.try_put( (T)n ), "" );  in test_serial_broadcasts()
106         CHECK_MESSAGE( b.try_put( (T)0 ), "" );  in test_serial_broadcasts()
113 template< typename T >
116     tbb::flow::broadcast_node<T> &my_b;
120     native_body( tbb::flow::broadcast_node<T> &b ) : my_b(b) {}  in native_body()
124             CHECK_MESSAGE( my_b.try_put( (T)n ), "" );  in operator ()()
130 template< typename T >
131 void run_parallel_broadcasts(tbb::flow::graph& g, int p, tbb::flow::broadcast_node<T>& b) {  in run_parallel_broadcasts()
133         std::vector< std::shared_ptr<counting_array_receiver<T>> > receivers;  in run_parallel_broadcasts()
135             receivers.push_back( std::make_shared< counting_array_receiver<T> >(g) );  in run_parallel_broadcasts()
141         utils::NativeParallelFor( p, native_body<T>( b ) );  in run_parallel_broadcasts()
149         CHECK_MESSAGE( b.try_put( (T)0 ), "" );  in run_parallel_broadcasts()
155 template< typename T >
159     tbb::flow::broadcast_node<T> b(g);  in test_parallel_broadcasts()
163     tbb::flow::broadcast_node<T> b_copy(b);  in test_parallel_broadcasts()
169 template<typename T>
172     tbb::flow::broadcast_node<T> b0(g);  in test_resets()
173     tbb::flow::broadcast_node<T> b1(g);  in test_resets()
174     tbb::flow::queue_node<T> q0(g);  in test_resets()
177     T j;  in test_resets()
181         for(T i= 0; i <= 3; i += 1) {  in test_resets()
185         for(T i= 0; i <= 3; i += 1) {  in test_resets()
195     for(T i= 0; i <= 3; i += 1) {  in test_resets()
200     for(T i= 0; i <= 3; i += 1) {  in test_resets()